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

Class CreateQueueMessage

java.lang.Object

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

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

CreateQueueMessage_V2

public class CreateQueueMessage
extends PacketImpl

Field Summary

Fields

Modifier and Type	Field	Description
protected SimpleString	address
protected boolean	durable
protected SimpleString	filterString
protected SimpleString	queueName
protected boolean	requiresResponse
protected boolean	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_24_0_VERSION, ARTEMIS_2_28_0_VERSION, ARTEMIS_2_29_0_VERSION, ARTEMIS_2_37_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_PRODUCER, 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, REMOVE_PRODUCER, 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_BINDINGQUERY_RESP_V5, 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()
CreateQueueMessage(byte createQueueMessageV2)
CreateQueueMessage(QueueConfiguration queueConfiguration, boolean requiresResponse)
CreateQueueMessage(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary, boolean requiresResponse)

Method Summary

Modifier and Type	Method	Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
SimpleString	getAddress()
SimpleString	getFilterString()
protected String	getPacketString()
SimpleString	getQueueName()
int	hashCode()
boolean	isDurable()
boolean	isRequiresResponse()
boolean	isTemporary()
void	setAddress(SimpleString address)
void	setDurable(boolean durable)
void	setFilterString(SimpleString filterString)
void	setQueueName(SimpleString queueName)
void	setTemporary(boolean temporary)

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 Details

address

protected SimpleString address

queueName

protected SimpleString queueName

filterString

protected SimpleString filterString

durable

protected boolean durable

temporary

protected boolean temporary

requiresResponse

protected boolean requiresResponse

Constructor Details

CreateQueueMessage

public CreateQueueMessage(QueueConfiguration queueConfiguration,
 boolean requiresResponse)

CreateQueueMessage

public CreateQueueMessage(SimpleString address,
 SimpleString queueName,
 SimpleString filterString,
 boolean durable,
 boolean temporary,
 boolean requiresResponse)

CreateQueueMessage

public CreateQueueMessage()

CreateQueueMessage

public CreateQueueMessage(byte createQueueMessageV2)

Method Details

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class PacketImpl

getAddress

public SimpleString getAddress()

getQueueName

public SimpleString getQueueName()

getFilterString

public SimpleString getFilterString()

isDurable

public boolean isDurable()

isTemporary

public boolean isTemporary()

isRequiresResponse

public boolean isRequiresResponse()

Specified by:

isRequiresResponse in interface Packet

Overrides:

isRequiresResponse in class PacketImpl

setAddress

public void setAddress(SimpleString address)

setQueueName

public void setQueueName(SimpleString queueName)

setFilterString

public void setFilterString(SimpleString filterString)

setDurable

public void setDurable(boolean durable)

setTemporary

public void setTemporary(boolean temporary)

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

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl