首页 > 其他 > 详细

ActiveMQ消息订阅成功,消息接受不到

时间:2021-03-11 22:29:06      阅读:114      评论:0      收藏:0      [点我收藏+]

今天对接第三方报警消息。厂商使用ActiveMQ消息服务。订阅成功后,消息一直接受不到。检查厂商服务器系统时间,发现和我电脑时间不一致。修改我电脑时间后,可以接受到报警消息。

c#订阅ActiveMQ消息nuget搜索apache.NMS库安装。

消息订阅代码:

 IConnectionFactory Factory = new ConnectionFactory(textBoxURL.Text);

                    Connection = Factory.CreateConnection();

                    Connection.ClientId = "ActiveMQ.Listener1";

                    Connection.Start(); // 开启侦听

                    Session = Connection.CreateSession();

     //MIDDLEWARE_ALARM 消息主题

                    Consumer = Session.CreateDurableConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQTopic("MIDDLEWARE_ALARM"), "Customer1", null, false);

                    Consumer.Listener += OnMessageReceived;

 

//监听消息处理

  private void OnMessageReceived(IMessage message)

        {

            if (message is ITextMessage)

            {

                this.BeginInvoke(new Action<string>((msg) => { textBoxMessage.AppendText(msg + "\r\n"); }), ((ITextMessage)message).Text);

            }

        }

ActiveMQ消息订阅成功,消息接受不到

原文:https://www.cnblogs.com/tianjinjin/p/14520410.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!