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

Class SessionQueueQueryResponseMessage_V2

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

SessionQueueQueryResponseMessage_V3

public class SessionQueueQueryResponseMessage_V2
extends SessionQueueQueryResponseMessage

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	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_24_0_VERSION, ARTEMIS_2_28_0_VERSION, ARTEMIS_2_29_0_VERSION, ARTEMIS_2_37_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_PRODUCER, 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, REMOVE_PRODUCER, 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_BINDINGQUERY_RESP_V5, 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_V2()
SessionQueueQueryResponseMessage_V2(byte v)
SessionQueueQueryResponseMessage_V2(QueueQueryResult result)

Method Summary

Modifier and Type	Method	Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
protected String	getPacketString()
int	hashCode()
boolean	isAutoCreateQueues()
ClientSession.QueueQuery	toQueueQuery()

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 Details

autoCreateQueues

protected boolean autoCreateQueues

Constructor Details

SessionQueueQueryResponseMessage_V2

public SessionQueueQueryResponseMessage_V2(QueueQueryResult result)

SessionQueueQueryResponseMessage_V2

public SessionQueueQueryResponseMessage_V2()

SessionQueueQueryResponseMessage_V2

public SessionQueueQueryResponseMessage_V2(byte v)

Method Details

isAutoCreateQueues

public boolean isAutoCreateQueues()

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionQueueQueryResponseMessage

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionQueueQueryResponseMessage

hashCode

public int hashCode()

Overrides:

hashCode in class SessionQueueQueryResponseMessage

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class SessionQueueQueryResponseMessage

toQueueQuery

public ClientSession.QueueQuery toQueueQuery()

Overrides:

toQueueQuery in class SessionQueueQueryResponseMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionQueueQueryResponseMessage