Package com.isomorphic.messaging

Class ISCSubscriber

java.lang.Object
com.isomorphic.messaging.ISCSubscriber
All Implemented Interfaces:
ISubscriber
public class ISCSubscriber extends Object implements 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 Type
    Method
    Description
    ISCMessage
    nextMessage(long timeout)
    retrieves a message from queue
    void
    send(ISCMessage message)
    adds message to a queue

  • Method Details

    • send

      public void send(ISCMessage message) throws Exception
      adds message to a queue
      Parameters:
      message - the message to send
      Throws:
      Exception

    • nextMessage

      public ISCMessage nextMessage(long timeout) throws Exception
      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