Package com.isomorphic.messaging
Class ISCSubscriber
java.lang.Object
com.isomorphic.messaging.ISCSubscriber
- All Implemented Interfaces:
ISubscriber
Simple concrete implementation of ISubscriber.
send(com.isomorphic.messaging.ISCMessage)
adds message to a queue and nextMessage(long)
retrieves them.-
Method Summary
Modifier and TypeMethodDescriptionnextMessage
(long timeout) retrieves a message from queuevoid
send
(ISCMessage message) adds message to a queue
-
Method Details
-
send
adds message to a queue- Parameters:
message
- the message to send- Throws:
Exception
-
nextMessage
retrieves a message from queue- Parameters:
timeout
- time to wait (in milliseconds) for the message to be retrieved, a timeout of -1 specifies wait until a message is available- Returns:
- ISCMessage the message retrieved
- Throws:
Exception
-