实时更新服务开启失败时，增加非空判断

search-console-b2b/src/main/java/com/uas/search/console/b2b/jms/AQListener.java

@@ -105,14 +105,15 @@ public class AQListener {
 			logger.info(message);
 		} catch (JMSException e) {
 			message = "索引实时更新服务开启失败";
-			logger.error(message);
-			e.printStackTrace();
-			try {
-				consumer.close();
-			} catch (JMSException e1) {
-				e1.printStackTrace();
+			logger.error(message, e);
+			if (consumer != null) {
+				try {
+					consumer.close();
+				} catch (JMSException e1) {
+					e1.printStackTrace();
+				}
+				consumer = null;
 			}
-			consumer = null;
 		}
 		return message;
 	}

search-console/src/main/java/com/uas/search/console/jms/AQListener.java

@@ -105,14 +105,15 @@ public class AQListener {
 			logger.info(message);
 		} catch (JMSException e) {
 			message = "索引实时更新服务开启失败";
-			logger.error(message);
-			e.printStackTrace();
-			try {
-				consumer.close();
-			} catch (JMSException e1) {
-				e1.printStackTrace();
+			logger.error(message, e);
+			if (consumer != null) {
+				try {
+					consumer.close();
+				} catch (JMSException e1) {
+					e1.printStackTrace();
+				}
+				consumer = null;
 			}
-			consumer = null;
 		}
 		return message;
 	}