OSMQ
v2.0.1

osmq.broker.sorter
Class MessageSortingThread

java.lang.Object
  extended byosmq.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)


Field Summary
 
Fields inherited from interface osmq.util.Threadable
HIGH_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
MessageSortingThread(TopicalSubscriberQueues subs, MQue pipeline)
           
 
Method Summary
 int getPriority()
           
 void onException(java.lang.Exception e)
          Notify user of an exception.
 boolean repeatableProcess()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageSortingThread

public MessageSortingThread(TopicalSubscriberQueues subs,
                            MQue pipeline)
Method Detail

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

(c) 2000 - 2003 MQue Systems
All Rights Reserved