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
-
Field Summary
FieldsFields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage
address, consumerCount, durable, exists, filterString, messageCount, name, temporaryFields 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_V2Fields inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet
INITIAL_PACKET_SIZE -
Constructor Summary
ConstructorsConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionvoiddecodeRest(ActiveMQBuffer buffer) voidencodeRest(ActiveMQBuffer buffer) booleanprotected StringinthashCode()booleanMethods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage
getAddress, getConsumerCount, getFilterString, getMessageCount, getName, isDurable, isExists, isResponse, isTemporaryMethods 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, toStringMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet
expectedEncodeSize, release
-
Field Details
-
autoCreateQueues
protected boolean autoCreateQueues
-
-
Constructor Details
-
SessionQueueQueryResponseMessage_V2
-
SessionQueueQueryResponseMessage_V2
public SessionQueueQueryResponseMessage_V2() -
SessionQueueQueryResponseMessage_V2
public SessionQueueQueryResponseMessage_V2(byte v)
-
-
Method Details
-
isAutoCreateQueues
public boolean isAutoCreateQueues() -
encodeRest
- Overrides:
encodeRestin classSessionQueueQueryResponseMessage
-
decodeRest
- Overrides:
decodeRestin classSessionQueueQueryResponseMessage
-
hashCode
public int hashCode()- Overrides:
hashCodein classSessionQueueQueryResponseMessage
-
getPacketString
- Overrides:
getPacketStringin classSessionQueueQueryResponseMessage
-
toQueueQuery
- Overrides:
toQueueQueryin classSessionQueueQueryResponseMessage
-
equals
- Overrides:
equalsin classSessionQueueQueryResponseMessage
-