Namespace CodersRealm.NmsAmqpClient

Classes

AcknowledgementCommandException

Represents an exception that is thrown when an acknowledgement command fails due to an underlying error.

Client

Represents a reusable AMQP client that manages an underlying connection and provides access to message broker producers, consumers and subscribers. The client is safe for concurrent use and supports asynchronous startup and disposal.

ConsumerExtensions

Runtime helpers for extracting capability-specific interfaces from a generic IConsumer instance. These helpers avoid breaking changes while providing explicit runtime checks for acknowledgement/transactional features.

ConsumerOptions

Options for configuring a message consumer of a queue.

DefaultRedeliveryPolicy

Represents the default redelivery policy used to determine message redelivery behavior.

MessageQueueEventArgs

Provides data for events raised when a message is queued, processed or otherwise observed by the consumer pipeline.

NmsAmqpClientOptions

Represents the configuration options for the NMS AMQP client, including connection string and redelivery policy.

ProducerOptions

Options used to configure a message producer.

RedeliveryPolicy

A policy used to customize exactly how you want the redelivery to work.

ResponderOptions

Configuration options that control where and how a responder sends reply messages. These options allow specifying an explicit Apache.NMS.IDestination, or alternatively a destination name and type to be used when creating the response destination.

SendResponseException

Represents an exception that is thrown when an error occurs while sending a response message.

ServiceCollectionExtensions

Provides extension methods for IServiceCollection to register NMS AMQP client services.

SubscriberOptions

Options used to configure a subscriber to a topic.

TransactionalCommandException

Represents an exception that is thrown when a transactional command fails during execution.

UserHandlerException

Represents an exception that is thrown when a user-provided handler throws an exception.

Interfaces

IAcknowledgeConsumer

Represents a consumer that supports explicit acknowledge and negative acknowledge operations (e.g. ClientAcknowledge or IndividualAcknowledge modes).

IClient

Represents a client that manages AMQP connection lifecycle and related producer/consumer/subscriber managers.

IConsumer

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

IConsumerManager

Manager abstraction responsible for creating and managing IConsumer instances. Implementations provide asynchronous creation methods with various configuration options and support deletion/lifecycle management of created consumers.

IProducer

Defines the contract for a message producer that creates and sends messages to queues or topics in a messaging system. Provides asynchronous methods for message creation, sending, and transaction management. Implementations are expected to be safe for concurrent use and to honor cancellation semantics where applicable.

IProducerManager

Factory abstraction responsible for creating and managing IProducer instances. Implementations create producers for destinations or queues and support deletion and lifecycle observation. All creation methods are asynchronous to allow for remote or I/O-bound producer initialization.

ISubscriber

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

ISubscriberManager

Manager abstraction responsible for creating and managing ISubscriber instances. Implementations provide asynchronous creation methods with various configuration options and support deletion/lifecycle management of created subscribers.

ITransactionalConsumer

Represents a consumer that supports transactional commands (Commit/Rollback).

Enums

MessageAction

Defines the actions that can be taken for a message processed by the consumer.

ResponseDestinationType

Specifies the type of destination to which a response message is sent.

Delegates

ConsumerTransformerAsync

A delegate that a client can register that will be called each time a consumer dispatches a message to the client code to allow the client to Transform a received message from one type to another, StreamMessage to TextMessage, ObjectMessage to TextMessage containing XML, etc. This allows a client to create a consumer that will automatically transform a message to a type that the client is capable of processing or adding additional information to a received message. For messages that do not need to be processed the client should return null from this method, in this case the original message will be dispatched to the client.

OnErrorHandlerAsync

Delegate invoked when an error occurs while processing messages.

OnMessageReceivedHandlerAsync

Delegate invoked when a message is received from the message queue.

ProducerTransformerAsync

A delegate that a client can register that will be called each time a Producer's send method is called to allow the client to Transform a sent message from one type to another, StreamMessage to TextMessage, ObjectMessage to TextMessage containing XML, etc. This allows a client to create a producer that will automatically transform a message to a type that some receiving client is capable of processing or adding additional information to a sent message such as additional message headers, etc. For messages that do not need to be processed the client should return null from this method, in this case the original message will be sent.

SubscriberTransformerAsync

A delegate that a client can register that will be called each time a subscriber dispatches a message to the client code to allow the client to Transform a received message from one type to another, StreamMessage to TextMessage, ObjectMessage to TextMessage containing XML, etc. This allows a client to create a subscriber that will automatically transform a message to a type that the client is capable of processing or adding additional information to a received message. For messages that do not need to be processed the client should return null from this method, in this case the original message will be dispatched to the client.