public class SessionCreateConsumerMessage extends QueueAbstractPacket
address, queueNameADDRESSING_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_V2INITIAL_PACKET_SIZE| Constructor and Description |
|---|
SessionCreateConsumerMessage() |
SessionCreateConsumerMessage(long id,
SimpleString queueName,
SimpleString filterString,
int priority,
boolean browseOnly,
boolean requiresResponse) |
| Modifier and Type | Method and Description |
|---|---|
void |
decodeRest(ActiveMQBuffer buffer) |
void |
encodeRest(ActiveMQBuffer buffer,
CoreRemotingConnection coreRemotingConnection) |
boolean |
equals(Object obj) |
SimpleString |
getFilterString() |
long |
getID() |
int |
getPriority() |
int |
hashCode() |
boolean |
isBrowseOnly() |
boolean |
isRequiresResponse() |
void |
setBrowseOnly(boolean browseOnly) |
void |
setFilterString(SimpleString filterString) |
void |
setPriority(byte priority) |
void |
setQueueName(SimpleString queueName) |
String |
toString() |
convertQueueNames, getAddress, getOldPrefixedAddress, getQueueNameconvertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationIDclone, finalize, getClass, notify, notifyAll, wait, wait, waitexpectedEncodeSize, releasepublic SessionCreateConsumerMessage(long id,
SimpleString queueName,
SimpleString filterString,
int priority,
boolean browseOnly,
boolean requiresResponse)
public SessionCreateConsumerMessage()
public String toString()
toString in class PacketImplpublic long getID()
public SimpleString getFilterString()
public int getPriority()
public boolean isBrowseOnly()
public boolean isRequiresResponse()
isRequiresResponse in interface PacketisRequiresResponse in class PacketImplpublic void setQueueName(SimpleString queueName)
public void setFilterString(SimpleString filterString)
public void setPriority(byte priority)
public void setBrowseOnly(boolean browseOnly)
public void encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection)
encodeRest in class PacketImplpublic void decodeRest(ActiveMQBuffer buffer)
decodeRest in class PacketImplpublic int hashCode()
hashCode in class PacketImplpublic boolean equals(Object obj)
equals in class PacketImplCopyright © 2019 JBoss by Red Hat. All rights reserved.