public class ISCSubscriber extends java.lang.Object implements ISubscriber
ISCSubscriber.send(com.isomorphic.messaging.ISCMessage) adds message to a queue and ISCSubscriber.nextMessage(long) retrieves them.| Modifier and Type | Method and Description |
|---|---|
ISCMessage | nextMessage(long timeout) retrieves a message from queue |
void | send(ISCMessage message) adds message to a queue |
public void send(ISCMessage message) throws java.lang.Exception
message - the message to sendjava.lang.Exceptionpublic ISCMessage nextMessage(long timeout) throws java.lang.Exception
timeout - time to wait (in milliseconds) for the message to be retrieved, a timeout of -1 specifies wait until a message is availablejava.lang.Exception