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 Summary

Fields

Modifier and Type	Field	Description
protected boolean	autoCreated

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateQueueMessage

address, durable, filterString, queueName, requiresResponse, temporary

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

ADDRESSING_CHANGE_VERSION, ARTEMIS_2_18_0_VERSION, ARTEMIS_2_21_0_VERSION, ARTEMIS_2_7_0_VERSION, ASYNC_RESPONSE_CHANGE_VERSION, BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, BACKUP_REQUEST, BACKUP_REQUEST_RESPONSE, channelID, CHECK_FOR_FAILOVER, CHECK_FOR_FAILOVER_REPLY, CLUSTER_CONNECT, CLUSTER_CONNECT_REPLY, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CLUSTER_TOPOLOGY_V3, CLUSTER_TOPOLOGY_V4, CONSUMER_PRIORITY_CHANGE_VERSION, CREATE_ADDRESS, CREATE_QUEUE, CREATE_QUEUE_V2, CREATE_SHARED_QUEUE, CREATE_SHARED_QUEUE_V2, CREATESESSION, CREATESESSION_RESP, CREATESESSION_V2, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, DISCONNECT_V3, EXCEPTION, FEDERATION_DOWNSTREAM_CONNECT, FQQN_CHANGE_VERSION, NODE_ANNOUNCE, NULL_RESPONSE, OLD_QUEUE_PREFIX, OLD_TEMP_QUEUE_PREFIX, OLD_TEMP_TOPIC_PREFIX, OLD_TOPIC_PREFIX, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, QUORUM_VOTE, QUORUM_VOTE_REPLY, REATTACH_SESSION, REATTACH_SESSION_RESP, REPLICATION_APPEND, REPLICATION_APPEND_TX, REPLICATION_COMMIT_ROLLBACK, REPLICATION_DELETE, REPLICATION_DELETE_TX, REPLICATION_LARGE_MESSAGE_BEGIN, REPLICATION_LARGE_MESSAGE_END, REPLICATION_LARGE_MESSAGE_WRITE, REPLICATION_PAGE_EVENT, REPLICATION_PAGE_WRITE, REPLICATION_PREPARE, REPLICATION_RESPONSE, REPLICATION_RESPONSE_V2, REPLICATION_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, SCALEDOWN_ANNOUNCEMENT, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_BINDINGQUERY_RESP_V2, SESS_BINDINGQUERY_RESP_V3, SESS_BINDINGQUERY_RESP_V4, SESS_CLOSE, SESS_COMMIT, SESS_CONSUMER_CLOSE, SESS_CREATECONSUMER, SESS_EXPIRED, SESS_FLOWTOKEN, SESS_FORCE_CONSUMER_DELIVERY, SESS_INDIVIDUAL_ACKNOWLEDGE, SESS_PRODUCER_CREDITS, SESS_PRODUCER_FAIL_CREDITS, SESS_PRODUCER_REQUEST_CREDITS, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_QUEUEQUERY_RESP_V2, SESS_QUEUEQUERY_RESP_V3, SESS_RECEIVE_CONTINUATION, SESS_RECEIVE_LARGE_MSG, SESS_RECEIVE_MSG, SESS_ROLLBACK, SESS_SEND, SESS_SEND_CONTINUATION, SESS_SEND_LARGE, SESS_START, SESS_STOP, SESS_UNIQUE_ADD_METADATA, SESS_XA_COMMIT, SESS_XA_END, SESS_XA_FAILED, SESS_XA_FORGET, SESS_XA_GET_TIMEOUT, SESS_XA_GET_TIMEOUT_RESP, SESS_XA_INDOUBT_XIDS, SESS_XA_INDOUBT_XIDS_RESP, SESS_XA_JOIN, SESS_XA_PREPARE, SESS_XA_RESP, SESS_XA_RESUME, SESS_XA_ROLLBACK, SESS_XA_SET_TIMEOUT, SESS_XA_SET_TIMEOUT_RESP, SESS_XA_START, SESS_XA_SUSPEND, size, SUBSCRIBE_TOPOLOGY, SUBSCRIBE_TOPOLOGY_V2

Fields inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

INITIAL_PACKET_SIZE

Constructor Summary

Constructors

