开发者社区 问答 正文

请问ActiveMQ 连接池 的connection出现异常如何重新连接?

写一个接口模块。提供通用接口,可以连接queue/topic 接收和发送内容。由于发送的频率比较快,所有不能每发送一个数据就打开一个连接再关闭,需要有一种连接池的功能。消息的侦听需要有断线重连的机制,就是连接异常断开后,程序能够自动重新启动侦听。

 
factory = new ActiveMQConnectionFactory(brokeURL);
        poolFactory = new PooledConnectionFactory(factory);
        // 配置连接池
        poolFactory.setMaximumActiveSessionPerConnection(5);
        poolFactory.setMaxConnections(5);
        poolFactory.setIdleTimeout(120);
        conn = poolFactory.createConnection();
                //设置conn异常监听
                conn.setExceptionListener(new ExceptionListener() {
 
            @Override
            public void onException(JMSException arg0) {
                // 出现异常,重新连接
                System.out.println("异常。。。。");
            }
        });
        conn.start();

当出现异常的时候我应该怎么重新连接,或者说怎么测试?

展开
收起
爵霸 2016-03-23 14:45:15 4543 分享 版权
0 条回答
写回答
取消 提交回答
问答分类:
问答地址: