Package org.apache.synapse.transport.nhttp.util

Class NhttpMetricsCollector

java.lang.Object
org.apache.axis2.transport.base.MetricsCollector
org.apache.synapse.transport.nhttp.util.NhttpMetricsCollector
public class NhttpMetricsCollector extends org.apache.axis2.transport.base.MetricsCollector

This simple extension of the Axis2 transport MetricsCollector implementation, maintains a ConnectionsView instance, which is updated based on the events fired by the NHTTP transport implementation. In addition to the usual events handled by the Axis2 MetricsCollector, this implementation handles two new events:

  • connected (this should get called whenever a new connection is created)
  • disconnected (this should get called whenever an existing connection is closed)

      • These new events are used to update the ConnectionsView at runtime.

  • Field Summary

    Fields inherited from class org.apache.axis2.transport.base.MetricsCollector

    LEVEL_FULL, LEVEL_NONE, LEVEL_TRANSPORT

  • Constructor Summary

    Constructors
    Constructor
    Description
    NhttpMetricsCollector(boolean listener, String schemeName)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    connected()
     
    void
    destroy()
     
    void
    disconnected()
     
    int
    getActiveConnectionCount()
     
    void
    notifyReceivedMessageSize(long l)
     
    void
    notifySentMessageSize(long l)
     
    void
    setConnectionsPerHosts(Map<String,AtomicInteger> activeConnectionsPerHost)
     

    Methods inherited from class org.apache.axis2.transport.base.MetricsCollector

    getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getLevel, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMinSizeReceived, getMinSizeSent, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, incrementBytesReceived, incrementBytesReceived, incrementBytesSent, incrementBytesSent, incrementFaultsReceiving, incrementFaultsReceiving, incrementFaultsSending, incrementFaultsSending, incrementMessagesReceived, incrementMessagesReceived, incrementMessagesSent, incrementMessagesSent, incrementTimeoutsReceiving, incrementTimeoutsReceiving, incrementTimeoutsSending, incrementTimeoutsSending, notifyReceivedMessageSize, notifySentMessageSize, reportResponseCode, reportResponseCode, reset, setLevel

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • NhttpMetricsCollector

      public NhttpMetricsCollector(boolean listener, String schemeName)

  • Method Details

    • destroy

      public void destroy()

    • connected

      public void connected()

    • disconnected

      public void disconnected()

    • notifyReceivedMessageSize

      public void notifyReceivedMessageSize(long l)
      Overrides:
      notifyReceivedMessageSize in class org.apache.axis2.transport.base.MetricsCollector

    • notifySentMessageSize

      public void notifySentMessageSize(long l)
      Overrides:
      notifySentMessageSize in class org.apache.axis2.transport.base.MetricsCollector

    • setConnectionsPerHosts

      public void setConnectionsPerHosts(Map<String,AtomicInteger> activeConnectionsPerHost)

    • getActiveConnectionCount

      public int getActiveConnectionCount()