-3

我正在尝试使用 C# 中的 AMQP.Net Lite 向 ActiveMQ 发送消息。将消息发送到队列工作正常,但我无法将消息发送到主题。我为此使用以下代码:

Address address = new Address("amqp://guest:guest@localhost:5672");
Connection connection = new Connection(address);
Session session = new Session(connection);

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

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

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

0 回答 0