Package org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Class SessionQueueQueryResponseMessage_V3

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage_V2

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage_V3

All Implemented Interfaces:

Packet

public class SessionQueueQueryResponseMessage_V3
extends SessionQueueQueryResponseMessage_V2

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	autoCreated
protected Integer	defaultConsumerWindowSize
protected Boolean	exclusive
protected Integer	groupBuckets
protected SimpleString	groupFirstKey
protected Boolean	groupRebalance
protected Boolean	groupRebalancePauseDispatch
protected Boolean	lastValue
protected SimpleString	lastValueKey
protected int	maxConsumers
protected Boolean	nonDestructive
protected boolean	purgeOnNoConsumers
protected RoutingType	routingType

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage_V2

autoCreateQueues

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage

address, consumerCount, durable, exists, filterString, messageCount, name, temporary

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

ADDRESSING_CHANGE_VERSION, ARTEMIS_2_18_0_VERSION, ARTEMIS_2_21_0_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, CLUSTER_TOPOLOGY_V4, CONSUMER_PRIORITY_CHANGE_VERSION, CREATE_ADDRESS, CREATE_QUEUE, CREATE_QUEUE_V2, CREATE_SHARED_QUEUE, CREATE_SHARED_QUEUE_V2, CREATESESSION, CREATESESSION_RESP, CREATESESSION_V2, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, DISCONNECT_V3, EXCEPTION, FEDERATION_DOWNSTREAM_CONNECT, 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

Fields inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

INITIAL_PACKET_SIZE

Constructor Summary

Constructors

Constructor	Description
SessionQueueQueryResponseMessage_V3()
SessionQueueQueryResponseMessage_V3(QueueQueryResult result)

Method Summary

Modifier and Type	Method	Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
Long	getAutoDeleteDelay()
Long	getAutoDeleteMessageCount()
Integer	getConsumersBeforeDispatch()
Integer	getDefaultConsumerWindowSize()
Long	getDelayBeforeDispatch()
Integer	getGroupBuckets()
SimpleString	getGroupFirstKey()
SimpleString	getLastValueKey()
int	getMaxConsumers()
protected String	getPacketString()
Long	getRingSize()
RoutingType	getRoutingType()
int	hashCode()
boolean	isAutoCreated()
Boolean	isAutoDelete()
Boolean	isConfigurationManaged()
Boolean	isEnabled()
Boolean	isExclusive()
Boolean	isGroupRebalance()
Boolean	isGroupRebalancePauseDispatch()
Boolean	isLastValue()
Boolean	isNonDestructive()
boolean	isPurgeOnNoConsumers()
void	setAutoCreated(boolean autoCreated)
void	setConfigurationManaged(Boolean configurationManaged)
void	setConsumersBeforeDispatch(Integer consumersBeforeDispatch)
void	setDefaultConsumerWindowSize(Integer defaultConsumerWindowSize)
void	setDelayBeforeDispatch(Long delayBeforeDispatch)
void	setEnabled(Boolean enabled)
void	setExclusive(Boolean exclusive)
void	setGroupBuckets(Integer groupBuckets)
void	setGroupFirstKey(SimpleString groupFirstKey)
void	setGroupRebalance(Boolean groupRebalance)
void	setGroupRebalancePauseDispatch(Boolean groupRebalancePauseDispatch)
void	setLastValue(Boolean lastValue)
void	setLastValueKey(SimpleString lastValueKey)
void	setMaxConsumers(int maxConsumers)
void	setNonDestructive(Boolean nonDestructive)
void	setPurgeOnNoConsumers(boolean purgeOnNoConsumers)
void	setRingSize(Long ringSize)
void	setRoutingType(RoutingType routingType)
ClientSession.QueueQuery	toQueueQuery()

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage_V2

isAutoCreateQueues

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage

getAddress, getConsumerCount, getFilterString, getMessageCount, getName, isDurable, isExists, isResponse, isTemporary

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getType, isRequiresConfirmations, isRequiresResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

expectedEncodeSize, release

Field Detail

autoCreated

protected boolean autoCreated

purgeOnNoConsumers

protected boolean purgeOnNoConsumers

routingType

