Skip to content

Commit 7a01874

Browse files
qq254963746qq254963746
committed
整理项目结构
1 parent 7920fce commit 7a01874

File tree

181 files changed

+495
-670
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

181 files changed

+495
-670
lines changed

‎job-client/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
<dependencies>
1515
<dependency>
1616
<groupId>com.lts</groupId>
17-
<artifactId>job-common</artifactId>
17+
<artifactId>job-core</artifactId>
1818
<version>${project.version}</version>
1919
</dependency>
2020
</dependencies>

‎job-client/src/main/java/com/lts/job/client/JobClient.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2,17 +2,17 @@
22

33
import com.lts.job.client.processor.RemotingDispatcher;
44
import com.lts.job.client.support.JobFinishedHandler;
5-
import com.lts.job.common.cluster.AbstractClientNode;
6-
import com.lts.job.common.constant.Constants;
7-
import com.lts.job.common.domain.Job;
5+
import com.lts.job.core.cluster.AbstractClientNode;
6+
import com.lts.job.core.constant.Constants;
7+
import com.lts.job.core.domain.Job;
88
import com.lts.job.client.domain.JobClientNode;
99
import com.lts.job.client.domain.Response;
1010
import com.lts.job.client.domain.ResponseCode;
11-
import com.lts.job.common.exception.JobTrackerNotFoundException;
12-
import com.lts.job.common.protocol.JobProtos;
13-
import com.lts.job.common.protocol.command.JobSubmitRequest;
14-
import com.lts.job.common.protocol.command.JobSubmitResponse;
15-
import com.lts.job.common.util.BatchUtils;
11+
import com.lts.job.core.exception.JobTrackerNotFoundException;
12+
import com.lts.job.core.protocol.JobProtos;
13+
import com.lts.job.core.protocol.command.JobSubmitRequest;
14+
import com.lts.job.core.protocol.command.JobSubmitResponse;
15+
import com.lts.job.core.util.BatchUtils;
1616
import com.lts.job.remoting.InvokeCallback;
1717
import com.lts.job.remoting.exception.RemotingCommandFieldCheckException;
1818
import com.lts.job.remoting.netty.NettyRequestProcessor;

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,13 @@
22

33
import com.lts.job.client.domain.JobClientNode;
44
import com.lts.job.client.domain.ResponseCode;
5-
import com.lts.job.common.domain.Job;
5+
import com.lts.job.core.domain.Job;
66
import com.lts.job.client.domain.Response;
7-
import com.lts.job.common.file.FileAccessor;
8-
import com.lts.job.common.file.FileException;
9-
import com.lts.job.common.file.Line;
10-
import com.lts.job.common.support.RetryScheduler;
11-
import com.lts.job.common.util.JsonUtils;
7+
import com.lts.job.core.file.FileAccessor;
8+
import com.lts.job.core.file.FileException;
9+
import com.lts.job.core.file.Line;
10+
import com.lts.job.core.support.RetryScheduler;
11+
import com.lts.job.core.util.JsonUtils;
1212

1313
import java.util.ArrayList;
1414
import java.util.Arrays;

‎job-client/src/main/java/com/lts/job/client/domain/JobClientNode.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.lts.job.client.domain;
22

3-
import com.lts.job.common.cluster.Node;
4-
import com.lts.job.common.cluster.NodeType;
3+
import com.lts.job.core.cluster.Node;
4+
import com.lts.job.core.cluster.NodeType;
55

66
/**
77
* @author Robert HG (254963746@qq.com) on 7/25/14.

‎job-client/src/main/java/com/lts/job/client/domain/Response.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.lts.job.client.domain;
22

33

4-
import com.lts.job.common.domain.Job;
4+
import com.lts.job.core.domain.Job;
55

66
import java.io.Serializable;
77
import java.util.ArrayList;

‎job-client/src/main/java/com/lts/job/client/processor/AbstractProcessor.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.lts.job.client.processor;
22

3-
import com.lts.job.common.remoting.RemotingClientDelegate;
3+
import com.lts.job.core.remoting.RemotingClientDelegate;
44
import com.lts.job.remoting.netty.NettyRequestProcessor;
55

66
/**

‎job-client/src/main/java/com/lts/job/client/processor/JobFinishedProcessor.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
package com.lts.job.client.processor;
22

33
import com.lts.job.client.support.JobFinishedHandler;
4-
import com.lts.job.common.domain.JobResult;
5-
import com.lts.job.common.protocol.JobProtos;
6-
import com.lts.job.common.protocol.command.JobFinishedRequest;
7-
import com.lts.job.common.remoting.RemotingClientDelegate;
8-
import com.lts.job.common.util.CollectionUtils;
4+
import com.lts.job.core.domain.JobResult;
5+
import com.lts.job.core.protocol.JobProtos;
6+
import com.lts.job.core.protocol.command.JobFinishedRequest;
7+
import com.lts.job.core.remoting.RemotingClientDelegate;
8+
import com.lts.job.core.util.CollectionUtils;
99
import com.lts.job.remoting.exception.RemotingCommandException;
1010
import com.lts.job.remoting.protocol.RemotingCommand;
1111
import io.netty.channel.ChannelHandlerContext;

‎job-client/src/main/java/com/lts/job/client/processor/RemotingDispatcher.java‎

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

33
import com.lts.job.client.support.JobFinishedHandler;
4-
import com.lts.job.common.protocol.JobProtos;
5-
import com.lts.job.common.remoting.RemotingClientDelegate;
4+
import com.lts.job.core.protocol.JobProtos;
5+
import com.lts.job.core.remoting.RemotingClientDelegate;
66
import com.lts.job.remoting.exception.RemotingCommandException;
77
import com.lts.job.remoting.netty.NettyRequestProcessor;
88
import com.lts.job.remoting.protocol.RemotingCommand;
@@ -12,8 +12,8 @@
1212
import java.util.HashMap;
1313
import java.util.Map;
1414

15-
import static com.lts.job.common.protocol.JobProtos.RequestCode.JOB_FINISHED;
16-
import static com.lts.job.common.protocol.JobProtos.RequestCode.valueOf;
15+
import static com.lts.job.core.protocol.JobProtos.RequestCode.JOB_FINISHED;
16+
import static com.lts.job.core.protocol.JobProtos.RequestCode.valueOf;
1717

1818
/**
1919
* @author Robert HG (254963746@qq.com) on 7/25/14.

‎job-client/src/main/java/com/lts/job/client/support/JobFinishedHandler.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.lts.job.client.support;
22

3-
import com.lts.job.common.domain.JobResult;
3+
import com.lts.job.core.domain.JobResult;
44

55
import java.util.List;
66

‎job-common/pom.xml‎

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

0 commit comments

Comments
 (0)