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>argumentsprivate booleanautoDelete(package private) static RecoveredQueueNameSupplierDEFAULT_QUEUE_NAME_SUPPLIERprivate booleandurablestatic java.lang.StringEMPTY_STRINGprivate booleanexclusiveprivate RecoveredQueueNameSupplierrecoveredQueueNameSupplierprivate booleanserverNamed-
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 RecordedQueuearguments(java.util.Map<java.lang.String,java.lang.Object> value)RecordedQueueautoDelete(boolean value)RecordedQueuedurable(boolean value)RecordedQueueexclusive(boolean value)java.util.Map<java.lang.String,java.lang.Object>getArguments()java.lang.StringgetNameToUseForRecovery()booleanisAutoDelete()booleanisDurable()booleanisExclusive()booleanisServerNamed()voidrecover()RecordedQueuerecoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)RecordedQueueserverNamed(boolean value)java.lang.StringtoString()-
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:
recoverin 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:
toStringin classjava.lang.Object
-
-