org.ocd.msgbus
Class MsgBusProcessor

java.lang.Object
  |
  +--org.ocd.msgbus.MsgBusProcessor

public class MsgBusProcessor

extends java.lang.Object

Field Summary

protected java.util.Vector	msgPool
protected org.ocd.msgbus.MsgBusProcessor.ProcessorThread	thread

Constructor Summary

MsgBusProcessor()

Method Summary

void	addMessage(MsgBusTopic topic, MsgBusMessage msg, IMsgBusListener resultListener) Add Message to the Pool to be delivered
protected org.ocd.msgbus.MsgBusProcessor.Bundle	getNextBundle() Returns the next Bundle to Deliver This method blocks until a Bundle is ready

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

msgPool

protected java.util.Vector msgPool

thread

protected org.ocd.msgbus.MsgBusProcessor.ProcessorThread thread

Constructor Detail

MsgBusProcessor

public MsgBusProcessor()

Method Detail

addMessage

public void addMessage(MsgBusTopic topic,
                       MsgBusMessage msg,
                       IMsgBusListener resultListener)

Add Message to the Pool to be delivered

getNextBundle

protected org.ocd.msgbus.MsgBusProcessor.Bundle getNextBundle()

Returns the next Bundle to Deliver This method blocks until a Bundle is ready

Returns:

bundle