public class SessionQueueQueryResponseMessage_V3 extends SessionQueueQueryResponseMessage_V2
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
autoCreated |
protected Integer |
defaultConsumerWindowSize |
protected Boolean |
exclusive |
protected Integer |
groupBuckets |
protected SimpleString |
groupFirstKey |
protected Boolean |
groupRebalance |
protected Boolean |
lastValue |
protected SimpleString |
lastValueKey |
protected int |
maxConsumers |
protected Boolean |
nonDestructive |
protected boolean |
purgeOnNoConsumers |
protected RoutingType |
routingType |
autoCreateQueuesaddress, consumerCount, durable, exists, filterString, messageCount, name, temporaryADDRESSING_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 |
|---|
SessionQueueQueryResponseMessage_V3() |
SessionQueueQueryResponseMessage_V3(QueueQueryResult result) |
isAutoCreateQueuesgetAddress, getConsumerCount, getFilterString, getMessageCount, getName, isDurable, isExists, isResponse, isTemporaryconvertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getType, isRequiresConfirmations, isRequiresResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationIDclone, finalize, getClass, notify, notifyAll, wait, wait, waitexpectedEncodeSize, releaseprotected boolean autoCreated
protected boolean purgeOnNoConsumers
protected RoutingType routingType
protected int maxConsumers
protected Boolean exclusive
protected Boolean groupRebalance
protected Integer groupBuckets
protected SimpleString groupFirstKey
protected Boolean lastValue
protected SimpleString lastValueKey
protected Boolean nonDestructive
protected Integer defaultConsumerWindowSize
public SessionQueueQueryResponseMessage_V3(QueueQueryResult result)
public SessionQueueQueryResponseMessage_V3()
public boolean isAutoCreated()
public void setAutoCreated(boolean autoCreated)
public boolean isPurgeOnNoConsumers()
public void setPurgeOnNoConsumers(boolean purgeOnNoConsumers)
public RoutingType getRoutingType()
public void setRoutingType(RoutingType routingType)
public int getMaxConsumers()
public void setMaxConsumers(int maxConsumers)
public Boolean isExclusive()
public void setExclusive(Boolean exclusive)
public Boolean isLastValue()
public void setLastValue(Boolean lastValue)
public SimpleString getLastValueKey()
public void setLastValueKey(SimpleString lastValueKey)
public Boolean isNonDestructive()
public void setNonDestructive(Boolean nonDestructive)
public Integer getConsumersBeforeDispatch()
public void setConsumersBeforeDispatch(Integer consumersBeforeDispatch)
public Long getDelayBeforeDispatch()
public void setDelayBeforeDispatch(Long delayBeforeDispatch)
public Integer getDefaultConsumerWindowSize()
public void setDefaultConsumerWindowSize(Integer defaultConsumerWindowSize)
public Boolean isGroupRebalance()
public void setGroupRebalance(Boolean groupRebalance)
public Integer getGroupBuckets()
public void setGroupBuckets(Integer groupBuckets)
public SimpleString getGroupFirstKey()
public void setGroupFirstKey(SimpleString groupFirstKey)
public Boolean isAutoDelete()
public Long getAutoDeleteDelay()
public Long getAutoDeleteMessageCount()
public void encodeRest(ActiveMQBuffer buffer)
encodeRest in class SessionQueueQueryResponseMessage_V2public void decodeRest(ActiveMQBuffer buffer)
decodeRest in class SessionQueueQueryResponseMessage_V2public int hashCode()
hashCode in class SessionQueueQueryResponseMessage_V2public String toString()
toString in class SessionQueueQueryResponseMessage_V2public String getParentString()
getParentString in class SessionQueueQueryResponseMessage_V2public ClientSession.QueueQuery toQueueQuery()
toQueueQuery in class SessionQueueQueryResponseMessage_V2public boolean equals(Object obj)
equals in class SessionQueueQueryResponseMessage_V2Copyright © 2019 JBoss by Red Hat. All rights reserved.