public class PersistentQueueBindingEncoding extends Object implements EncodingSupport, QueueBindingInfo
| Modifier and Type | Field and Description |
|---|---|
SimpleString |
address |
boolean |
autoCreated |
boolean |
autoDelete |
long |
autoDeleteDelay |
long |
autoDeleteMessageCount |
boolean |
configurationManaged |
int |
consumersBeforeDispatch |
long |
delayBeforeDispatch |
boolean |
exclusive |
SimpleString |
filterString |
int |
groupBuckets |
SimpleString |
groupFirstKey |
boolean |
groupRebalance |
long |
id |
boolean |
lastValue |
SimpleString |
lastValueKey |
int |
maxConsumers |
SimpleString |
name |
boolean |
nonDestructive |
boolean |
purgeOnNoConsumers |
List<QueueStatusEncoding> |
queueStatusEncodings |
byte |
routingType |
SimpleString |
user |
| Constructor and Description |
|---|
PersistentQueueBindingEncoding() |
PersistentQueueBindingEncoding(SimpleString name,
SimpleString address,
SimpleString filterString,
SimpleString user,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
byte routingType,
boolean configurationManaged) |
public long id
public SimpleString name
public SimpleString address
public SimpleString filterString
public boolean autoCreated
public SimpleString user
public List<QueueStatusEncoding> queueStatusEncodings
public int maxConsumers
public boolean purgeOnNoConsumers
public boolean exclusive
public boolean lastValue
public SimpleString lastValueKey
public boolean nonDestructive
public int consumersBeforeDispatch
public long delayBeforeDispatch
public byte routingType
public boolean configurationManaged
public boolean groupRebalance
public int groupBuckets
public SimpleString groupFirstKey
public boolean autoDelete
public long autoDeleteDelay
public long autoDeleteMessageCount
public PersistentQueueBindingEncoding()
public PersistentQueueBindingEncoding(SimpleString name, SimpleString address, SimpleString filterString, SimpleString user, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, byte routingType, boolean configurationManaged)
public long getId()
getId in interface QueueBindingInfopublic void setId(long id)
public SimpleString getAddress()
getAddress in interface QueueBindingInfopublic void replaceQueueName(SimpleString newName)
QueueBindingInforeplaceQueueName in interface QueueBindingInfopublic SimpleString getFilterString()
getFilterString in interface QueueBindingInfopublic SimpleString getQueueName()
getQueueName in interface QueueBindingInfopublic SimpleString getUser()
getUser in interface QueueBindingInfopublic boolean isAutoCreated()
isAutoCreated in interface QueueBindingInfopublic boolean isConfigurationManaged()
isConfigurationManaged in interface QueueBindingInfopublic void setConfigurationManaged(boolean configurationManaged)
setConfigurationManaged in interface QueueBindingInfopublic void addQueueStatusEncoding(QueueStatusEncoding status)
addQueueStatusEncoding in interface QueueBindingInfopublic List<QueueStatusEncoding> getQueueStatusEncodings()
getQueueStatusEncodings in interface QueueBindingInfopublic int getMaxConsumers()
getMaxConsumers in interface QueueBindingInfopublic void setMaxConsumers(int maxConsumers)
setMaxConsumers in interface QueueBindingInfopublic boolean isPurgeOnNoConsumers()
isPurgeOnNoConsumers in interface QueueBindingInfopublic void setPurgeOnNoConsumers(boolean purgeOnNoConsumers)
setPurgeOnNoConsumers in interface QueueBindingInfopublic boolean isExclusive()
isExclusive in interface QueueBindingInfopublic void setExclusive(boolean exclusive)
setExclusive in interface QueueBindingInfopublic boolean isLastValue()
isLastValue in interface QueueBindingInfopublic void setLastValue(boolean lastValue)
setLastValue in interface QueueBindingInfopublic SimpleString getLastValueKey()
getLastValueKey in interface QueueBindingInfopublic void setLastValueKey(SimpleString lastValueKey)
setLastValueKey in interface QueueBindingInfopublic boolean isNonDestructive()
isNonDestructive in interface QueueBindingInfopublic void setNonDestructive(boolean nonDestructive)
setNonDestructive in interface QueueBindingInfopublic int getConsumersBeforeDispatch()
getConsumersBeforeDispatch in interface QueueBindingInfopublic void setConsumersBeforeDispatch(int consumersBeforeDispatch)
setConsumersBeforeDispatch in interface QueueBindingInfopublic long getDelayBeforeDispatch()
getDelayBeforeDispatch in interface QueueBindingInfopublic void setDelayBeforeDispatch(long delayBeforeDispatch)
setDelayBeforeDispatch in interface QueueBindingInfopublic byte getRoutingType()
getRoutingType in interface QueueBindingInfopublic void setRoutingType(byte routingType)
setRoutingType in interface QueueBindingInfopublic boolean isGroupRebalance()
isGroupRebalance in interface QueueBindingInfopublic int getGroupBuckets()
getGroupBuckets in interface QueueBindingInfopublic SimpleString getGroupFirstKey()
getGroupFirstKey in interface QueueBindingInfopublic boolean isAutoDelete()
isAutoDelete in interface QueueBindingInfopublic long getAutoDeleteDelay()
getAutoDeleteDelay in interface QueueBindingInfopublic long getAutoDeleteMessageCount()
getAutoDeleteMessageCount in interface QueueBindingInfopublic void decode(ActiveMQBuffer buffer)
decode in interface EncodingSupportpublic void encode(ActiveMQBuffer buffer)
encode in interface EncodingSupportpublic int getEncodeSize()
getEncodeSize in interface EncodingSupportCopyright © 2019 JBoss by Red Hat. All rights reserved.