Class BlockingQueueConsumer

Inheritance

System.Object

BlockingQueueConsumer

Namespace: Steeltoe.Messaging.RabbitMQ.Listener

Assembly: Steeltoe.Messaging.RabbitMQ.dll

Syntax

public class BlockingQueueConsumer : object

Constructors

| Edit this page View Source

BlockingQueueConsumer(IConnectionFactory, IMessageHeadersConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, Boolean, UInt16, ILoggerFactory, String[])

Declaration

public BlockingQueueConsumer(IConnectionFactory connectionFactory, IMessageHeadersConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, bool transactional, ushort prefetchCount, ILoggerFactory loggerFactory, params string[] queues)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
IMessageHeadersConverter	messagePropertiesConverter
ActiveObjectCounter<BlockingQueueConsumer>	activeObjectCounter
AcknowledgeMode	acknowledgeMode
System.Boolean	transactional
System.UInt16	prefetchCount
ILoggerFactory	loggerFactory
System.String[]	queues

| Edit this page View Source

BlockingQueueConsumer(IConnectionFactory, IMessageHeadersConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, Boolean, UInt16, Boolean, Dictionary<String, Object>, ILoggerFactory, String[])

Declaration

public BlockingQueueConsumer(IConnectionFactory connectionFactory, IMessageHeadersConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, bool transactional, ushort prefetchCount, bool defaultRequeueRejected, Dictionary<string, object> consumerArgs, ILoggerFactory loggerFactory, params string[] queues)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
IMessageHeadersConverter	messagePropertiesConverter
ActiveObjectCounter<BlockingQueueConsumer>	activeObjectCounter
AcknowledgeMode	acknowledgeMode
System.Boolean	transactional
System.UInt16	prefetchCount
System.Boolean	defaultRequeueRejected
Dictionary<System.String, System.Object>	consumerArgs
ILoggerFactory	loggerFactory
System.String[]	queues

| Edit this page View Source

BlockingQueueConsumer(IConnectionFactory, IMessageHeadersConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, Boolean, UInt16, Boolean, Dictionary<String, Object>, Boolean, ILoggerFactory, String[])

Declaration

public BlockingQueueConsumer(IConnectionFactory connectionFactory, IMessageHeadersConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, bool transactional, ushort prefetchCount, bool defaultRequeueRejected, Dictionary<string, object> consumerArgs, bool exclusive, ILoggerFactory loggerFactory, params string[] queues)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
IMessageHeadersConverter	messagePropertiesConverter
ActiveObjectCounter<BlockingQueueConsumer>	activeObjectCounter
AcknowledgeMode	acknowledgeMode
System.Boolean	transactional
System.UInt16	prefetchCount
System.Boolean	defaultRequeueRejected
Dictionary<System.String, System.Object>	consumerArgs
System.Boolean	exclusive
ILoggerFactory	loggerFactory
System.String[]	queues

| Edit this page View Source

BlockingQueueConsumer(IConnectionFactory, IMessageHeadersConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, Boolean, UInt16, Boolean, Dictionary<String, Object>, Boolean, Boolean, ILoggerFactory, String[])

Declaration

public BlockingQueueConsumer(IConnectionFactory connectionFactory, IMessageHeadersConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, bool transactional, ushort prefetchCount, bool defaultRequeueRejected, Dictionary<string, object> consumerArgs, bool noLocal, bool exclusive, ILoggerFactory loggerFactory, params string[] queues)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
IMessageHeadersConverter	messagePropertiesConverter
ActiveObjectCounter<BlockingQueueConsumer>	activeObjectCounter
AcknowledgeMode	acknowledgeMode
System.Boolean	transactional
System.UInt16	prefetchCount
System.Boolean	defaultRequeueRejected
Dictionary<System.String, System.Object>	consumerArgs
System.Boolean	noLocal
System.Boolean	exclusive
ILoggerFactory	loggerFactory
System.String[]	queues

| Edit this page View Source

BlockingQueueConsumer(IConnectionFactory, IMessageHeadersConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, Boolean, UInt16, Boolean, ILoggerFactory, String[])

Declaration

public BlockingQueueConsumer(IConnectionFactory connectionFactory, IMessageHeadersConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, bool transactional, ushort prefetchCount, bool defaultRequeueRejected, ILoggerFactory loggerFactory, params string[] queues)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
IMessageHeadersConverter	messagePropertiesConverter
ActiveObjectCounter<BlockingQueueConsumer>	activeObjectCounter
AcknowledgeMode	acknowledgeMode
System.Boolean	transactional
System.UInt16	prefetchCount
System.Boolean	defaultRequeueRejected
ILoggerFactory	loggerFactory
System.String[]	queues

Properties

| Edit this page View Source

AbortStarted

Declaration

public long AbortStarted { get; }

Property Value

Type	Description
System.Int64

| Edit this page View Source

AcknowledgeMode

Declaration

public AcknowledgeMode AcknowledgeMode { get; }

Property Value

Type	Description
AcknowledgeMode

| Edit this page View Source

ActiveObjectCounter

Declaration

public ActiveObjectCounter<BlockingQueueConsumer> ActiveObjectCounter { get; }

Property Value

Type	Description
ActiveObjectCounter<BlockingQueueConsumer>

| Edit this page View Source

BackOffExecution

Declaration

