Package org.apache.activemq.artemis.core.server

Interface ConsumerInfo

All Known Subinterfaces:
ServerConsumer
All Known Implementing Classes:
ServerConsumerImpl
public interface ConsumerInfo

  • Method Details

    • getSequentialID

      long getSequentialID()
      an unique sequential ID for this consumer

    • getQueueName

      SimpleString getQueueName()
      Returns name of the queue that is being consumed.
      Returns:
      name of the queue that is being consumed

    • getQueueType

      RoutingType getQueueType()
      Returns routing type of the queue that is being consumed.
      Returns:
      routing type of the queue that is being consumed

    • getQueueAddress

      SimpleString getQueueAddress()
      Returns address of the queue that is being consumed.
      Returns:
      address of the queue that is being consumed

    • getFilterString

      SimpleString getFilterString()

    • getSessionName

      String getSessionName()

    • getConnectionClientID

      String getConnectionClientID()

    • getConnectionProtocolName

      String getConnectionProtocolName()
      Returns the name of the protocol for this Remoting Connection.
      Returns:
      the name of the protocol for this Remoting Connection

    • getConnectionLocalAddress

      String getConnectionLocalAddress()
      Returns a string representation of the local IP address this connection is connected to; useful when the server is configured at 0.0.0.0 (or multiple IPs).
      Returns:
      a string representation of the local IP address this connection is connected to; useful when the server is configured at 0.0.0.0 (or multiple IPs)

    • getConnectionRemoteAddress

      String getConnectionRemoteAddress()
      Returns a string representation of the remote address this connection is connected to.
      Returns:
      a string representation of the remote address this connection is connected to

    • getMessagesInTransit

      int getMessagesInTransit()
      Returns how many messages are out for delivery but not yet acknowledged.
      Returns:
      how many messages are out for delivery but not yet acknowledged

    • getMessagesInTransitSize

      long getMessagesInTransitSize()
      Returns the combined size of all the messages out for delivery but not yet acknowledged.
      Returns:
      the combined size of all the messages out for delivery but not yet acknowledged

    • getMessagesDelivered

      long getMessagesDelivered()
      Returns the total number of messages sent to a consumer including redeliveries that have been acknowledged.
      Returns:
      the total number of messages sent to a consumer including redeliveries that have been acknowledged

    • getMessagesDeliveredSize

      long getMessagesDeliveredSize()
      Returns the total size of all the messages delivered to the consumer including redelivered messages.
      Returns:
      the total size of all the messages delivered to the consumer including redelivered messages

    • getMessagesAcknowledged

      long getMessagesAcknowledged()
      Returns the number of messages acknowledged by this consumer since it was created.
      Returns:
      the number of messages acknowledged by this consumer since it was created

    • getMessagesAcknowledgedAwaitingCommit

      int getMessagesAcknowledgedAwaitingCommit()
      Returns the number of acknowledged messages that are awaiting commit an a transaction.
      Returns:
      the number of acknowledged messages that are awaiting commit an a transaction

    • getLastDeliveredTime

      long getLastDeliveredTime()
      Returns the time in milliseconds that the last message was delivered to a consumer.
      Returns:
      the time in milliseconds that the last message was delivered to a consumer

    • getLastAcknowledgedTime

      long getLastAcknowledgedTime()
      Returns the time in milliseconds that the last message was acknowledged by a consumer.
      Returns:
      the time in milliseconds that the last message was acknowledged by a consumer