Interface ISubscriber

Broker-backed message receiver exposing core, transport-agnostic operations for consuming messages and managing destinations.

Inherited Members

IConsumer.IsDisposed

IConsumer.IsRunning

IConsumer.AcknowledgementMode

IConsumer.Tag

IConsumer.CreateTemporaryQueueAsync()

IConsumer.CreateTemporaryTopicAsync()

IConsumer.GetQueueAsync(string)

IConsumer.GetTopicAsync(string)

Namespace: CodersRealm.NmsAmqpClient

Assembly: CodersRealm.NmsAmqpClient.dll

Syntax

public interface ISubscriber : IConsumer

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?)