com.github.iamiddy.syncrest.asynchprocessor.service

Class SyncAsyncProcessor

java.lang.Object

com.github.iamiddy.syncrest.asynchprocessor.service.SyncAsyncProcessor

public class SyncAsyncProcessor
extends Object

Author:

iddymagohe Created by iddymagohe on 1/9/16.

Method Summary

Modifier and Type	Method and Description
static SyncAsyncProcessor	getInstance(MessageProducer producer, MessageConsumer messageConsumer)
<R extends AbstractResponse,T extends AbstractResponse> T	sendAndReceive(R request, long timeout) 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static SyncAsyncProcessor getInstance(MessageProducer producer,
                                             MessageConsumer messageConsumer)

sendAndReceive

public <R extends AbstractResponse,T extends AbstractResponse> T sendAndReceive(R request,
                                                                                long timeout)
                                                                         throws InterruptedException,
                                                                                ExecutionException,
                                                                                TimeoutException

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

Type Parameters:

R - extends AbstractResponse

T - extends AbstractResponse

Parameters:

timeout - in Milliseconds

request - for processing

Returns:

T extends AbstractResponse

Throws:

NullPointerException - null request or eventId

InterruptedException - interruption caused

ExecutionException - execution issue

TimeoutException - took longer than the passed milliseconds

See Also:

ResponseObservable.addObservers(ResponseObserver), ExecutorService.submit(Callable), MessageProducer.produceMessage(AbstractResponse)