Merge pull request #23 from qq254963746/develop

Optimize imports

Author: qq254963746

job-client/src/main/java/com/lts/job/client/RetryJobClient.java

@@ -8,7 +8,6 @@
 import com.lts.job.core.domain.Job;
 import com.lts.job.core.support.RetryScheduler;
 import com.lts.job.core.util.JSONUtils;
-import sun.security.util.Resources_es;
 
 import java.util.Arrays;
 import java.util.List;

job-core/src/main/java/com/lts/job/core/remoting/HeartBeatMonitor.java

@@ -8,13 +8,9 @@
 import com.lts.job.core.protocol.JobProtos;
 import com.lts.job.core.protocol.command.HeartBeatRequest;
 import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.Holder;
-import com.lts.job.remoting.InvokeCallback;
-import com.lts.job.remoting.netty.ResponseFuture;
 import com.lts.job.remoting.protocol.RemotingCommand;
 
 import java.util.List;
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;

job-core/src/main/java/com/lts/job/store/mongo/MongoFactoryBean.java

@@ -3,7 +3,10 @@
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.util.StringUtils;
-import com.mongodb.*;
+import com.mongodb.MongoClient;
+import com.mongodb.MongoClientOptions;
+import com.mongodb.MongoCredential;
+import com.mongodb.ServerAddress;
 
 import java.util.ArrayList;
 import java.util.List;

job-core/src/test/java/com/lts/job/core/failstore/rocksdb/RocksdbFailStoreTest.java

@@ -7,16 +7,13 @@
 import com.lts.job.core.domain.KVPair;
 import com.lts.job.core.failstore.FailStore;
 import com.lts.job.core.failstore.FailStoreException;
-import com.lts.job.core.failstore.berkeleydb.BerkeleydbFailStore;
 import com.lts.job.core.util.CollectionUtils;
 import com.lts.job.core.util.JSONUtils;
 import org.junit.Before;
 import org.junit.Test;
 
 import java.util.List;
 
-import static org.junit.Assert.*;
-
 /**
  * Robert HG ([email protected]) on 5/27/15.
  */

job-core/src/test/java/com/lts/job/core/file/FileLockTest.java

@@ -2,8 +2,6 @@
 
 import java.io.IOException;
 
-import static org.junit.Assert.*;
-
 /**
  * Robert HG ([email protected]) on 5/27/15.
  */

job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoCronJobQueue.java

@@ -8,7 +8,10 @@
 import com.lts.job.queue.domain.JobPo;
 import com.lts.job.queue.exception.DuplicateJobException;
 import com.lts.job.store.mongo.MongoRepository;
-import com.mongodb.*;
+import com.mongodb.DBCollection;
+import com.mongodb.DBObject;
+import com.mongodb.DuplicateKeyException;
+import com.mongodb.WriteResult;
 import org.mongodb.morphia.query.Query;
 
 import java.util.List;

job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoExecutingJobQueue.java

@@ -8,7 +8,10 @@
 import com.lts.job.queue.domain.JobPo;
 import com.lts.job.queue.exception.DuplicateJobException;
 import com.lts.job.store.mongo.MongoRepository;
-import com.mongodb.*;
+import com.mongodb.DBCollection;
+import com.mongodb.DBObject;
+import com.mongodb.DuplicateKeyException;
+import com.mongodb.WriteResult;
 import org.mongodb.morphia.query.Query;
 
 import java.util.List;

job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoJobFeedbackQueue.java

@@ -9,7 +9,10 @@
 import com.lts.job.queue.JobFeedbackQueue;
 import com.lts.job.queue.domain.JobFeedbackPo;
 import com.lts.job.store.mongo.MongoRepository;
-import com.mongodb.*;
+import com.mongodb.DBCollection;
+import com.mongodb.DBObject;
+import com.mongodb.DuplicateKeyException;
+import com.mongodb.WriteResult;
 import org.mongodb.morphia.query.Query;
 
 import java.util.List;

job-task-tracker/src/main/java/com/lts/job/task/tracker/logger/BizLoggerImpl.java

@@ -6,7 +6,6 @@
 import com.lts.job.core.protocol.command.BizLogSendRequest;
 import com.lts.job.core.remoting.RemotingClientDelegate;
 import com.lts.job.remoting.InvokeCallback;
-import com.lts.job.remoting.exception.RemotingCommandFieldCheckException;
 import com.lts.job.remoting.netty.ResponseFuture;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import com.lts.job.task.tracker.domain.TaskTrackerApplication;

job-task-tracker/src/main/java/com/lts/job/task/tracker/support/JobPullMachine.java

@@ -5,9 +5,7 @@
 import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.protocol.JobProtos;
 import com.lts.job.core.protocol.command.JobPullRequest;
-import com.lts.job.remoting.InvokeCallback;
 import com.lts.job.remoting.exception.RemotingCommandFieldCheckException;
-import com.lts.job.remoting.netty.ResponseFuture;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import com.lts.job.task.tracker.domain.TaskTrackerApplication;