Interface IQueueSpecification
public interface IQueueSpecification : IEntityInfoSpecification<IQueueInfo>
- Inherited Members
Properties
IsAutoDelete
bool IsAutoDelete { get; }
Property Value
IsExclusive
bool IsExclusive { get; }
Property Value
QueueArguments
Dictionary<object, object> QueueArguments { get; }
Property Value
QueueName
string QueueName { get; }
Property Value
Methods
Arguments(Dictionary<object, object>)
IQueueSpecification Arguments(Dictionary<object, object> queueArguments)
Parameters
queueArgumentsDictionary<object, object>
Returns
AutoDelete(bool)
IQueueSpecification AutoDelete(bool isAutoDelete)
Parameters
isAutoDeletebool
Returns
Classic()
IClassicQueueSpecification Classic()
Returns
DeadLetterExchange(string)
IQueueSpecification DeadLetterExchange(string dlx)
Parameters
dlxstring
Returns
DeadLetterRoutingKey(string)
IQueueSpecification DeadLetterRoutingKey(string dlrk)
Parameters
dlrkstring
Returns
Delayed()
Configures a delayed queue (x-queue-type: delayed). Requires Tanzu RabbitMQ 4.x or later.
IDelayedQueueSpecification Delayed()
Returns
Exclusive(bool)
IQueueSpecification Exclusive(bool isExclusive)
Parameters
isExclusivebool
Returns
Expires(TimeSpan)
IQueueSpecification Expires(TimeSpan expiration)
Parameters
expirationTimeSpan
Returns
Jms()
Configures a JMS queue (x-queue-type: jms). Requires a broker that supports the JMS queue type.
IJmsQueueSpecification Jms()
Returns
LeaderLocator(LeaderLocatorStrategy)
IQueueSpecification LeaderLocator(LeaderLocatorStrategy strategy)
Parameters
strategyLeaderLocatorStrategy
Returns
MaxLength(long)
IQueueSpecification MaxLength(long maxLength)
Parameters
maxLengthlong
Returns
MaxLengthBytes(ByteCapacity)
IQueueSpecification MaxLengthBytes(ByteCapacity maxLengthBytes)
Parameters
maxLengthBytesByteCapacity
Returns
MessageTtl(TimeSpan)
IQueueSpecification MessageTtl(TimeSpan ttl)
Parameters
ttlTimeSpan
Returns
Name(string)
IQueueSpecification Name(string queueName)
Parameters
queueNamestring
Returns
OverflowStrategy(OverFlowStrategy)
IQueueSpecification OverflowStrategy(OverFlowStrategy overflow)
Parameters
overflowOverFlowStrategy
Returns
PurgeAsync()
Task<ulong> PurgeAsync()
Returns
Quorum()
IQuorumQueueSpecification Quorum()
Returns
SingleActiveConsumer(bool)
IQueueSpecification SingleActiveConsumer(bool singleActiveConsumer)
Parameters
singleActiveConsumerbool
Returns
Stream()
IStreamSpecification Stream()
Returns
Type(QueueType)
IQueueSpecification Type(QueueType queueType)
Parameters
queueTypeQueueType