Package org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Class SessionQueueQueryResponseMessage

java.lang.Object
org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage
All Implemented Interfaces:
Packet
Direct Known Subclasses:
SessionQueueQueryResponseMessage_V2
public class SessionQueueQueryResponseMessage extends PacketImpl

  • Field Details

    • name

      protected SimpleString name

    • exists

      protected boolean exists

    • durable

      protected boolean durable

    • consumerCount

      protected int consumerCount

    • messageCount

      protected long messageCount

    • filterString

      protected SimpleString filterString

    • address

      protected SimpleString address

    • temporary

      protected boolean temporary

  • Constructor Details

    • SessionQueueQueryResponseMessage

      public SessionQueueQueryResponseMessage(QueueQueryResult result)

    • SessionQueueQueryResponseMessage

      public SessionQueueQueryResponseMessage()

    • SessionQueueQueryResponseMessage

      public SessionQueueQueryResponseMessage(byte v)

  • Method Details

    • isResponse

      public boolean isResponse()
      Description copied from interface: Packet
      Returns true if this packet is being sent in response to a previously received packet.
      Specified by:
      isResponse in interface Packet
      Overrides:
      isResponse in class PacketImpl
      Returns:
      true if this packet is being sent in response to a previously received packet

    • isExists

      public boolean isExists()

    • isDurable

      public boolean isDurable()

    • getConsumerCount

      public int getConsumerCount()

    • getMessageCount

      public long getMessageCount()

    • getFilterString

      public SimpleString getFilterString()

    • getAddress

      public SimpleString getAddress()

    • getName

      public SimpleString getName()

    • isTemporary

      public boolean isTemporary()

    • encodeRest

      public void encodeRest(ActiveMQBuffer buffer)
      Overrides:
      encodeRest in class PacketImpl

    • decodeRest

      public void decodeRest(ActiveMQBuffer buffer)
      Overrides:
      decodeRest in class PacketImpl

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class PacketImpl

    • getPacketString

      protected String getPacketString()
      Overrides:
      getPacketString in class PacketImpl

    • toQueueQuery

      public ClientSession.QueueQuery toQueueQuery()

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class PacketImpl