我正试图以你好世界为例。有了常规的ActiveMQ,它是有效的,但是ActiveMQ-Artemis让我头疼。我想有些配置我做得不正确。地址是通过多播路由生成的。我想我需要单播(队列路由)。
以下代码段不适用于ActiveMQ的Artemis版本。有没有可能我要做的?我想自动创建一个持久队列。
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");
var target = new Target
{
Address = "simple-queue",
Durable = 1,
};
SenderLink sender = new SenderLink(session, "sender-link", target, null);
await sender.SendAsync(message);
ReceiverLink receiver = new ReceiverLink(session, "receiver-link", "simple-queue");
message = await receiver.ReceiveAsync();
receiver.Accept(message);
await sender.CloseAsync();
await receiver.CloseAsync();
await session.CloseAsync();
await connection.CloseAsync();
}
}