ActiveMQ 连接池 的connection出现异常怎么重新连接？

Question

写一个接口模块。提供通用接口，可以连接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();

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

Answer 1

如果是connectin异常，在创建连接时如果指定了failover机制，mq的客户端会自动重连

Answer 2

activeMQ连接断开后会自动重连

Answer 3

就是connection出现异常，之后的重连要怎么写？

Answer 4

@爱学习的小雷 不会初始化？

Answer 5

是MQ异常，还是程序异常？程序异常只能重新再连，出现异常再调用一次连接信息