Interface ISubscriber

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

Inherited Members

IConsumer.IsDisposed

IConsumer.IsRunning

IConsumer.AcknowledgementMode

IConsumer.Tag

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 ISubscriber : IConsumer, IMessageCreator, IDestinationProvider

Remarks

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

Extension Methods

ConsumerExtensions.AsAcknowledge(IConsumer)

ConsumerExtensions.AsTransactional(IConsumer)

ConsumerExtensions.TryAsAcknowledge(IConsumer, out IAcknowledgeConsumer?)

ConsumerExtensions.TryAsTransactional(IConsumer, out ITransactionalConsumer?)