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

Class CreateSharedQueueMessage_V2

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

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

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

All Implemented Interfaces:

Packet

public class CreateSharedQueueMessage_V2
extends CreateSharedQueueMessage

Field Summary

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

address, durable, filterString, queueName, requiresResponse

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
CreateSharedQueueMessage_V2()
CreateSharedQueueMessage_V2(QueueConfiguration queueConfiguration, boolean requiresResponse)
CreateSharedQueueMessage_V2(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, 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, boolean requiresResponse)

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()
Integer	getMaxConsumers()
protected String	getPacketString()
Long	getRingSize()
RoutingType	getRoutingType()
int	hashCode()
Boolean	isAutoDelete()
Boolean	isEnabled()
Boolean	isExclusive()
Boolean	isGroupRebalance()
Boolean	isGroupRebalancePauseDispatch()
Boolean	isLastValue()
Boolean	isNonDestructive()
Boolean	isPurgeOnNoConsumers()
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	setGroupBuckets(SimpleString groupFirstKey)
void	setGroupRebalance(Boolean groupRebalance)
void	setGroupRebalancePauseDispatch(Boolean groupRebalancePauseDispatch)
void	setLastValue(Boolean lastValue)
void	setLastValueKey(SimpleString lastValueKey)
void	setMaxConsumers(Integer 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.CreateSharedQueueMessage

getAddress, getFilterString, getQueueName, isDurable, isRequiresResponse, setAddress, setFilterString, setQueueName

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

Constructor Detail

CreateSharedQueueMessage_V2

public CreateSharedQueueMessage_V2(QueueConfiguration queueConfiguration,
                                   boolean requiresResponse)

CreateSharedQueueMessage_V2

public CreateSharedQueueMessage_V2(SimpleString address,
                                   SimpleString queueName,
                                   RoutingType routingType,
                                   SimpleString filterString,
                                   boolean durable,
                                   Integer maxConsumers,
                                   Boolean purgeOnNoConsumers,
                                   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,
                                   boolean requiresResponse)

CreateSharedQueueMessage_V2

public CreateSharedQueueMessage_V2()

Method Detail

getRoutingType

public RoutingType getRoutingType()

setRoutingType

public void setRoutingType(RoutingType routingType)

getMaxConsumers

public Integer getMaxConsumers()

setMaxConsumers

public void setMaxConsumers(Integer maxConsumers)

isPurgeOnNoConsumers

public Boolean isPurgeOnNoConsumers()

setPurgeOnNoConsumers

public void setPurgeOnNoConsumers(Boolean purgeOnNoConsumers)

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

setGroupBuckets

public void setGroupBuckets(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)

toQueueConfiguration

public QueueConfiguration toQueueConfiguration()

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class CreateSharedQueueMessage

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class CreateSharedQueueMessage

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class CreateSharedQueueMessage

hashCode

public int hashCode()

Overrides:

hashCode in class CreateSharedQueueMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class CreateSharedQueueMessage