0

我正在连接到托管在 AWS 上的 Apache Active MQ，以将我的应用程序集成到自定义服务中。我需要一直保持这种运行状态，而不是像现在这样一次。下面的代码有效，但仅适用于一条消息，我需要始终保持连接处于活动状态，以便接收所有消息。这是代码。

    using Apache.NMS;
    using Apache.NMS.Util;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading;
    using System.Threading.Tasks;

namespace ApacheMQAsync
{
    class Program
    {

        protected static ITextMessage message = null;


        public static void Main(string[] args)
        {

            Uri connecturi = new Uri("URL:61617");

            Console.WriteLine("About to connect to " + connecturi);

            // NOTE: ensure the nmsprovider-activemq.config file exists in the executable folder.
            IConnectionFactory factory = new Apache.NMS.ActiveMQ.ConnectionFactory(connecturi);

            IConnection connection = factory.CreateConnection("username", "password");

            ISession session = connection.CreateSession();
            IDestination destination = SessionUtil.GetDestination(session, "queue://FOO.BAR");

            Console.WriteLine("Using destination: " + destination);

            // Create a consumer and producer
            IMessageConsumer consumer = session.CreateConsumer(destination);

            consumer.Listener += new MessageListener(OnMessage);
            connection.Start();
            // Wait for the message


            if (message == null)
            {
                Console.WriteLine("No message received!");
            }
            else
            {
                Console.WriteLine("Received message with ID:   " + message.NMSMessageId);
                Console.WriteLine("Received message with text: " + message.Text);
            }
        }

        protected static void OnMessage(IMessage receivedMsg)
        {
            message = receivedMsg as ITextMessage;
            message.Acknowledge();

        }
    }
}

在控制台上显示以下未收到消息！几秒钟后控制台存在？

4

1 回答 1

1

那里没有真正的魔法，你需要做一些事情来保持你的应用程序运行，例如暂停控制台输入或循环睡眠或其他等待类型的调用，然后检查你的应用程序是否应该继续运行。JMS 客户端不能保证让您的应用程序保持打开和运行，您永远不应该依赖它。

于 2018-05-31T20:51:58.717 回答