public class PersistentQueueBindingEncoding extends Object implements org.apache.activemq.artemis.core.journal.EncodingSupport, QueueBindingInfo
| Modifier and Type | Field and Description |
|---|---|
org.apache.activemq.artemis.api.core.SimpleString |
address |
boolean |
autoCreated |
org.apache.activemq.artemis.api.core.SimpleString |
filterString |
long |
id |
org.apache.activemq.artemis.api.core.SimpleString |
name |
List<QueueStatusEncoding> |
queueStatusEncodings |
org.apache.activemq.artemis.api.core.SimpleString |
user |
| Constructor and Description |
|---|
PersistentQueueBindingEncoding() |
PersistentQueueBindingEncoding(org.apache.activemq.artemis.api.core.SimpleString name,
org.apache.activemq.artemis.api.core.SimpleString address,
org.apache.activemq.artemis.api.core.SimpleString filterString,
org.apache.activemq.artemis.api.core.SimpleString user,
boolean autoCreated) |
| Modifier and Type | Method and Description |
|---|---|
void |
addQueueStatusEncoding(QueueStatusEncoding status) |
void |
decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer) |
void |
encode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer) |
org.apache.activemq.artemis.api.core.SimpleString |
getAddress() |
int |
getEncodeSize() |
org.apache.activemq.artemis.api.core.SimpleString |
getFilterString() |
long |
getId() |
org.apache.activemq.artemis.api.core.SimpleString |
getQueueName() |
List<QueueStatusEncoding> |
getQueueStatusEncodings() |
org.apache.activemq.artemis.api.core.SimpleString |
getUser() |
boolean |
isAutoCreated() |
void |
replaceQueueName(org.apache.activemq.artemis.api.core.SimpleString newName)
used to rename the queue in case of a duplication during load time
|
void |
setId(long id) |
String |
toString() |
public long id
public org.apache.activemq.artemis.api.core.SimpleString name
public org.apache.activemq.artemis.api.core.SimpleString address
public org.apache.activemq.artemis.api.core.SimpleString filterString
public boolean autoCreated
public org.apache.activemq.artemis.api.core.SimpleString user
public List<QueueStatusEncoding> queueStatusEncodings
public PersistentQueueBindingEncoding()
public PersistentQueueBindingEncoding(org.apache.activemq.artemis.api.core.SimpleString name,
org.apache.activemq.artemis.api.core.SimpleString address,
org.apache.activemq.artemis.api.core.SimpleString filterString,
org.apache.activemq.artemis.api.core.SimpleString user,
boolean autoCreated)
public long getId()
getId in interface QueueBindingInfopublic void setId(long id)
public org.apache.activemq.artemis.api.core.SimpleString getAddress()
getAddress in interface QueueBindingInfopublic void replaceQueueName(org.apache.activemq.artemis.api.core.SimpleString newName)
QueueBindingInforeplaceQueueName in interface QueueBindingInfopublic org.apache.activemq.artemis.api.core.SimpleString getFilterString()
getFilterString in interface QueueBindingInfopublic org.apache.activemq.artemis.api.core.SimpleString getQueueName()
getQueueName in interface QueueBindingInfopublic org.apache.activemq.artemis.api.core.SimpleString getUser()
getUser in interface QueueBindingInfopublic boolean isAutoCreated()
isAutoCreated in interface QueueBindingInfopublic void addQueueStatusEncoding(QueueStatusEncoding status)
addQueueStatusEncoding in interface QueueBindingInfopublic List<QueueStatusEncoding> getQueueStatusEncodings()
getQueueStatusEncodings in interface QueueBindingInfopublic void decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
decode in interface org.apache.activemq.artemis.core.journal.EncodingSupportpublic void encode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
encode in interface org.apache.activemq.artemis.core.journal.EncodingSupportpublic int getEncodeSize()
getEncodeSize in interface org.apache.activemq.artemis.core.journal.EncodingSupportCopyright © 2023 The Apache Software Foundation. All rights reserved.