Constructor	Description
CreateQueueMessage_V2()
CreateQueueMessage_V2(QueueConfiguration queueConfiguration, boolean requiresResponse)
CreateQueueMessage_V2(SimpleString address, SimpleString queueName, boolean temporary, boolean autoCreated, boolean requiresResponse, QueueAttributes queueAttributes)	Deprecated.
CreateQueueMessage_V2(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, boolean requiresResponse, Boolean exclusive, Boolean groupRebalance, Boolean groupRebalancePauseDispatch, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Long ringSize, Boolean enabled)

Method Summary

Modifier and Type	Method	Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
Long	getAutoDeleteDelay()
Long	getAutoDeleteMessageCount()
Integer	getConsumersBeforeDispatch()
Long	getDelayBeforeDispatch()
Integer	getGroupBuckets()
SimpleString	getGroupFirstKey()
SimpleString	getLastValueKey()
int	getMaxConsumers()
protected String	getPacketString()
Long	getRingSize()
RoutingType	getRoutingType()
int	hashCode()
boolean	isAutoCreated()
Boolean	isAutoDelete()
Boolean	isEnabled()
Boolean	isExclusive()
Boolean	isGroupRebalance()
Boolean	isGroupRebalancePauseDispatch()
Boolean	isLastValue()
Boolean	isNonDestructive()
boolean	isPurgeOnNoConsumers()
void	setAutoCreated(boolean autoCreated)
void	setAutoDelete(Boolean autoDelete)
void	setAutoDeleteDelay(Long autoDeleteDelay)
void	setAutoDeleteMessageCount(Long autoDeleteMessageCount)
void	setConsumersBeforeDispatch(Integer consumersBeforeDispatch)
void	setDelayBeforeDispatch(Long delayBeforeDispatch)
void	setEnabled(Boolean enabled)
void	setExclusive(Boolean exclusive)
void	setGroupBuckets(Integer groupBuckets)
void	setGroupFirstKey(SimpleString groupFirstKey)
void	setGroupRebalance(Boolean groupRebalance)
void	setGroupRebalancePauseDispatch(Boolean groupRebalancePauseDispatch)
void	setLastValue(Boolean lastValue)
void	setLastValueKey(SimpleString lastValueKey)
void	setMaxConsumers(int maxConsumers)
void	setNonDestructive(Boolean nonDestructive)
void	setPurgeOnNoConsumers(boolean purgeOnNoConsumers)
void	setRingSize(Long ringSize)
void	setRoutingType(RoutingType routingType)
QueueConfiguration	toQueueConfiguration()

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateQueueMessage

getAddress, getFilterString, getQueueName, isDurable, isRequiresResponse, isTemporary, setAddress, setDurable, setFilterString, setQueueName, setTemporary

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getType, isRequiresConfirmations, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

expectedEncodeSize, release

Field Detail

autoCreated

protected boolean autoCreated

Constructor Detail

CreateQueueMessage_V2

@Deprecated
public CreateQueueMessage_V2(SimpleString address,
                             SimpleString queueName,
                             boolean temporary,
                             boolean autoCreated,
                             boolean requiresResponse,
                             QueueAttributes queueAttributes)

Deprecated.

CreateQueueMessage_V2

public CreateQueueMessage_V2(QueueConfiguration queueConfiguration,
                             boolean requiresResponse)

CreateQueueMessage_V2

public CreateQueueMessage_V2(SimpleString address,
                             SimpleString queueName,
                             RoutingType routingType,
                             SimpleString filterString,
                             boolean durable,
                             boolean temporary,
                             int maxConsumers,
                             boolean purgeOnNoConsumers,
                             boolean autoCreated,
                             boolean requiresResponse,
                             Boolean exclusive,
                             Boolean groupRebalance,
                             Boolean groupRebalancePauseDispatch,
                             Integer groupBuckets,
                             SimpleString groupFirstKey,
                             Boolean lastValue,
                             SimpleString lastValueKey,
                             Boolean nonDestructive,
                             Integer consumersBeforeDispatch,
                             Long delayBeforeDispatch,
                             Boolean autoDelete,
                             Long autoDeleteDelay,
                             Long autoDeleteMessageCount,
                             Long ringSize,
                             Boolean enabled)

CreateQueueMessage_V2

public CreateQueueMessage_V2()

Method Detail

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