zoukankan      html  css  js  c++  java
  • 关于ActiveMQ接收端停止接收的方法

    现在有一个需求:

    在发送端服务器出现故障后,接收端的接收方法要停下来,关于停止接收的方法,我做了下面这些事情:

    // 获取 ConnectionFactory
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                    "tcp://" + ip + ":61616");
    // 创建 Connection
    Connection connection = connectionFactory.createConnection();
    connection.start();
    
    //把connection放入map,方便停止
    ConfigInfo.receiveSocket.put("connection", connection);
            System.out.println("connectionmap======"+ConfigInfo.receiveSocket.get("connection"));
    // 创建 Session
    Session session = connection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);

    然后写了一个方法,停止接收 ,其实就是将connection关闭:

    public static void stopReceivewebsite() throws JMSException{
            System.out.println("websiteimage开始停止方法");
            System.out.println(ConfigInfo.receiveSocket.get("connection"));
            Connection connection = (Connection) ConfigInfo.receiveSocket.get("connection");
            connection.close();
            System.out.println("websiteimage接收停止完成");
        }

     亲测好使。

  • 相关阅读:
    Java项目xml相关配置
    Jquery的bind跟on绑定事件的区别
    命令操作Mysql数据库
    Jquery实现功能---购物车
    Jquery插件---渐隐轮播
    Jquery制作插件---内容切换
    PCB画板的快捷键
    蓝牙2.0传数据给数码管
    蓝牙2.0传数据给数码管
    共阳极数码管计数器
  • 原文地址:https://www.cnblogs.com/zjiacun/p/6831421.html
Copyright © 2011-2022 走看看