JXTA

net.jxta.impl.endpoint.endpointMeter
Class InboundMetric

java.lang.Object
  extended by net.jxta.impl.endpoint.endpointMeter.InboundMetric
All Implemented Interfaces:
DocumentSerializable

public class InboundMetric
extends Object
implements DocumentSerializable

Meter corresponding to inbound queue for registered EndpointListeners ServiceName/ServiceParam pair


Constructor Summary
InboundMetric()
           
InboundMetric(InboundMeter inboundMeter)
           
InboundMetric(InboundMetric prototype)
           
 
Method Summary
 boolean equals(Object obj)
           
 long getAverageInboundDropTime()
          The Average of time in queue for dropped messages
 long getAverageInboundProcessTime()
          The Average clock time for local listeners to process messages
 long getAverageTimeInInboundQueue()
          The Average of time in queue for messages
 int getNumInboundDeQueued()
          The Number of Inbound Messages Dequeued
 int getNumInboundDropped()
          The Number of Inbound Messages Dropped
 int getNumInboundProcessed()
           
 int getNumInboundQueued()
          The Number of Inbound Messages Queued
 String getServiceName()
          The Service Name for this Metric
 String getServiceParameter()
          The Service Parameter for this Metric
 long getTimeInInboundQueue()
          The Sum of time in queue for messages in queue
 long getTimeToDropInbound()
          The Sum of time for all dropped messages from queue
 long getTimeToProcessInbound()
          The Sum of time for local listeners to process messages
 int hashCode()
           
(package private)  void inboundMessageDeQueued(Message message, long time)
           
(package private)  void inboundMessageDropped(Message message, long time)
           
(package private)  void inboundMessageProcessed(Message message, long time)
           
(package private)  void inboundMessageQueued(Message message)
           
 void initializeFrom(Element element)
           
 boolean matches(String serviceName, String serviceParam)
           
 void mergeMetrics(InboundMetric other)
           
 void serializeTo(Element element)
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InboundMetric

public InboundMetric(InboundMeter inboundMeter)

InboundMetric

public InboundMetric(InboundMetric prototype)

InboundMetric

public InboundMetric()
Method Detail

getServiceName

public String getServiceName()
The Service Name for this Metric


getServiceParameter

public String getServiceParameter()
The Service Parameter for this Metric


getNumInboundQueued

public int getNumInboundQueued()
The Number of Inbound Messages Queued


getNumInboundDropped

public int getNumInboundDropped()
The Number of Inbound Messages Dropped


getTimeToDropInbound

public long getTimeToDropInbound()
The Sum of time for all dropped messages from queue


getNumInboundDeQueued

public int getNumInboundDeQueued()
The Number of Inbound Messages Dequeued


getTimeInInboundQueue

public long getTimeInInboundQueue()
The Sum of time in queue for messages in queue


getNumInboundProcessed

public int getNumInboundProcessed()

getTimeToProcessInbound

public long getTimeToProcessInbound()
The Sum of time for local listeners to process messages


getAverageTimeInInboundQueue

public long getAverageTimeInInboundQueue()
The Average of time in queue for messages


getAverageInboundDropTime

public long getAverageInboundDropTime()
The Average of time in queue for dropped messages


getAverageInboundProcessTime

public long getAverageInboundProcessTime()
The Average clock time for local listeners to process messages


equals

public boolean equals(Object obj)
Overrides:
equals in class Object

matches

public boolean matches(String serviceName,
                       String serviceParam)

hashCode

public int hashCode()
Overrides:
hashCode in class Object

inboundMessageQueued

void inboundMessageQueued(Message message)

inboundMessageDropped

void inboundMessageDropped(Message message,
                           long time)

inboundMessageDeQueued

void inboundMessageDeQueued(Message message,
                            long time)

inboundMessageProcessed

void inboundMessageProcessed(Message message,
                             long time)

mergeMetrics

public void mergeMetrics(InboundMetric other)

serializeTo

public void serializeTo(Element element)
                 throws DocumentSerializationException
Specified by:
serializeTo in interface DocumentSerializable
Throws:
DocumentSerializationException

initializeFrom

public void initializeFrom(Element element)
                    throws DocumentSerializationException
Specified by:
initializeFrom in interface DocumentSerializable
Throws:
DocumentSerializationException

JXSE