osmq.broker.sorter
Class MessageSortingThread
java.lang.Object
osmq.broker.sorter.MessageSortingThread
- All Implemented Interfaces:
- ExceptionListener, Threadable
- public class MessageSortingThread
- extends java.lang.Object
- implements Threadable
takes network messages from an input fifo and places them into the appropriate
output fifos. Fifo selection is based on the value of MSG_RECIPENT and
MSG_TOPIC.
This version increments message sequences (versus FifoMuxNS that does not)
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageSortingThread
public MessageSortingThread(TopicalSubscriberQueues subs,
MQue pipeline)
onException
public void onException(java.lang.Exception e)
- Description copied from interface:
ExceptionListener
- Notify user of an exception.
- Specified by:
onException
in interface ExceptionListener
- Parameters:
e
- the exception.
getPriority
public int getPriority()
- Specified by:
getPriority
in interface Threadable
repeatableProcess
public final boolean repeatableProcess()
throws java.lang.Exception
- Specified by:
repeatableProcess
in interface Threadable
- Throws:
java.lang.Exception