日志回调服务

xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerRepository.java

@@ -204,6 +204,7 @@ public class HandlerRepository {
 		new Thread(new Runnable() {
 		new Thread(new Runnable() {
 			@Override
 			@Override
 			public void run() {
 			public void run() {
+				while(true){
 					try {
 					try {
 						HashMap<String, String> item = callBackQueue.poll();
 						HashMap<String, String> item = callBackQueue.poll();
 						if (item != null) {
 						if (item != null) {
@@ -216,9 +217,11 @@ public class HandlerRepository {
 							logger.info(">>>>>>>>>>> xxl-job callback , params:{}, result:{}", new Object[]{item, callback});
 							logger.info(">>>>>>>>>>> xxl-job callback , params:{}, result:{}", new Object[]{item, callback});
 						} 
 						} 
 					} catch (Exception e) {
 					} catch (Exception e) {
+						e.printStackTrace();
 					}
 					}
 				}
 				}
-		});
+			}
+		}).start();
 	}
 	}
 	public static void pushCallBack(String address, HashMap<String, String> params){
 	public static void pushCallBack(String address, HashMap<String, String> params){
 		params.put("_address", address);
 		params.put("_address", address);