public class CreateSharedQueueMessage extends PacketImpl
Modifier and Type | Field and Description |
---|---|
protected SimpleString |
address |
protected boolean |
durable |
protected SimpleString |
filterString |
protected SimpleString |
queueName |
protected boolean |
requiresResponse |
ADDRESSING_CHANGE_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, CONSUMER_PRIORITY_CHANGE_VERSION, CREATE_ADDRESS, CREATE_QUEUE, CREATE_QUEUE_V2, CREATE_SHARED_QUEUE, CREATE_SHARED_QUEUE_V2, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, EXCEPTION, 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
INITIAL_PACKET_SIZE
Constructor and Description |
---|
CreateSharedQueueMessage() |
CreateSharedQueueMessage(byte packetType) |
CreateSharedQueueMessage(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean requiresResponse) |
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() |
void |
setAddress(SimpleString address) |
void |
setFilterString(SimpleString filterString) |
void |
setQueueName(SimpleString queueName) |
String |
toString() |
convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
expectedEncodeSize, release
protected SimpleString address
protected SimpleString queueName
protected SimpleString filterString
protected boolean durable
protected boolean requiresResponse
public CreateSharedQueueMessage(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean requiresResponse)
public CreateSharedQueueMessage()
public CreateSharedQueueMessage(byte packetType)
public String toString()
toString
in class PacketImpl
public SimpleString getAddress()
public SimpleString getQueueName()
public SimpleString getFilterString()
public boolean isRequiresResponse()
isRequiresResponse
in interface Packet
isRequiresResponse
in class PacketImpl
public void setAddress(SimpleString address)
public void setQueueName(SimpleString queueName)
public void setFilterString(SimpleString filterString)
public boolean isDurable()
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class PacketImpl
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class PacketImpl
public int hashCode()
hashCode
in class PacketImpl
public boolean equals(Object obj)
equals
in class PacketImpl
Copyright © 2020 JBoss by Red Hat. All rights reserved.