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 |
autoCreateQueues
address, consumerCount, durable, exists, filterString, messageCount, name, temporary
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 |
---|
SessionQueueQueryResponseMessage_V3() |
SessionQueueQueryResponseMessage_V3(QueueQueryResult result) |
isAutoCreateQueues
getAddress, getConsumerCount, getFilterString, getMessageCount, getName, isDurable, isExists, isResponse, isTemporary
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
protected 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_V2
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class SessionQueueQueryResponseMessage_V2
public int hashCode()
hashCode
in class SessionQueueQueryResponseMessage_V2
public String toString()
toString
in class SessionQueueQueryResponseMessage_V2
public String getParentString()
getParentString
in class SessionQueueQueryResponseMessage_V2
public ClientSession.QueueQuery toQueueQuery()
toQueueQuery
in class SessionQueueQueryResponseMessage_V2
public boolean equals(Object obj)
equals
in class SessionQueueQueryResponseMessage_V2
Copyright © 2019 JBoss by Red Hat. All rights reserved.