protected RoutingType routingType

maxConsumers

protected int maxConsumers

exclusive

protected Boolean exclusive

groupRebalance

protected Boolean groupRebalance

groupRebalancePauseDispatch

protected Boolean groupRebalancePauseDispatch

groupBuckets

protected Integer groupBuckets

groupFirstKey

protected SimpleString groupFirstKey

lastValue

protected Boolean lastValue

lastValueKey

protected SimpleString lastValueKey

nonDestructive

protected Boolean nonDestructive

defaultConsumerWindowSize

protected Integer defaultConsumerWindowSize

Constructor Detail

SessionQueueQueryResponseMessage_V3

public SessionQueueQueryResponseMessage_V3(QueueQueryResult result)

SessionQueueQueryResponseMessage_V3

public SessionQueueQueryResponseMessage_V3()

Method Detail

isAutoCreated

public boolean isAutoCreated()

setAutoCreated

public void setAutoCreated(boolean autoCreated)

isPurgeOnNoConsumers

public boolean isPurgeOnNoConsumers()

setPurgeOnNoConsumers

public void setPurgeOnNoConsumers(boolean purgeOnNoConsumers)

getRoutingType

public RoutingType getRoutingType()

setRoutingType

public void setRoutingType(RoutingType routingType)

getMaxConsumers

public int getMaxConsumers()

setMaxConsumers

public void setMaxConsumers(int maxConsumers)

isExclusive

public Boolean isExclusive()

setExclusive

public void setExclusive(Boolean exclusive)

isLastValue

public Boolean isLastValue()

setLastValue

public void setLastValue(Boolean lastValue)

getLastValueKey

public SimpleString getLastValueKey()

setLastValueKey

public void setLastValueKey(SimpleString lastValueKey)

isNonDestructive

public Boolean isNonDestructive()

setNonDestructive

public void setNonDestructive(Boolean nonDestructive)

getConsumersBeforeDispatch

public Integer getConsumersBeforeDispatch()

setConsumersBeforeDispatch

public void setConsumersBeforeDispatch(Integer consumersBeforeDispatch)

getDelayBeforeDispatch

public Long getDelayBeforeDispatch()

setDelayBeforeDispatch

public void setDelayBeforeDispatch(Long delayBeforeDispatch)

getDefaultConsumerWindowSize

public Integer getDefaultConsumerWindowSize()

setDefaultConsumerWindowSize

public void setDefaultConsumerWindowSize(Integer defaultConsumerWindowSize)

isGroupRebalance

public Boolean isGroupRebalance()

setGroupRebalance

public void setGroupRebalance(Boolean groupRebalance)

isGroupRebalancePauseDispatch

public Boolean isGroupRebalancePauseDispatch()

setGroupRebalancePauseDispatch

public void setGroupRebalancePauseDispatch(Boolean groupRebalancePauseDispatch)

getGroupBuckets

public Integer getGroupBuckets()

setGroupBuckets

public void setGroupBuckets(Integer groupBuckets)

getGroupFirstKey

public SimpleString getGroupFirstKey()

setGroupFirstKey

public void setGroupFirstKey(SimpleString groupFirstKey)

isAutoDelete

public Boolean isAutoDelete()

getAutoDeleteDelay

public Long getAutoDeleteDelay()

getAutoDeleteMessageCount

public Long getAutoDeleteMessageCount()

getRingSize

public Long getRingSize()

setRingSize

public void setRingSize(Long ringSize)

isEnabled

public Boolean isEnabled()

setEnabled

public void setEnabled(Boolean enabled)

isConfigurationManaged

public Boolean isConfigurationManaged()

setConfigurationManaged

public void setConfigurationManaged(Boolean configurationManaged)

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionQueueQueryResponseMessage_V2

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionQueueQueryResponseMessage_V2

hashCode

public int hashCode()

Overrides:

hashCode in class SessionQueueQueryResponseMessage_V2

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class SessionQueueQueryResponseMessage_V2

toQueueQuery

public ClientSession.QueueQuery toQueueQuery()

Overrides:

toQueueQuery in class SessionQueueQueryResponseMessage_V2

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionQueueQueryResponseMessage_V2