public class PersistentQueueBindingEncoding extends Object implements EncodingSupport, QueueBindingInfo
Modifier and Type | Field and Description |
---|---|
SimpleString |
address |
boolean |
autoCreated |
boolean |
exclusive |
SimpleString |
filterString |
long |
id |
boolean |
lastValue |
int |
maxConsumers |
SimpleString |
name |
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 lastValue,
byte routingType) |
Modifier and Type | Method and Description |
---|---|
void |
addQueueStatusEncoding(QueueStatusEncoding status) |
void |
decode(ActiveMQBuffer buffer) |
void |
encode(ActiveMQBuffer buffer) |
SimpleString |
getAddress() |
int |
getEncodeSize() |
SimpleString |
getFilterString() |
long |
getId() |
int |
getMaxConsumers() |
SimpleString |
getQueueName() |
List<QueueStatusEncoding> |
getQueueStatusEncodings() |
byte |
getRoutingType() |
SimpleString |
getUser() |
boolean |
isAutoCreated() |
boolean |
isExclusive() |
boolean |
isLastValue() |
boolean |
isPurgeOnNoConsumers() |
void |
replaceQueueName(SimpleString newName)
used to rename the queue in case of a duplication during load time
|
void |
setExclusive(boolean exclusive) |
void |
setId(long id) |
void |
setLastValue(boolean lastValue) |
void |
setMaxConsumers(int maxConsumers) |
void |
setPurgeOnNoConsumers(boolean purgeOnNoConsumers) |
void |
setRoutingType(byte routingType) |
String |
toString() |
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 byte routingType
public PersistentQueueBindingEncoding()
public PersistentQueueBindingEncoding(SimpleString name, SimpleString address, SimpleString filterString, SimpleString user, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue, byte routingType)
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 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 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 byte getRoutingType()
getRoutingType
in interface QueueBindingInfo
public void setRoutingType(byte routingType)
setRoutingType
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 © 2018 JBoss by Red Hat. All rights reserved.