public class CreateSharedQueueMessage_V2 extends CreateSharedQueueMessage
address, durable, filterString, queueName, requiresResponseADDRESSING_CHANGE_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, CONSUMER_PRIORITY_CHANGE_VERSION, 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, 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, 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, size, SUBSCRIBE_TOPOLOGY, SUBSCRIBE_TOPOLOGY_V2INITIAL_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 groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean requiresResponse) |
getAddress, getFilterString, getQueueName, isDurable, isRequiresResponse, setAddress, setFilterString, setQueueNameconvertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationIDclone, finalize, getClass, notify, notifyAll, wait, wait, waitexpectedEncodeSize, releasepublic CreateSharedQueueMessage_V2(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, 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 SimpleString getLastValueKey()
public void setLastValueKey(SimpleString lastValueKey)
public Boolean isNonDestructive()
public void setNonDestructive(Boolean nonDestructive)
public Integer getConsumersBeforeDispatch()
public void setConsumersBeforeDispatch(Integer consumersBeforeDispatch)
public Long getDelayBeforeDispatch()
public void setDelayBeforeDispatch(Long delayBeforeDispatch)
public Boolean isGroupRebalance()
public void setGroupRebalance(Boolean groupRebalance)
public Integer getGroupBuckets()
public void setGroupBuckets(Integer groupBuckets)
public SimpleString getGroupFirstKey()
public void setGroupBuckets(SimpleString groupFirstKey)
public Boolean isAutoDelete()
public void setAutoDelete(Boolean autoDelete)
public Long getAutoDeleteDelay()
public void setAutoDeleteDelay(Long autoDeleteDelay)
public Long getAutoDeleteMessageCount()
public void setAutoDeleteMessageCount(Long autoDeleteMessageCount)
public String toString()
toString in class CreateSharedQueueMessagepublic void encodeRest(ActiveMQBuffer buffer)
encodeRest in class CreateSharedQueueMessagepublic void decodeRest(ActiveMQBuffer buffer)
decodeRest in class CreateSharedQueueMessagepublic int hashCode()
hashCode in class CreateSharedQueueMessagepublic boolean equals(Object obj)
equals in class CreateSharedQueueMessageCopyright © 2019 JBoss by Red Hat. All rights reserved.