meteor.util
Class MeteorMessageQueue

java.lang.Object
  meteor.util.MeteorMessageQueue

public class MeteorMessageQueue

extends java.lang.Object

The idea is to separate the Incoming and Outgoing messages from the processing of these messages
The concept is that:

• Incoming messages are enqueued in a ReceiveQueue
• Outgoing messages are enqueued in a SendQueue
• A MessageSender thread dequeues messages from the SendQueue and sends them to their appropriate destination
• A MessageReceiver thread dequeues messages from the ReceiveQueue and sends them for processing to the appropriate handler (i.e. MessageHandler)

This is to avoid handling Receiving incoming messages and their processing in the same thread, which could lead to missing messages if processing takes too long

You can enable or disable the queueing by setting a system property called "queueing" to true or false in the build.xml

Author:

Vincent Matossian January 2004

Constructor Summary

MeteorMessageQueue()

Method Summary

java.lang.Object	dequeue()
void	enqueue(java.lang.Object element)
void	setSize(int i)

Methods inherited from class java.lang.Object

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

Constructor Detail

MeteorMessageQueue

public MeteorMessageQueue()

Method Detail

setSize

public void setSize(int i)

enqueue

public void enqueue(java.lang.Object element)

dequeue

public java.lang.Object dequeue()