Show / Hide Table of Contents

Interface IConsumer

Represents a message consumer that can receive messages from a destination (queue or topic) in a messaging system.

Inherited Members
IMessageCreator.CreateBytesMessageAsync()
IMessageCreator.CreateBytesMessageAsync(byte[])
IMessageCreator.CreateMapMessageAsync()
IMessageCreator.CreateMessageAsync()
IMessageCreator.CreateStreamMessageAsync()
IMessageCreator.CreateTextMessageAsync()
IMessageCreator.CreateTextMessageAsync(string)
IDestinationProvider.CreateTemporaryQueueAsync()
IDestinationProvider.CreateTemporaryTopicAsync()
IDestinationProvider.GetQueueAsync(string)
IDestinationProvider.GetTopicAsync(string)
Namespace: CodersRealm.AmqpClient
Assembly: CodersRealm.AmqpClient.dll
Syntax
public interface IConsumer : IMessageCreator, IDestinationProvider
Remarks

Acknowledgement and transaction controls are omitted; use TryAs/AsXxx helpers to acquire those capabilities when available.

Properties

AcknowledgementMode

The acknowledgement mode configured for this message receiver.

Declaration
AcknowledgementMode AcknowledgementMode { get; }
Property Value
Type Description
AcknowledgementMode

IsDisposed

Gets a value indicating whether this has been disposed and is no longer usable.

Declaration
bool IsDisposed { get; }
Property Value
Type Description
bool

IsRunning

Gets a value indicating whether currently running.

Declaration
bool IsRunning { get; }
Property Value
Type Description
bool

Tag

A unique identifier for this message receiver instance.

Declaration
Guid Tag { get; }
Property Value
Type Description
Guid

Extension Methods

ConsumerExtensions.AsAcknowledge(IConsumer)
ConsumerExtensions.AsTransactional(IConsumer)
ConsumerExtensions.TryAsAcknowledge(IConsumer, out IAcknowledgeConsumer?)
ConsumerExtensions.TryAsTransactional(IConsumer, out ITransactionalConsumer?)
In this article
Back to top Generated by DocFX