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

public class SessionQueueQueryResponseMessage_V2
extends SessionQueueQueryResponseMessage

Field Summary

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

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, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, 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_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_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 and Description
SessionQueueQueryResponseMessage_V2()
SessionQueueQueryResponseMessage_V2(QueueQueryResult result)

Method Summary

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

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

createPacket, decode, encode, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, nullableStringEncodeSize, setChannelID

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

Constructor Detail

SessionQueueQueryResponseMessage_V2

public SessionQueueQueryResponseMessage_V2(QueueQueryResult result)

SessionQueueQueryResponseMessage_V2

public SessionQueueQueryResponseMessage_V2()

Method Detail

isAutoCreationEnabled

public boolean isAutoCreationEnabled()

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

toString

public String toString()

Overrides:

toString in class SessionQueueQueryResponseMessage

toQueueQuery

public ClientSession.QueueQuery toQueueQuery()

Overrides:

toQueueQuery in class SessionQueueQueryResponseMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionQueueQueryResponseMessage