如何在C#中从Artemis组播队列接收消息？

Question

我准备使用C#应用程序通过ActiveMQ Artemis发送和接收消息。在选播模式下，一切都在工作。

private void Receiver()
{
    IConnectionFactory factory = new NMSConnectionFactory("multicast:tcp://172.29.213.150:61616");
    IConnection connection = factory.CreateConnection("artemis", "simetraehcapa");
    connection.Start();
    ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
    IDestination destination = SessionUtil.GetDestination(session, "hund");
    IMessageConsumer receiver = session.CreateConsumer(destination);
    receiver.Listener += new MessageListener(Message_Listener);
}

通常我会收到消息，因为我只是从选播切换到多播，但实际上我什么也没有收到。

Answer 1

如果使用AcitveMQ OpenWire NMS客户机，您没有将所做的奇怪的多播应用到URI，这将给您一个错误。如果您使用Session API，客户机就应该正常工作，而不是那种导致许多人遇到问题的令人困惑的SessionUtil API。

我会使用session.createTopic获得一个ITopic实例，然后使用该实例创建一个消费者，该消费者应该映射到Artemis多播地址，而不需要做任何事情。当然，您需要在发送任何消息之前进行订阅，因为如果发送消息时周围没有消费者，主题不会保留消息。