Package org.apache.axis2.transport.testkit.axis2.util

Class MessageLevelMetricsCollectorImpl

  • All Implemented Interfaces:
    org.apache.axis2.transport.base.MessageLevelMetricsCollector
    public class MessageLevelMetricsCollectorImpl
extends Object
implements org.apache.axis2.transport.base.MessageLevelMetricsCollector
    Message level metrics collector implementation used during the tests to check that message level metrics collection is implemented.

    On any update, all threads waiting for an instance of this class are notified.

    • Constructor Detail

      • MessageLevelMetricsCollectorImpl

        public MessageLevelMetricsCollectorImpl()

    • Method Detail

      • incrementBytesReceived

        public void incrementBytesReceived​(long size)
        Specified by:
        incrementBytesReceived in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementBytesSent

        public void incrementBytesSent​(long size)
        Specified by:
        incrementBytesSent in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementFaultsReceiving

        public void incrementFaultsReceiving​(int errorCode)
        Specified by:
        incrementFaultsReceiving in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementFaultsSending

        public void incrementFaultsSending​(int errorCode)
        Specified by:
        incrementFaultsSending in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementMessagesReceived

        public void incrementMessagesReceived()
        Specified by:
        incrementMessagesReceived in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementMessagesSent

        public void incrementMessagesSent()
        Specified by:
        incrementMessagesSent in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementTimeoutsReceiving

        public void incrementTimeoutsReceiving()
        Specified by:
        incrementTimeoutsReceiving in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • incrementTimeoutsSending

        public void incrementTimeoutsSending()
        Specified by:
        incrementTimeoutsSending in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • notifyReceivedMessageSize

        public void notifyReceivedMessageSize​(long size)
        Specified by:
        notifyReceivedMessageSize in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • notifySentMessageSize

        public void notifySentMessageSize​(long size)
        Specified by:
        notifySentMessageSize in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • reportReceivingFault

        public void reportReceivingFault​(int errorCode)
        Specified by:
        reportReceivingFault in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • reportResponseCode

        public void reportResponseCode​(int respCode)
        Specified by:
        reportResponseCode in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • reportSendingFault

        public void reportSendingFault​(int errorCode)
        Specified by:
        reportSendingFault in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector

      • getMessagesSent

        public long getMessagesSent()

      • getBytesSent

        public long getBytesSent()