Skip to content

Commit cb6e616

Browse files
qq254963746qq254963746
committed
调整例子
1 parent 7a01874 commit cb6e616

File tree

13 files changed

+32
-94
lines changed

13 files changed

+32
-94
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package com.lts.job.core.remoting;
22

33
import com.lts.job.core.exception.JobTrackerNotFoundException;
4-
import org.apache.commons.logging.Log;
5-
import org.apache.commons.logging.LogFactory;
4+
import org.slf4j.Logger;
5+
import org.slf4j.LoggerFactory;
66

77
import java.util.concurrent.Executors;
88
import java.util.concurrent.ScheduledExecutorService;
@@ -14,7 +14,7 @@
1414
*/
1515
public class HeartBeatMonitor {
1616

17-
private static final Log LOGGER = LogFactory.getLog("HeartBeat");
17+
private static final Logger LOGGER = LoggerFactory.getLogger("HeartBeat");
1818

1919
// 用来定时发送心跳
2020
private final ScheduledExecutorService HEART_BEAT_EXECUTOR_SERVICE = Executors.newScheduledThreadPool(1);

‎job-core/src/main/java/com/lts/job/registry/zookeeper/support/AbstractZookeeperClient.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44
import com.lts.job.registry.zookeeper.ChildListener;
55
import com.lts.job.registry.zookeeper.StateListener;
66
import com.lts.job.registry.zookeeper.ZookeeperClient;
7-
import org.apache.commons.logging.Log;
8-
import org.apache.commons.logging.LogFactory;
7+
import org.slf4j.Logger;
8+
import org.slf4j.LoggerFactory;
99

1010
import java.util.List;
1111
import java.util.Set;
@@ -18,7 +18,7 @@
1818
*/
1919
public abstract class AbstractZookeeperClient<TargetChildListener> implements ZookeeperClient {
2020

21-
private static final Log logger = LogFactory.getLog(AbstractZookeeperClient.class);
21+
private static final Logger logger = LoggerFactory.getLogger(AbstractZookeeperClient.class);
2222

2323
private final Set<StateListener> stateListeners = new CopyOnWriteArraySet<StateListener>();
2424

‎job-core/target/maven-archiver/pom.properties‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
#Generated by Maven
2-
#Wed Mar 04 11:34:19 CST 2015
2+
#Wed Mar 04 11:47:03 CST 2015
33
version=1.2-SNAPSHOT
44
groupId=com.lts
55
artifactId=job-core

‎job-example/job-client-test/pom.xml‎

Lines changed: 0 additions & 22 deletions
This file was deleted.

‎job-example/job-tracker-test/pom.xml‎

Lines changed: 0 additions & 22 deletions
This file was deleted.

‎job-example/pom.xml‎

Lines changed: 17 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,12 +8,23 @@
88
<version>1.2-SNAPSHOT</version>
99
</parent>
1010
<modelVersion>4.0.0</modelVersion>
11-
<packaging>pom</packaging>
12-
<modules>
13-
<module>job-client-test</module>
14-
<module>job-tracker-test</module>
15-
<module>task-tracker-test</module>
16-
</modules>
1711
<artifactId>job-example</artifactId>
1812

13+
<dependencies>
14+
<dependency>
15+
<groupId>com.lts</groupId>
16+
<artifactId>job-tracker</artifactId>
17+
<version>${project.version}</version>
18+
</dependency>
19+
<dependency>
20+
<groupId>com.lts</groupId>
21+
<artifactId>job-task-tracker</artifactId>
22+
<version>${project.version}</version>
23+
</dependency>
24+
<dependency>
25+
<groupId>com.lts</groupId>
26+
<artifactId>job-client</artifactId>
27+
<version>${project.version}</version>
28+
</dependency>
29+
</dependencies>
1930
</project>

job-example/job-client-test/src/main/java/JobClientTest.java renamed to job-example/src/main/java/com/lts/job/example/jobclient/JobClientTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
package com.lts.job.example.jobclient;
2+
13
import com.lts.job.client.JobClient;
24
import com.lts.job.client.RetryJobClient;
35
import com.lts.job.client.support.JobFinishedHandler;

job-example/job-tracker-test/src/main/java/JobTrackerTest.java renamed to job-example/src/main/java/com/lts/job/example/jobtracker/JobTrackerTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
package com.lts.job.example.jobtracker;
2+
13
import com.lts.job.store.Config;
24
import com.lts.job.tracker.JobTracker;
35

job-example/task-tracker-test/src/main/java/TaskTrackerTest.java renamed to job-example/src/main/java/com/lts/job/example/tasktracker/TaskTrackerTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
package com.lts.job.example.tasktracker;
2+
13
import com.lts.job.core.cluster.Node;
24
import com.lts.job.core.listener.MasterNodeChangeListener;
35
import com.lts.job.task.tracker.TaskTracker;

job-example/task-tracker-test/src/main/java/TestJobRunner.java renamed to job-example/src/main/java/com/lts/job/example/tasktracker/TestJobRunner.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
package com.lts.job.example.tasktracker;
2+
13
import com.lts.job.core.domain.Job;
24
import com.lts.job.task.tracker.runner.JobRunner;
35

0 commit comments

Comments
 (0)