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

Class CreateQueueMessage_V2

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

  • Field Details

    • autoCreated

      protected boolean autoCreated

  • Constructor Details

  • Method Details

    • toQueueConfiguration

      public QueueConfiguration toQueueConfiguration()

    • getPacketString

      protected String getPacketString()
      Overrides:
      getPacketString in class CreateQueueMessage

    • getRoutingType

      public RoutingType getRoutingType()

    • setRoutingType

      public void setRoutingType(RoutingType routingType)

    • getMaxConsumers

      public int getMaxConsumers()

    • setMaxConsumers

      public void setMaxConsumers(int maxConsumers)

    • isPurgeOnNoConsumers

      public boolean isPurgeOnNoConsumers()

    • setPurgeOnNoConsumers

      public void setPurgeOnNoConsumers(boolean purgeOnNoConsumers)

    • isAutoCreated

      public boolean isAutoCreated()

    • setAutoCreated

      public void setAutoCreated(boolean autoCreated)

    • 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)

    • 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()

    • setAutoDelete

      public void setAutoDelete(Boolean autoDelete)

    • getAutoDeleteDelay

      public Long getAutoDeleteDelay()

    • setAutoDeleteDelay

      public void setAutoDeleteDelay(Long autoDeleteDelay)

    • getAutoDeleteMessageCount

      public Long getAutoDeleteMessageCount()

    • setAutoDeleteMessageCount

      public void setAutoDeleteMessageCount(Long autoDeleteMessageCount)

    • getRingSize

      public Long getRingSize()

    • setRingSize

      public void setRingSize(Long ringSize)

    • isEnabled

      public Boolean isEnabled()

    • setEnabled

      public void setEnabled(Boolean enabled)

    • encodeRest

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

    • decodeRest

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

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class CreateQueueMessage

    • equals

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