Package org.apache.catalina.tribes.group.interceptors

Interface ThroughputInterceptorMBean

  • All Known Implementing Classes:
    ThroughputInterceptor
    public interface ThroughputInterceptorMBean
    MBean interface for managing the ThroughputInterceptor.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      int getInterval()
      Returns the reporting interval in milliseconds.
      double getLastCnt()
      Returns the last message count.
      double getMbAppTx()
      Returns the cumulative amount of data transmitted at the application layer, in MB.
      double getMbRx()
      Returns the cumulative amount of data received, in MB.
      double getMbTx()
      Returns the cumulative amount of data transmitted, in MB.
      java.util.concurrent.atomic.AtomicLong getMsgRxCnt()
      Returns the received message count.
      java.util.concurrent.atomic.AtomicLong getMsgTxCnt()
      Returns the transmitted message count.
      java.util.concurrent.atomic.AtomicLong getMsgTxErr()
      Returns the transmit error count.
      int getOptionFlag()
      Returns the option flag used to determine if this interceptor should process a message.
      long getRxStart()
      Returns the receive start timestamp.
      double getTimeTx()
      Returns the accumulated total transmit time in seconds.
      long getTxStart()
      Returns the transmit start timestamp.
      void report​(double timeTx)
      Reports throughput statistics.
      void setInterval​(int interval)
      Sets the reporting interval in milliseconds.

    • Method Detail

      • getOptionFlag

        int getOptionFlag()
        Returns the option flag used to determine if this interceptor should process a message.
        Returns:
        the option flag

      • getInterval

        int getInterval()
        Returns the reporting interval in milliseconds.
        Returns:
        the interval

      • setInterval

        void setInterval​(int interval)
        Sets the reporting interval in milliseconds.
        Parameters:
        interval - the interval

      • getLastCnt

        double getLastCnt()
        Returns the last message count.
        Returns:
        the last count

      • getMbAppTx

        double getMbAppTx()
        Returns the cumulative amount of data transmitted at the application layer, in MB.
        Returns:
        the amount in MB

      • getMbRx

        double getMbRx()
        Returns the cumulative amount of data received, in MB.
        Returns:
        the amount in MB

      • getMbTx

        double getMbTx()
        Returns the cumulative amount of data transmitted, in MB.
        Returns:
        the amount in MB

      • getMsgRxCnt

        java.util.concurrent.atomic.AtomicLong getMsgRxCnt()
        Returns the received message count.
        Returns:
        the count

      • getMsgTxCnt

        java.util.concurrent.atomic.AtomicLong getMsgTxCnt()
        Returns the transmitted message count.
        Returns:
        the count

      • getMsgTxErr

        java.util.concurrent.atomic.AtomicLong getMsgTxErr()
        Returns the transmit error count.
        Returns:
        the count

      • getRxStart

        long getRxStart()
        Returns the receive start timestamp.
        Returns:
        the timestamp

      • getTimeTx

        double getTimeTx()
        Returns the accumulated total transmit time in seconds.
        Returns:
        the time in seconds

      • getTxStart

        long getTxStart()
        Returns the transmit start timestamp.
        Returns:
        the timestamp

      • report

        void report​(double timeTx)
        Reports throughput statistics.
        Parameters:
        timeTx - the transmit time