com.github.iamiddy.syncrest.asynchprocessor.service

Class MessageConsumer

java.lang.Object

com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

com.github.iamiddy.syncrest.asynchprocessor.service.MessageConsumer

Direct Known Subclasses:

MessageConsumerImpl

public abstract class MessageConsumer
extends ResponseObservable

Since:

0.0.1 Created by iddymagohe on 1/9/16.

Author:

iddymagohe

Constructor Summary

Constructors

Constructor and Description
MessageConsumer()

Method Summary

Modifier and Type	Method and Description
<R extends AbstractResponse> void	onMessage(R response) On a message from message-bus, remember to call setChanged and notifyObservers otherwise requests will never get a response

Methods inherited from class com.github.iamiddy.syncrest.asynchprocessor.ResponseObservable

addObservers, clearChanged, countObservers, deleteObserver, hasChanged, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageConsumer

public MessageConsumer()

Method Detail

onMessage

public <R extends AbstractResponse> void onMessage(R response)

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

Type Parameters:

R - type be returned

Parameters:

response - extends AbstractResponse

See Also:

ResponseObservable.setChanged(), ResponseObservable.notifyObservers(AbstractResponse)