LTS admin 日志查询， 各种任务列表展示 和 查询 mongo实现，修复 ping bug, 推荐使用mongo做任务队列

Author: 胡贵

lts-job-tracker/src/main/java/com/lts/job/tracker/processor/JobPullProcessor.java

@@ -6,7 +6,7 @@
 import com.lts.job.remoting.exception.RemotingCommandException;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import com.lts.job.tracker.domain.JobTrackerApplication;
-import com.lts.job.tracker.support.JobDistributor;
+import com.lts.job.tracker.support.JobPusher;
 import io.netty.channel.ChannelHandlerContext;
 
 /**
@@ -15,20 +15,20 @@
  */
 public class JobPullProcessor extends AbstractProcessor {
 
-    private JobDistributor jobDistributor;
+    private JobPusher jobPusher;
 
     public JobPullProcessor(RemotingServerDelegate remotingServer, JobTrackerApplication application) {
         super(remotingServer, application);
 
-        jobDistributor = new JobDistributor(application);
+        jobPusher = new JobPusher(application);
     }
 
     @Override
     public RemotingCommand processRequest(final ChannelHandlerContext ctx, final RemotingCommand request) throws RemotingCommandException {
 
         JobPullRequest requestBody = request.getBody();
 
-        jobDistributor.distribute(remotingServer, requestBody);
+        jobPusher.push(remotingServer, requestBody);
 
         return RemotingCommand.createResponseCommand(JobProtos.ResponseCode.JOB_PULL_SUCCESS.code(), "");
     }

…/job/tracker/support/JobDistributor.java …m/lts/job/tracker/support/JobPusher.javalts-job-tracker/src/main/java/com/lts/job/tracker/support/JobDistributor.java renamed to lts-job-tracker/src/main/java/com/lts/job/tracker/support/JobPusher.java lts-job-tracker/src/main/java/com/lts/job/tracker/support/JobDistributor.java renamed to lts-job-tracker/src/main/java/com/lts/job/tracker/support/JobPusher.java

@@ -32,24 +32,24 @@
  * @author Robert HG (254963746@qq.com) on 8/18/14.
  *         任务分发管理
  */
-public class JobDistributor {
+public class JobPusher {
 
-    private final Logger LOGGER = LoggerFactory.getLogger(JobDistributor.class);
+    private final Logger LOGGER = LoggerFactory.getLogger(JobPusher.class);
     private JobTrackerApplication application;
     private final ExecutorService executor;
 
-    public JobDistributor(JobTrackerApplication application) {
+    public JobPusher(JobTrackerApplication application) {
         this.application = application;
         executor = Executors.newFixedThreadPool(Constants.AVAILABLE_PROCESSOR * 5
-                , new NamedThreadFactory(JobDistributor.class.getSimpleName()));
+                , new NamedThreadFactory(JobPusher.class.getSimpleName()));
     }
 
-    public void distribute(final RemotingServerDelegate remotingServer, final JobPullRequest request) {
+    public void push(final RemotingServerDelegate remotingServer, final JobPullRequest request) {
         executor.submit(new Runnable() {
             @Override
             public void run() {
                 try {
-                    _sendJob(remotingServer, request);
+                    pushJob(remotingServer, request);
                 } catch (Exception e) {
                     LOGGER.error(e.getMessage(), e);
                 }
@@ -64,7 +64,7 @@ public void run() {
      * @param remotingServer
      * @param request
      */
-    private void _sendJob(RemotingServerDelegate remotingServer, JobPullRequest request) {
+    private void pushJob(RemotingServerDelegate remotingServer, JobPullRequest request) {
 
         String nodeGroup = request.getNodeGroup();
         String identity = request.getIdentity();