Azure / Azure/amqpnetlite

Documentation to work with Activemq Artemis

Open
#286 1 comment 8 reactions 0 assignees View on GitHub
Info
Dominant language
C#
Stars
419
Forks
155
PR merge metrics
No merged PRs in 30d

Description

The standard HelloWorld sample works in multiple Amqp 1.0 brokers, I had some issues using Activemq Artemis. It was caused by artemis standard auto-creation feature. all-defaults it will create topics. When you want to work with queues you need to specify it in either broker.xml, or you can set it using Capabilities, see below. Might be good to document how to work with different brokers.

```
public class SimpleAmqpTest
{
[Fact]
public async Task TestHelloWorld()
{
Address address = new Address("amqp://guest:guest@localhost:5672");
Connection connection = await Connection.Factory.CreateAsync(address);
Session session = new Session(connection);

Message message = new Message("Hello AMQP");

Target target = new Target
{
Address = "q1",
Capabilities = new Symbol[] { new Symbol("queue") }
};

SenderLink sender = new SenderLink(session, "sender-link", target, null);
await sender.SendAsync(message);

Source source = new Source
{
Address = "q1",
Capabilities = new Symbol[] { new Symbol("queue") }
};

ReceiverLink receiver = new ReceiverLink(session, "receiver-link", source, null);
message = await receiver.ReceiveAsync();
receiver.Accept(message);

await sender.CloseAsync();
await receiver.CloseAsync();
await session.CloseAsync();
await connection.CloseAsync();
}
}
```

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.