website·Indexed 30 days ago
https://havret.github.io/dotnet-activemq-artemis-client/A lightweight, .NET Standard compliant library built on top of AmqpNetLite for interacting with Apache Artemis. The client supports asynchronous messaging, transactions, message filtering, request-reply patterns, and provides integration with Microsoft.Extensions.DependencyInjection via ArtemisNetClient.Extensions.DependencyInjection.
ActiveMQ Artemis supports two durability modes that determine how messages are persisted and acknowledged:
SendAsync.Send method, which is non-blocking and does not wait for broker confirmation.TestKit class is the core of the ArtemisNetClient.Testing package. It spins up an in-memory message broker that supports the AMQP protocol, allowing a system under test to connect, send, and receive messages without requiring a full external broker installation.var endpoint = Endpoint.Create(
host: "localhost",
port: 5672,
"artemis",
"artemis"
);
using var testKit = new TestKit(endpoint);ArtemisNetClient.Testing package provides tools to test messaging-dependent parts of an application in a controlled environment using an in-memory message broker.dotnet add package ArtemisNetClient.TestingIConsumer by specifying an address and routing type. Messages are delivered automatically and buffered. Use ReceiveAsync to retrieve a message from the buffer. If the buffer is empty, the method waits asynchronously. A CancellationToken should be used to handle application shutdown or timeouts.var consumer = await connection.CreateConsumerAsync("a1", RoutingType.Anycast);
// Simple receive
var message = await consumer.ReceiveAsync();
// Receive with cancellation token for graceful shutdown
var cts = new CancellationTokenSource();
var messageWithToken = await consumer.ReceiveAsync(cts.Token);The client library supports automatic recovery of connections, producers, and consumers, which is enabled by default. Recovery behavior is governed by the IRecoveryPolicy interface, which determines the number of retry attempts and the delay between them. To retry indefinitely, set RetryCount to int.MaxValue.
If the initial connection fails, automatic recovery also triggers. To prevent ConnectionFactory.CreateAsync from waiting indefinitely when using a permanent recovery policy, pass a CancellationToken to the method.
public interface IRecoveryPolicy
{
int RetryCount { get; }
TimeSpan GetDelay(int attempt);
}Microsoft.Extensions.DependencyInjection, install the following NuGet packages based on your application type. For ASP.NET Core or generic hosted applications, both packages are required.# For DI-only registration
dotnet add package ArtemisNetClient.Extensions.DependencyInjection
# For ASP.NET Core or generic hosted applications
dotnet add package ArtemisNetClient.Extensions.Hostingdotnet add package ArtemisNetClientMessage priority defines the importance of a message, where higher priority messages are delivered before lower priority ones. Messages with the same priority are delivered in the order they were sent.
Key priority rules:
Priority is set to null, the message defaults to normal priority (4).Message object takes precedence over the priority configured on the Producer.Transaction class to ensure a group of messages are sent in an 'all or nothing' manner. Messages sent within a transaction are not visible to consumers until CommitAsync() is called. If any operation fails before the commit, no messages from that transaction will be delivered.var connectionFactory = new ConnectionFactory();
var endpoint = Endpoint.Create("localhost", 5672, "guest", "guest");
var connection = await connectionFactory.CreateAsync(endpoint);
await using (var transaction = new Transaction())
{
await producer.SendAsync(
address: "credit-queue",
message: new Message("credit:500,account:a"),
transaction: transaction
);
await producer.SendAsync(
address: "debit-queue",
message: new Message("debit:500,account:b"),
transaction: transaction);
await transaction.CommitAsync();
}