@@ -103,7 +103,7 @@ public class AQListener {
connection.start();
message = "索引实时更新服务成功开启";
logger.info(message);
- } catch (JMSException e) {
+ } catch (Throwable e) {
message = "索引实时更新服务开启失败";
logger.error(message, e);
if (consumer != null) {