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