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 |
enabled |
boolean |
exclusive |
SimpleString |
filterString |
int |
groupBuckets |
SimpleString |
groupFirstKey |
boolean |
groupRebalance |
boolean |
groupRebalancePauseDispatch |
long |
id |
boolean |
lastValue |
SimpleString |
lastValueKey |
int |
maxConsumers |
SimpleString |
name |
boolean |
nonDestructive |
boolean |
purgeOnNoConsumers |
List<QueueStatusEncoding> |
queueStatusEncodings |
long |
ringSize |
byte |
routingType |
SimpleString |
user |
Constructor and Description |
---|
PersistentQueueBindingEncoding() |
PersistentQueueBindingEncoding(SimpleString name,
SimpleString address,
SimpleString filterString,
SimpleString user,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean enabled,
boolean exclusive,
boolean groupRebalance,
boolean groupRebalancePauseDispatch,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
byte routingType,
boolean configurationManaged,
long ringSize) |
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 enabled
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 boolean groupRebalancePauseDispatch
public int groupBuckets
public SimpleString groupFirstKey
public boolean autoDelete
public long autoDeleteDelay
public long autoDeleteMessageCount
public long ringSize
public PersistentQueueBindingEncoding()
public PersistentQueueBindingEncoding(SimpleString name, SimpleString address, SimpleString filterString, SimpleString user, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean enabled, boolean exclusive, boolean groupRebalance, boolean groupRebalancePauseDispatch, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, byte routingType, boolean configurationManaged, long ringSize)
public long getId()
getId
in interface QueueBindingInfo
public void setId(long id)
public SimpleString getAddress()
getAddress
in interface QueueBindingInfo
public void replaceQueueName(SimpleString newName)
QueueBindingInfo
replaceQueueName
in interface QueueBindingInfo
public SimpleString getFilterString()
getFilterString
in interface QueueBindingInfo
public SimpleString getQueueName()
getQueueName
in interface QueueBindingInfo
public SimpleString getUser()
getUser
in interface QueueBindingInfo
public boolean isAutoCreated()
isAutoCreated
in interface QueueBindingInfo
public boolean isConfigurationManaged()
isConfigurationManaged
in interface QueueBindingInfo
public void setConfigurationManaged(boolean configurationManaged)
setConfigurationManaged
in interface QueueBindingInfo
public void addQueueStatusEncoding(QueueStatusEncoding status)
addQueueStatusEncoding
in interface QueueBindingInfo
public List<QueueStatusEncoding> getQueueStatusEncodings()
getQueueStatusEncodings
in interface QueueBindingInfo
public int getMaxConsumers()
getMaxConsumers
in interface QueueBindingInfo
public void setMaxConsumers(int maxConsumers)
setMaxConsumers
in interface QueueBindingInfo
public boolean isPurgeOnNoConsumers()
isPurgeOnNoConsumers
in interface QueueBindingInfo
public void setPurgeOnNoConsumers(boolean purgeOnNoConsumers)
setPurgeOnNoConsumers
in interface QueueBindingInfo
public boolean isEnabled()
isEnabled
in interface QueueBindingInfo
public void setEnabled(boolean enabled)
setEnabled
in interface QueueBindingInfo
public boolean isExclusive()
isExclusive
in interface QueueBindingInfo
public void setExclusive(boolean exclusive)
setExclusive
in interface QueueBindingInfo
public boolean isLastValue()
isLastValue
in interface QueueBindingInfo
public void setLastValue(boolean lastValue)
setLastValue
in interface QueueBindingInfo
public SimpleString getLastValueKey()
getLastValueKey
in interface QueueBindingInfo
public void setLastValueKey(SimpleString lastValueKey)
setLastValueKey
in interface QueueBindingInfo
public boolean isNonDestructive()
isNonDestructive
in interface QueueBindingInfo
public void setNonDestructive(boolean nonDestructive)
setNonDestructive
in interface QueueBindingInfo
public int getConsumersBeforeDispatch()
getConsumersBeforeDispatch
in interface QueueBindingInfo
public void setConsumersBeforeDispatch(int consumersBeforeDispatch)
setConsumersBeforeDispatch
in interface QueueBindingInfo
public long getDelayBeforeDispatch()
getDelayBeforeDispatch
in interface QueueBindingInfo
public void setDelayBeforeDispatch(long delayBeforeDispatch)
setDelayBeforeDispatch
in interface QueueBindingInfo
public byte getRoutingType()
getRoutingType
in interface QueueBindingInfo
public void setRoutingType(byte routingType)
setRoutingType
in interface QueueBindingInfo
public boolean isGroupRebalance()
isGroupRebalance
in interface QueueBindingInfo
public boolean isGroupRebalancePauseDispatch()
isGroupRebalancePauseDispatch
in interface QueueBindingInfo
public int getGroupBuckets()
getGroupBuckets
in interface QueueBindingInfo
public SimpleString getGroupFirstKey()
getGroupFirstKey
in interface QueueBindingInfo
public boolean isAutoDelete()
isAutoDelete
in interface QueueBindingInfo
public long getAutoDeleteDelay()
getAutoDeleteDelay
in interface QueueBindingInfo
public long getAutoDeleteMessageCount()
getAutoDeleteMessageCount
in interface QueueBindingInfo
public long getRingSize()
getRingSize
in interface QueueBindingInfo
public void decode(ActiveMQBuffer buffer)
decode
in interface EncodingSupport
public void encode(ActiveMQBuffer buffer)
encode
in interface EncodingSupport
public int getEncodeSize()
getEncodeSize
in interface EncodingSupport
Copyright © 2021 JBoss by Red Hat. All rights reserved.