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

Class SessionQueueQueryResponseMessage_V3

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

  • Field Details

    • autoCreated

      protected boolean autoCreated

    • purgeOnNoConsumers

      protected boolean purgeOnNoConsumers

    • routingType

      protected RoutingType routingType

    • maxConsumers

      protected int maxConsumers

    • exclusive

      protected Boolean exclusive

    • groupRebalance

      protected Boolean groupRebalance

    • groupRebalancePauseDispatch

      protected Boolean groupRebalancePauseDispatch

    • groupBuckets

      protected Integer groupBuckets

    • groupFirstKey

      protected SimpleString groupFirstKey

    • lastValue

      protected Boolean lastValue

    • lastValueKey

      protected SimpleString lastValueKey

    • nonDestructive

      protected Boolean nonDestructive

    • defaultConsumerWindowSize

      protected Integer defaultConsumerWindowSize

  • Constructor Details

    • SessionQueueQueryResponseMessage_V3

      public SessionQueueQueryResponseMessage_V3(QueueQueryResult result)

    • SessionQueueQueryResponseMessage_V3

      public SessionQueueQueryResponseMessage_V3()

  • Method Details

    • isAutoCreated

      public boolean isAutoCreated()

    • setAutoCreated

      public void setAutoCreated(boolean autoCreated)

    • isPurgeOnNoConsumers

      public boolean isPurgeOnNoConsumers()

    • setPurgeOnNoConsumers

      public void setPurgeOnNoConsumers(boolean purgeOnNoConsumers)

    • getRoutingType

      public RoutingType getRoutingType()

    • setRoutingType

      public void setRoutingType(RoutingType routingType)

    • getMaxConsumers

      public int getMaxConsumers()

    • setMaxConsumers

      public void setMaxConsumers(int maxConsumers)

    • isExclusive

      public Boolean isExclusive()

    • setExclusive

      public void setExclusive(Boolean exclusive)

    • isLastValue

      public Boolean isLastValue()

    • setLastValue

      public void setLastValue(Boolean lastValue)

    • getLastValueKey

      public SimpleString getLastValueKey()

    • setLastValueKey

      public void setLastValueKey(SimpleString lastValueKey)

    • isNonDestructive

      public Boolean isNonDestructive()

    • setNonDestructive

      public void setNonDestructive(Boolean nonDestructive)

    • getConsumersBeforeDispatch

      public Integer getConsumersBeforeDispatch()

    • setConsumersBeforeDispatch

      public void setConsumersBeforeDispatch(Integer consumersBeforeDispatch)

    • getDelayBeforeDispatch

      public Long getDelayBeforeDispatch()

    • setDelayBeforeDispatch

      public void setDelayBeforeDispatch(Long delayBeforeDispatch)

    • getDefaultConsumerWindowSize

      public Integer getDefaultConsumerWindowSize()

    • setDefaultConsumerWindowSize

      public void setDefaultConsumerWindowSize(Integer defaultConsumerWindowSize)

    • isGroupRebalance

      public Boolean isGroupRebalance()

    • setGroupRebalance

      public void setGroupRebalance(Boolean groupRebalance)

    • isGroupRebalancePauseDispatch

      public Boolean isGroupRebalancePauseDispatch()

    • setGroupRebalancePauseDispatch

      public void setGroupRebalancePauseDispatch(Boolean groupRebalancePauseDispatch)

    • getGroupBuckets

      public Integer getGroupBuckets()

    • setGroupBuckets

      public void setGroupBuckets(Integer groupBuckets)

    • getGroupFirstKey

      public SimpleString getGroupFirstKey()

    • setGroupFirstKey

      public void setGroupFirstKey(SimpleString groupFirstKey)

    • isAutoDelete

      public Boolean isAutoDelete()

    • getAutoDeleteDelay

      public Long getAutoDeleteDelay()

    • getAutoDeleteMessageCount

      public Long getAutoDeleteMessageCount()

    • getRingSize

      public Long getRingSize()

    • setRingSize

      public void setRingSize(Long ringSize)

    • isEnabled

      public Boolean isEnabled()

    • setEnabled

      public void setEnabled(Boolean enabled)

    • isConfigurationManaged

      public Boolean isConfigurationManaged()

    • setConfigurationManaged

      public void setConfigurationManaged(Boolean configurationManaged)

    • encodeRest

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

    • decodeRest

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

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class SessionQueueQueryResponseMessage_V2

    • getPacketString

      protected String getPacketString()
      Overrides:
      getPacketString in class SessionQueueQueryResponseMessage_V2

    • toQueueQuery

      public ClientSession.QueueQuery toQueueQuery()
      Overrides:
      toQueueQuery in class SessionQueueQueryResponseMessage_V2

    • equals

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