使用isRunning方法判断索引实时更新服务是否运行

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

@@ -54,7 +54,7 @@ public class AQListener {
 	 */
 	public String start() {
 		String message = "";
-		if (consumer != null) {
+		if (isRunning()) {
 			message = "已存在运行的索引实时更新服务";
 			logger.warn(message);
 			return message;
@@ -78,7 +78,7 @@ public class AQListener {
 				public void onMessage(Message message) {
 					try {
 						// 等待30秒，为了等待数据表变动的事务提交
-						Thread.sleep(5000);
+						Thread.sleep(30000);
 					} catch (InterruptedException e1) {
 						e1.printStackTrace();
 					}
@@ -118,7 +118,7 @@ public class AQListener {
 	 */
 	public String stop() {
 		String message = "";
-		if (consumer == null) {
+		if (!isRunning()) {
 			message = "索引实时更新服务未开启或已关闭";
 			logger.warn(message);
 		} else {