连接到 AWS 上设置的 ActiveMQ 后几秒后连接关闭

Question

我正在连接到托管在 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();

        }
    }
}

控制台显示如下没有收到消息！几秒钟后控制台存在？

Answer 1

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

连接到 AWS 上设置的 ActiveMQ 后几秒后连接关闭

Connection closes after few seconds when connecting to ActiveMQ set up on AWS

c#

activemq

nms