A C D E G H M N O P R S T

A

AbstractResponse - Class in com.github.iamiddy.syncrest.asynchprocessor

Created by iddymagohe on 1/9/16.

AbstractResponse() - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.AbstractResponse

addObservers(ResponseObserver) - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

Adds an observer to the Map of responseObservers for this response, provided that it is not the same as some observer already in the set.

App - Class in com.github.iamiddy.syncrest.asynchprocessor

Hello world!

App() - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.App

applyResponse(ResponseObservable, T) - Method in interface com.github.iamiddy.syncrest.asynchprocessor.ResponseObserver

Applies a response to ResponseObserver and delete this Observer from responseObservable

applyResponse(ResponseObservable, T) - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

C

call() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

clearChanged() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

Indicates that this object has no longer changed, or that it has already notified all of its observers of its most recent change, so that the hasChanged method will now return false.

com.github.iamiddy.syncrest.asynchprocessor - package com.github.iamiddy.syncrest.asynchprocessor

com.github.iamiddy.syncrest.asynchprocessor.domain - package com.github.iamiddy.syncrest.asynchprocessor.domain

com.github.iamiddy.syncrest.asynchprocessor.service - package com.github.iamiddy.syncrest.asynchprocessor.service

countObservers() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

Returns the number of observers of this Observable object.

D

deleteObserver(ResponseObserver) - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

Deletes an observer from a map of observers of this object.

E

equals(Object) - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

G

getEventId() - Method in class com.github.iamiddy.syncrest.asynchprocessor.AbstractResponse

getEventId() - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.RequestEvent

getEventId() - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.ResponseEvent

getEventId() - Method in interface com.github.iamiddy.syncrest.asynchprocessor.ResponseObserver

getEventId() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

getInstance(MessageProducer, MessageConsumer) - Static method in class com.github.iamiddy.syncrest.asynchprocessor.service.SyncAsyncProcessor

getRequestBody() - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.RequestEvent

getResponse() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

getResponseBody() - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.ResponseEvent

H

hasChanged() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

Tests if this object has changed.

hashCode() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

M

main(String[]) - Static method in class com.github.iamiddy.syncrest.asynchprocessor.App

MessageConsumer - Class in com.github.iamiddy.syncrest.asynchprocessor.service

MessageConsumer() - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.service.MessageConsumer

MessageConsumerImpl - Class in com.github.iamiddy.syncrest.asynchprocessor.service

MessageConsumerImpl() - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.service.MessageConsumerImpl

MessageProducer - Interface in com.github.iamiddy.syncrest.asynchprocessor.service

Created by iddymagohe on 1/9/16.

N

notifyObservers(T) - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

If this object has changed, as indicated by the hasChanged method, then find and notify only one Observer and then call the clearChanged method to indicate that this object has no longer changed.

O

onMessage(R) - Method in class com.github.iamiddy.syncrest.asynchprocessor.service.MessageConsumer

On a message from message-bus, remember to call setChanged and notifyObservers otherwise requests will never get a response

P

produceMessage(R) - Method in interface com.github.iamiddy.syncrest.asynchprocessor.service.MessageProducer

produceMessage(R) - Method in class com.github.iamiddy.syncrest.asynchprocessor.service.SampleService

Takes in a RequestEvent, reverse it's body and put the response in a blocking queue.

R

RequestEvent - Class in com.github.iamiddy.syncrest.asynchprocessor.domain

Created by iddymagohe on 1/9/16.

RequestEvent(String, String) - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.domain.RequestEvent

ResponseEvent - Class in com.github.iamiddy.syncrest.asynchprocessor.domain

Created by iddymagohe on 1/9/16.

ResponseEvent(String, String) - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.domain.ResponseEvent

ResponseObservable - Class in com.github.iamiddy.syncrest.asynchprocessor

Created by iddymagohe on 1/9/16.

ResponseObservable() - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

ResponseObserver<T extends AbstractResponse> - Interface in com.github.iamiddy.syncrest.asynchprocessor

Created by iddymagohe on 1/9/16.

ResponseObserverImpl<T extends AbstractResponse> - Class in com.github.iamiddy.syncrest.asynchprocessor

Created by iddymagohe on 1/9/16.

ResponseObserverImpl(String) - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.ResponseObserverImpl

run() - Method in class com.github.iamiddy.syncrest.asynchprocessor.service.SampleService

S

SampleService - Class in com.github.iamiddy.syncrest.asynchprocessor.service

SampleService(BlockingQueue<ResponseEvent>, MessageConsumer) - Constructor for class com.github.iamiddy.syncrest.asynchprocessor.service.SampleService

sendAndReceive(R, long) - Method in class com.github.iamiddy.syncrest.asynchprocessor.service.SyncAsyncProcessor

takes in a request creates an Observer to subscribe for a response submits a task asynchronously to executorService for a response whenever it's available or timesout Produces a message to a message bus for backend processing

setChanged() - Method in class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

Marks this Observable object as having been changed; the hasChanged method will now return true.

setRequestBody(String) - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.RequestEvent

setResponseBody(String) - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.ResponseEvent

SyncAsyncProcessor - Class in com.github.iamiddy.syncrest.asynchprocessor.service

T

toString() - Method in class com.github.iamiddy.syncrest.asynchprocessor.domain.ResponseEvent

A C D E G H M N O P R S T