Class MetricsCollector


  • public class MetricsCollector
    extends Object
    Collects metrics related to a transport that has metrics support enabled
    • Constructor Detail

      • MetricsCollector

        public MetricsCollector()
    • Method Detail

      • reset

        public void reset()
      • getLevel

        public int getLevel()
      • setLevel

        public void setLevel​(int level)
      • getLastResetTime

        public long getLastResetTime()
      • getMessagesReceived

        public long getMessagesReceived()
      • getFaultsReceiving

        public long getFaultsReceiving()
      • getTimeoutsReceiving

        public long getTimeoutsReceiving()
      • getBytesReceived

        public long getBytesReceived()
      • getMessagesSent

        public long getMessagesSent()
        Get the number of messages sent. This metrics is incremented after a message has been completely and successfully put on the wire.
        Returns:
        the number of messages sent
      • getFaultsSending

        public long getFaultsSending()
      • getTimeoutsSending

        public long getTimeoutsSending()
      • getBytesSent

        public long getBytesSent()
      • getMinSizeReceived

        public long getMinSizeReceived()
      • getMaxSizeReceived

        public long getMaxSizeReceived()
      • getMinSizeSent

        public long getMinSizeSent()
      • getMaxSizeSent

        public long getMaxSizeSent()
      • getAvgSizeReceived

        public double getAvgSizeReceived()
      • getAvgSizeSent

        public double getAvgSizeSent()
      • getResponseCodeTable

        public Map<Integer,​Long> getResponseCodeTable()
      • incrementMessagesReceived

        public void incrementMessagesReceived()
      • incrementFaultsReceiving

        public void incrementFaultsReceiving()
      • incrementTimeoutsReceiving

        public void incrementTimeoutsReceiving()
      • incrementBytesReceived

        public void incrementBytesReceived​(long size)
      • incrementMessagesSent

        public void incrementMessagesSent()
      • incrementFaultsSending

        public void incrementFaultsSending()
      • incrementTimeoutsSending

        public void incrementTimeoutsSending()
      • incrementBytesSent

        public void incrementBytesSent​(long size)
      • notifyReceivedMessageSize

        public void notifyReceivedMessageSize​(long size)
      • notifySentMessageSize

        public void notifySentMessageSize​(long size)
      • reportResponseCode

        public void reportResponseCode​(int respCode)
      • incrementMessagesReceived

        public void incrementMessagesReceived​(MessageContext mc)
      • incrementFaultsReceiving

        public void incrementFaultsReceiving​(int errorCode,
                                             MessageContext mc)
      • incrementTimeoutsReceiving

        public void incrementTimeoutsReceiving​(MessageContext mc)
      • incrementBytesReceived

        public void incrementBytesReceived​(MessageContext mc,
                                           long size)
      • incrementMessagesSent

        public void incrementMessagesSent​(MessageContext mc)
      • incrementFaultsSending

        public void incrementFaultsSending​(int errorCode,
                                           MessageContext mc)
      • incrementTimeoutsSending

        public void incrementTimeoutsSending​(MessageContext mc)
      • incrementBytesSent

        public void incrementBytesSent​(MessageContext mc,
                                       long size)
      • notifyReceivedMessageSize

        public void notifyReceivedMessageSize​(MessageContext mc,
                                              long size)
      • notifySentMessageSize

        public void notifySentMessageSize​(MessageContext mc,
                                          long size)
      • reportResponseCode

        public void reportResponseCode​(MessageContext mc,
                                       int respCode)