public class SessionBindingQueryResponseMessage_V4 extends SessionBindingQueryResponseMessage_V3
autoCreateAddresses
autoCreateQueues
exists, queueNames
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 |
---|
SessionBindingQueryResponseMessage_V4() |
SessionBindingQueryResponseMessage_V4(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateQueues,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers,
Boolean defaultExclusive,
Boolean defaultLastValue,
SimpleString defaultLastValueKey,
Boolean defaultNonDestructive,
Integer defaultConsumersBeforeDispatch,
Long defaultDelayBeforeDispatch) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(ActiveMQBuffer buffer) |
void |
encodeRest(ActiveMQBuffer buffer) |
boolean |
equals(Object obj) |
Integer |
getDefaultConsumersBeforeDispatch() |
Long |
getDefaultDelayBeforeDispatch() |
SimpleString |
getDefaultLastValueKey() |
int |
getDefaultMaxConsumers() |
String |
getParentString() |
int |
hashCode() |
Boolean |
isDefaultExclusive() |
Boolean |
isDefaultLastValue() |
Boolean |
isDefaultNonDestructive() |
boolean |
isDefaultPurgeOnNoConsumers() |
String |
toString() |
isAutoCreateAddresses
isAutoCreateQueues
getQueueNames, isExists, isResponse
convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getType, isRequiresConfirmations, isRequiresResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
expectedEncodeSize, release
public SessionBindingQueryResponseMessage_V4(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch)
public SessionBindingQueryResponseMessage_V4()
public boolean isDefaultPurgeOnNoConsumers()
public int getDefaultMaxConsumers()
public Boolean isDefaultExclusive()
public Boolean isDefaultLastValue()
public SimpleString getDefaultLastValueKey()
public Boolean isDefaultNonDestructive()
public Integer getDefaultConsumersBeforeDispatch()
public Long getDefaultDelayBeforeDispatch()
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class SessionBindingQueryResponseMessage_V3
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class SessionBindingQueryResponseMessage_V3
public int hashCode()
hashCode
in class SessionBindingQueryResponseMessage_V3
public String toString()
toString
in class SessionBindingQueryResponseMessage_V3
public String getParentString()
getParentString
in class SessionBindingQueryResponseMessage_V3
public boolean equals(Object obj)
equals
in class SessionBindingQueryResponseMessage_V3
Copyright © 2019 JBoss by Red Hat. All rights reserved.