Class StreamConsumer


  • public class StreamConsumer
    extends 
    Object containing details about Stream Consumer
    Author:
    Nikita Koksharov
    • Constructor Summary

      Constructors 
      Constructor Description
       name, int pending, long idleTime)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long getIdleTime()
      Returns idle time in milliseconds since which this consumer hasn't consumed messages
      getName()
      Returns name of this consumer
      int getPending()
      Returns amount of pending messages for this consumer
      • Methods inherited from class java.lang.

        , , , , , , , , , ,
    • Constructor Detail

      • StreamConsumer

        public StreamConsumer​( name,
                              int pending,
                              long idleTime)
    • Method Detail

      • getPending

        public int getPending()
        Returns amount of pending messages for this consumer
        Returns:
        amount of pending messages
      • getName

        public  getName()
        Returns name of this consumer
        Returns:
        name of consumer
      • getIdleTime

        public long getIdleTime()
        Returns idle time in milliseconds since which this consumer hasn't consumed messages
        Returns:
        idle time in milliseconds