public class CreateSharedQueueMessage_V2 extends CreateSharedQueueMessage
address, durable, filterString, queueName, requiresResponse
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
INITIAL_PACKET_SIZE
Constructor and Description |
---|
CreateSharedQueueMessage_V2() |
CreateSharedQueueMessage_V2(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean requiresResponse) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(ActiveMQBuffer buffer) |
void |
encodeRest(ActiveMQBuffer buffer) |
boolean |
equals(Object obj) |
Integer |
getMaxConsumers() |
RoutingType |
getRoutingType() |
int |
hashCode() |
Boolean |
isExclusive() |
Boolean |
isLastValue() |
Boolean |
isPurgeOnNoConsumers() |
void |
setExclusive(Boolean exclusive) |
void |
setLastValue(Boolean lastValue) |
void |
setMaxConsumers(Integer maxConsumers) |
void |
setPurgeOnNoConsumers(Boolean purgeOnNoConsumers) |
void |
setRoutingType(RoutingType routingType) |
String |
toString() |
getAddress, getFilterString, getQueueName, isDurable, isRequiresResponse, setAddress, setFilterString, setQueueName
convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeSize, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
expectedEncodeSize, release
public CreateSharedQueueMessage_V2(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean requiresResponse)
public CreateSharedQueueMessage_V2()
public RoutingType getRoutingType()
public void setRoutingType(RoutingType routingType)
public Integer getMaxConsumers()
public void setMaxConsumers(Integer maxConsumers)
public Boolean isPurgeOnNoConsumers()
public void setPurgeOnNoConsumers(Boolean purgeOnNoConsumers)
public Boolean isExclusive()
public void setExclusive(Boolean exclusive)
public Boolean isLastValue()
public void setLastValue(Boolean lastValue)
public String toString()
toString
in class CreateSharedQueueMessage
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class CreateSharedQueueMessage
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class CreateSharedQueueMessage
public int hashCode()
hashCode
in class CreateSharedQueueMessage
public boolean equals(Object obj)
equals
in class CreateSharedQueueMessage
Copyright © 2019 JBoss by Red Hat. All rights reserved.