Interface IConsumer

Namespace

RabbitMQ.AMQP.Client

Assembly

RabbitMQ.AMQP.Client.dll

API to consume messages from a RabbitMQ queue.

Instances are configured and created with a IConsumerBuilder.

See ConsumerBuilder() and IConsumerBuilder.

public interface IConsumer : ILifeCycle, IDisposable

Inherited Members

ILifeCycle.CloseAsync()

ILifeCycle.State

ILifeCycle.ChangeState

IDisposable.Dispose()

Properties

Queue

Returns queue name the consumer is consuming from. The Queue name is usually configured by the user via the IConsumerBuilder, but can also be generated by the client the special direct-reply-to queue.

string Queue { get; }

Property Value

string

UnsettledMessageCount

Returns the number of unsettled messages.

long UnsettledMessageCount { get; }

Property Value

long

Methods

Pause()

Pause the consumer to stop receiving messages.

void Pause()

Unpause()

Request to receive messages again.

void Unpause()