cgl.narada.protocol
Class EventBuffer

java.lang.Object
  extended by cgl.narada.protocol.EventBuffer
All Implemented Interfaces:
ProtocolDebugFlags

public class EventBuffer
extends Object
implements ProtocolDebugFlags


Field Summary
 
Fields inherited from interface cgl.narada.protocol.ProtocolDebugFlags
BrokerLocatorCommunicator_Debug, ClientConnectionHandler_Debug, Connection_Debug, ConnectionPropagation_Debug, Destinations_Debug, DuplicateDetection_Debug, EventBuffer_Debug, EventRoutingProtocol_Debug, Gateway_Debug, GatewayInfo_Debug, GatewayPropagation_Debug, JmsProfilePropagation_Debug, LinkCostMatrix_Debug, NodeAdditionProtocol_Debug, NodeAddress_Debug, Path_Debug, PersistentEventRouting_Debug, ProfilePropagationProtocol_Debug, ProtocolException_Debug, ProtocolHandler_Debug, ProtocolID_Debug, ProtocolIDFactory_Debug, RoutingCache_Debug, RtpEventRoutingProtocol_Debug, RtpProfilePropagation_Debug, SecureMessageRouting_Debug, TagValueEventRoutingProtocol_Debug, TagValueProfilePropagation_Debug, XmlEventRoutingProtocol_Debug, XPathProfilePropagation_Debug
 
Method Summary
protected  void addEvent(NBEvent nbEvent)
           
protected  NBEvent getEvent()
           
static EventBuffer getInstance()
           
 int getNumberOfEventsInBuffer()
          This returns the number of events in a given buffer.
 long getTotalPayloadSize()
          This returns the total payload size of ALL the events in the buffer
protected  void new_addEvent(NBEvent nbEvent)
           
protected  NBEvent new_getEvent()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInstance

public static EventBuffer getInstance()

new_addEvent

protected void new_addEvent(NBEvent nbEvent)

new_getEvent

protected NBEvent new_getEvent()
                        throws InterruptedException
Throws:
InterruptedException

addEvent

protected void addEvent(NBEvent nbEvent)

getEvent

protected NBEvent getEvent()
                    throws InterruptedException
Throws:
InterruptedException

getNumberOfEventsInBuffer

public int getNumberOfEventsInBuffer()
This returns the number of events in a given buffer.

Returns:

getTotalPayloadSize

public long getTotalPayloadSize()
This returns the total payload size of ALL the events in the buffer

Returns:


For comments and suggestions please send e-mail to The NaradaBrokering Project