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

public class CreateQueueMessage
extends PacketImpl

Field Summary

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

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, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_V2, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, 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_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_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

Constructor Summary

Constructors

Constructor and Description
CreateQueueMessage()
CreateQueueMessage(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary, boolean requiresResponse)

Method Summary

Modifier and Type	Method and Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
SimpleString	getAddress()
SimpleString	getFilterString()
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)
String	toString()

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

decode, encode, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateQueueMessage

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

CreateQueueMessage

public CreateQueueMessage()

Method Detail

toString

public String toString()

Overrides:

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

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