Class RecordedQueue
- java.lang.Object
-
- com.rabbitmq.client.impl.recovery.RecordedEntity
-
- com.rabbitmq.client.impl.recovery.RecordedNamedEntity
-
- com.rabbitmq.client.impl.recovery.RecordedQueue
-
public class RecordedQueue extends RecordedNamedEntity
- Since:
- 3.3.0
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.Map<java.lang.String,java.lang.Object>
arguments
private boolean
autoDelete
(package private) static RecoveredQueueNameSupplier
DEFAULT_QUEUE_NAME_SUPPLIER
private boolean
durable
static java.lang.String
EMPTY_STRING
private boolean
exclusive
private RecoveredQueueNameSupplier
recoveredQueueNameSupplier
private boolean
serverNamed
-
Fields inherited from class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
name
-
Fields inherited from class com.rabbitmq.client.impl.recovery.RecordedEntity
channel
-
-
Constructor Summary
Constructors Constructor Description RecordedQueue(AutorecoveringChannel channel, java.lang.String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RecordedQueue
arguments(java.util.Map<java.lang.String,java.lang.Object> value)
RecordedQueue
autoDelete(boolean value)
RecordedQueue
durable(boolean value)
RecordedQueue
exclusive(boolean value)
java.util.Map<java.lang.String,java.lang.Object>
getArguments()
java.lang.String
getNameToUseForRecovery()
boolean
isAutoDelete()
boolean
isDurable()
boolean
isExclusive()
boolean
isServerNamed()
void
recover()
RecordedQueue
recoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
RecordedQueue
serverNamed(boolean value)
java.lang.String
toString()
-
Methods inherited from class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
getName
-
Methods inherited from class com.rabbitmq.client.impl.recovery.RecordedEntity
getChannel, getDelegateChannel
-
-
-
-
Field Detail
-
EMPTY_STRING
public static final java.lang.String EMPTY_STRING
- See Also:
- Constant Field Values
-
DEFAULT_QUEUE_NAME_SUPPLIER
static final RecoveredQueueNameSupplier DEFAULT_QUEUE_NAME_SUPPLIER
-
recoveredQueueNameSupplier
private RecoveredQueueNameSupplier recoveredQueueNameSupplier
-
durable
private boolean durable
-
autoDelete
private boolean autoDelete
-
arguments
private java.util.Map<java.lang.String,java.lang.Object> arguments
-
exclusive
private boolean exclusive
-
serverNamed
private boolean serverNamed
-
-
Constructor Detail
-
RecordedQueue
public RecordedQueue(AutorecoveringChannel channel, java.lang.String name)
-
-
Method Detail
-
exclusive
public RecordedQueue exclusive(boolean value)
-
isExclusive
public boolean isExclusive()
-
serverNamed
public RecordedQueue serverNamed(boolean value)
-
isServerNamed
public boolean isServerNamed()
-
recover
public void recover() throws java.io.IOException
- Specified by:
recover
in classRecordedNamedEntity
- Throws:
java.io.IOException
-
getNameToUseForRecovery
public java.lang.String getNameToUseForRecovery()
-
durable
public RecordedQueue durable(boolean value)
-
isDurable
public boolean isDurable()
-
autoDelete
public RecordedQueue autoDelete(boolean value)
-
isAutoDelete
public boolean isAutoDelete()
-
arguments
public RecordedQueue arguments(java.util.Map<java.lang.String,java.lang.Object> value)
-
getArguments
public java.util.Map<java.lang.String,java.lang.Object> getArguments()
-
recoveredQueueNameSupplier
public RecordedQueue recoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-