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

Class SessionBindingQueryResponseMessage_V4

java.lang.Object

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

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

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

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

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

All Implemented Interfaces:

Packet

public class SessionBindingQueryResponseMessage_V4
extends SessionBindingQueryResponseMessage_V3

Field Summary

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

autoCreateAddresses

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

autoCreateQueues

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

exists, queueNames

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

ADDRESSING_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, 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, 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, SHARED_QUEUE_SECURITY_FIX_CHANGE_VERSION, 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
SessionBindingQueryResponseMessage_V4()
SessionBindingQueryResponseMessage_V4(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue)

Method Summary

Modifier and Type	Method and Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
int	getDefaultMaxConsumers()
String	getParentString()
int	hashCode()
Boolean	isDefaultExclusive()
Boolean	isDefaultLastValue()
boolean	isDefaultPurgeOnNoConsumers()
String	toString()

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

isAutoCreateAddresses

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

isAutoCreateQueues

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

getQueueNames, isExists, isResponse

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

convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeSize, getChannelID, getPacketSize, 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

SessionBindingQueryResponseMessage_V4

public SessionBindingQueryResponseMessage_V4(boolean exists,
                                             List<SimpleString> queueNames,
                                             boolean autoCreateQueues,
                                             boolean autoCreateAddresses,
                                             boolean defaultPurgeOnNoConsumers,
                                             int defaultMaxConsumers,
                                             Boolean defaultExclusive,
                                             Boolean defaultLastValue)

SessionBindingQueryResponseMessage_V4

public SessionBindingQueryResponseMessage_V4()

Method Detail

isDefaultPurgeOnNoConsumers

public boolean isDefaultPurgeOnNoConsumers()

getDefaultMaxConsumers

public int getDefaultMaxConsumers()

isDefaultExclusive

public Boolean isDefaultExclusive()

isDefaultLastValue

public Boolean isDefaultLastValue()

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionBindingQueryResponseMessage_V3

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionBindingQueryResponseMessage_V3

hashCode

public int hashCode()

Overrides:

hashCode in class SessionBindingQueryResponseMessage_V3

toString

public String toString()

Overrides:

toString in class SessionBindingQueryResponseMessage_V3

getParentString

public String getParentString()

Overrides:

getParentString in class SessionBindingQueryResponseMessage_V3

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionBindingQueryResponseMessage_V3