Commify.Titan.API.RabbitMQ 0.6.0

Commify.Titan.API.RabbitMQ

Self-contained NuGet package that enables RabbitMQ messaging to any .NET 8 or .NET 10 app.

Contact

Titan API Team

Configuration

The necessary configuration in appsettings is:

RabbitMQ

"TitanCommunication": {
	"RabbitMQ": {
		"ConnectionString" : "connection_string",
		"Host": "host" //if connection string is not available
		"Port": 5672 //if connection string is not available
		"BasicCredentials": { //if set will use basic auth, if not, will fall back to AAD token authentication
			"Username": "username",
			"Password": "password"
		}
	}
}

Identity

"Identity": {
	"WorkstreamToken": {
		"KeyVaultUrl": "https://my-key-vault.net/",
		"ManagedIdentity": "managedIdentityId"
		},
		"Mappings": [
        {
          "Key": "example-service",
          "Value": "exampleServiceId"
        }
      ]
}

Additional environment variables:

• K8S_POD_NAME (Required for unique queue generation)

Usage

Publisher

To enable it, this component offers a selection of extension methods over IServiceCollection:

• RegisterEventPublisher handles event publishing, no configuration needed.
• RegisterMessagePublisher registers an IMessagePublisher<TMessage> that publishes messages to the configured virtual host and exchange name. Comes in two flavours, one that provides IServiceProvider in the options delegate and one that doesn't.
• RegisterMessagePublisherWithOutbox registers an IOutboxMessagePublisher<TMessage> that publishes messages using an outbox to the configured virtual host and exchange name. Comes in two flavours, one that provides IServiceProvider in the options delegate and one that doesn't.

Consumer

To enable it, this component offers a selection of extension methods over IServiceCollection:

• RegisterEventConsumer handles event consuming, no configuration needed.
• RegisterMessageConsumer requires the user to provide an implementation of IMessageConsumer<TMessage>, which will be called when a message is consumed. Configuration requires a virtual host, an exchange name to bind to, the exchange type and an optional queue name. If the queue name is not specified it will be generated automatically with a name based on the K8S_POD_NAME variable and will self-delete when the application is stopped. Comes in two flavours, one that provides IServiceProvider in the options delegate and one that doesn't.
• RegisterChannelMessageConsumer registers a Channel<QueueMessage<TMessage>> that can be used to consume messages. Configuration requires a virtual host, an exchange name to bind to, the exchange type and an optional queue name. If the queue name is not specified it will be generated automatically with a name based on the K8S_POD_NAME variable and will self-delete when the application is stopped. Comes in two flavours, one that provides IServiceProvider in the options delegate and one that doesn't.

Custom implementation

If a more flexible implementation is desired, only needing the connection management part with absolute freedom over publishing and consuming messages we also provide the RegisterRabbitMQMessaging extension method. It will only register a singleton IConnectionManagement.