Project JXTA

net.jxta.impl.resolver.resolverMeter
Class QueryHandlerMeter

java.lang.Object
  extended by net.jxta.impl.resolver.resolverMeter.QueryHandlerMeter

public class QueryHandlerMeter
extends Object


Constructor Summary
QueryHandlerMeter(String handlerName, ResolverServiceMonitor resolverServiceMonitor)
           
 
Method Summary
 QueryHandlerMetric collectMetrics()
           
 void errorWhileProcessingQuery(ResolverQueryMsg query)
           
 void errorWhileProcessingResponse(EndpointAddress srcAddr)
           
 QueryHandlerMetric getCumulativeMetrics()
           
 String getHandlerName()
           
 int getQueryDestinationCount()
           
 QueryDestinationMeter getQueryDestinationMeter(EndpointAddress endpointAddress)
           
 QueryDestinationMeter getQueryDestinationMeter(PeerID peerID)
           
 QueryDestinationMeter getQueryDestinationMeter(String peerIdString)
           
 Enumeration getQueryDestinationMeters()
           
 void propagationQueryDropped()
           
 void queryHopCountDropped()
           
 void queryProcessed(ResolverQueryMsg query, int result, long processTime)
           
 void queryPropagatedInGroup()
           
 void queryPropagatedViaWalker()
           
 void queryPropagateError()
           
 void querySendError()
           
 void querySentInGroup(ResolverQueryMsg query)
           
 void querySentViaUnicast(String peer, ResolverQueryMsg query)
           
 void querySentViaWalker(ResolverQueryMsg query)
           
 void queryToUnregisteredHandler(ResolverQueryMsg query)
           
 void responseProcessed(ResolverResponseMsg response, long processTime, EndpointAddress srcAddr)
           
 void responsePropagateError()
           
 void responseSendError()
           
 void responseSentInGroup(ResolverResponseMsg response)
           
 void responseSentViaUnicast(String peer, ResolverResponseMsg response)
           
 void responseSentViaWalker(ResolverResponseMsg response)
           
 void responseToUnregisteredHandler(EndpointAddress src)
           
 void setRegistered(boolean registered)
           
 String toString()
           
 void unableToPropagate()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

QueryHandlerMeter

public QueryHandlerMeter(String handlerName,
                         ResolverServiceMonitor resolverServiceMonitor)
Method Detail

getCumulativeMetrics

public QueryHandlerMetric getCumulativeMetrics()

getHandlerName

public String getHandlerName()

collectMetrics

public QueryHandlerMetric collectMetrics()

getQueryDestinationMeter

public QueryDestinationMeter getQueryDestinationMeter(EndpointAddress endpointAddress)

getQueryDestinationMeter

public QueryDestinationMeter getQueryDestinationMeter(String peerIdString)

getQueryDestinationMeter

public QueryDestinationMeter getQueryDestinationMeter(PeerID peerID)

toString

public String toString()
Overrides:
toString in class Object

setRegistered

public void setRegistered(boolean registered)

querySentInGroup

public void querySentInGroup(ResolverQueryMsg query)

querySentViaWalker

public void querySentViaWalker(ResolverQueryMsg query)

querySentViaUnicast

public void querySentViaUnicast(String peer,
                                ResolverQueryMsg query)

querySendError

public void querySendError()

queryPropagateError

public void queryPropagateError()

queryHopCountDropped

public void queryHopCountDropped()

unableToPropagate

public void unableToPropagate()

queryPropagatedInGroup

public void queryPropagatedInGroup()

queryPropagatedViaWalker

public void queryPropagatedViaWalker()

propagationQueryDropped

public void propagationQueryDropped()

responseSentViaUnicast

public void responseSentViaUnicast(String peer,
                                   ResolverResponseMsg response)

responseSentViaWalker

public void responseSentViaWalker(ResolverResponseMsg response)

responseSentInGroup

public void responseSentInGroup(ResolverResponseMsg response)

responseSendError

public void responseSendError()

responsePropagateError

public void responsePropagateError()

responseProcessed

public void responseProcessed(ResolverResponseMsg response,
                              long processTime,
                              EndpointAddress srcAddr)

responseToUnregisteredHandler

public void responseToUnregisteredHandler(EndpointAddress src)

errorWhileProcessingResponse

public void errorWhileProcessingResponse(EndpointAddress srcAddr)

queryProcessed

public void queryProcessed(ResolverQueryMsg query,
                           int result,
                           long processTime)

queryToUnregisteredHandler

public void queryToUnregisteredHandler(ResolverQueryMsg query)

errorWhileProcessingQuery

public void errorWhileProcessingQuery(ResolverQueryMsg query)

getQueryDestinationMeters

public Enumeration getQueryDestinationMeters()

getQueryDestinationCount

public int getQueryDestinationCount()

JXTA J2SE