public IBackOffExecution BackOffExecution { get; set; }

Property Value

Type	Description
IBackOffExecution

| Edit this page View Source

Cancel

Declaration

public AtomicBoolean Cancel { get; }

Property Value

Type	Description
AtomicBoolean

| Edit this page View Source

Cancelled

Declaration

protected bool Cancelled { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

Channel

Declaration

public RabbitMQ.Client.IModel Channel { get; }

Property Value

Type	Description
RabbitMQ.Client.IModel

| Edit this page View Source

ConnectionFactory

Declaration

public IConnectionFactory ConnectionFactory { get; }

Property Value

Type	Description
IConnectionFactory

| Edit this page View Source

ConsumerArgs

Declaration

public Dictionary<string, object> ConsumerArgs { get; }

Property Value

Type	Description
Dictionary<System.String, System.Object>

| Edit this page View Source

DeclarationRetries

Declaration

public int DeclarationRetries { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

Declaring

Declaration

public bool Declaring { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

DefaultRequeueRejected

Declaration

public bool DefaultRequeueRejected { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

DeliveryTags

Declaration

public HashSet<ulong> DeliveryTags { get; }

Property Value

Type	Description
HashSet<System.UInt64>

| Edit this page View Source

Exclusive

Declaration

public bool Exclusive { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

FailedDeclarationRetryInterval

Declaration

public int FailedDeclarationRetryInterval { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

HasDelivery

Declaration

protected bool HasDelivery { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

LastRetryDeclaration

Declaration

public long LastRetryDeclaration { get; set; }

Property Value

Type	Description
System.Int64

| Edit this page View Source

LocallyTransacted

Declaration

public bool LocallyTransacted { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

Logger

Declaration

public ILogger<BlockingQueueConsumer> Logger { get; }

Property Value

Type	Description
ILogger<BlockingQueueConsumer>

| Edit this page View Source

LoggerFactory

Declaration

public ILoggerFactory LoggerFactory { get; }

Property Value

Type	Description
ILoggerFactory

| Edit this page View Source

MessageHeadersConverter

Declaration

public IMessageHeadersConverter MessageHeadersConverter { get; set; }

Property Value

Type	Description
IMessageHeadersConverter

| Edit this page View Source

MissingQueues

Declaration

public HashSet<string> MissingQueues { get; }

Property Value

Type	Description
HashSet<System.String>

| Edit this page View Source

NoLocal

Declaration

public bool NoLocal { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

NormalCancel

Declaration

public bool NormalCancel { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

PrefetchCount

Declaration

public ushort PrefetchCount { get; }

Property Value

Type	Description
System.UInt16

| Edit this page View Source

Queue

Declaration

public BlockingCollection<Delivery> Queue { get; }

Property Value

Type	Description
BlockingCollection<Delivery>

| Edit this page View Source

QueueCount

Declaration

public int QueueCount { get; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

Queues

Declaration

public List<string> Queues { get; }

Property Value

Type	Description
List<System.String>

| Edit this page View Source

ResourceHolder

Declaration

public RabbitResourceHolder ResourceHolder { get; set; }

Property Value

Type	Description
RabbitResourceHolder

| Edit this page View Source

RetryDeclarationInterval

Declaration

public int RetryDeclarationInterval { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

Shutdown

Declaration

public RabbitMQ.Client.ShutdownEventArgs Shutdown { get; }

Property Value

Type	Description
RabbitMQ.Client.ShutdownEventArgs

| Edit this page View Source

ShutdownTimeout

Declaration

public int ShutdownTimeout { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

TagStrategy

Declaration

public IConsumerTagStrategy TagStrategy { get; set; }

Property Value

Type	Description
IConsumerTagStrategy

| Edit this page View Source

Transactional

Declaration

public bool Transactional { get; }

Property Value

Type	Description
System.Boolean

Methods

| Edit this page View Source

BasicCancel()

Declaration

protected void BasicCancel()

| Edit this page View Source

BasicCancel(Boolean)

Declaration

protected void BasicCancel(bool expected)

Parameters

Type	Name	Description
System.Boolean	expected

| Edit this page View Source

ClearDeliveryTags()

Declaration

public void ClearDeliveryTags()

| Edit this page View Source

CommitIfNecessary(Boolean)

Declaration

public bool CommitIfNecessary(bool localTx)

Parameters

Type	Name	Description
System.Boolean	localTx

Returns

Type	Description
System.Boolean

| Edit this page View Source

GetConsumerTags()

Declaration

public List<string> GetConsumerTags()

Returns

Type	Description
List<System.String>

| Edit this page View Source

NextMessage()

Declaration

public IMessage NextMessage()

Returns

Type	Description
IMessage

| Edit this page View Source

NextMessage(Int32)

Declaration

public IMessage NextMessage(int timeout)

Parameters

Type	Name	Description
System.Int32	timeout

Returns

Type	Description
IMessage

| Edit this page View Source

RollbackOnExceptionIfNecessary(Exception)

Declaration

public void RollbackOnExceptionIfNecessary(Exception ex)

Parameters

Type	Name	Description
Exception	ex

| Edit this page View Source

Start()

Declaration

public void Start()

| Edit this page View Source

Stop()

Declaration

public void Stop()

| Edit this page View Source

ToString()

Declaration

public override string ToString()

Returns

Type	Description
System.String