diff --git a/powerjob-remote/powerjob-remote-framework/src/main/java/tech/powerjob/remote/framework/cs/CSInitializer.java b/powerjob-remote/powerjob-remote-framework/src/main/java/tech/powerjob/remote/framework/cs/CSInitializer.java index 16ebd6f7..723379a6 100644 --- a/powerjob-remote/powerjob-remote-framework/src/main/java/tech/powerjob/remote/framework/cs/CSInitializer.java +++ b/powerjob-remote/powerjob-remote-framework/src/main/java/tech/powerjob/remote/framework/cs/CSInitializer.java @@ -1,7 +1,6 @@ package tech.powerjob.remote.framework.cs; import tech.powerjob.remote.framework.actor.ActorInfo; -import tech.powerjob.remote.framework.actor.HandlerInfo; import tech.powerjob.remote.framework.transporter.Transporter; import java.io.Closeable; diff --git a/powerjob-remote/powerjob-remote-impl-http/pom.xml b/powerjob-remote/powerjob-remote-impl-http/pom.xml index 621bbf4d..489b01a9 100644 --- a/powerjob-remote/powerjob-remote-impl-http/pom.xml +++ b/powerjob-remote/powerjob-remote-impl-http/pom.xml @@ -15,6 +15,18 @@ 8 8 UTF-8 + + 4.2.0 + + + + tech.powerjob + powerjob-remote-framework + ${powerjob-remote-framework.version} + + + + \ No newline at end of file diff --git a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpCSInitializer.java b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpCSInitializer.java new file mode 100644 index 00000000..3d28f9aa --- /dev/null +++ b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpCSInitializer.java @@ -0,0 +1,43 @@ +package tech.powerjob.remote.http; + +import tech.powerjob.remote.framework.actor.ActorInfo; +import tech.powerjob.remote.framework.cs.CSInitializer; +import tech.powerjob.remote.framework.cs.CSInitializerConfig; +import tech.powerjob.remote.framework.transporter.Transporter; + +import java.io.IOException; +import java.util.List; + +/** + * HttpCSInitializer + * + * @author tjq + * @since 2022/12/31 + */ +public class HttpCSInitializer implements CSInitializer { + + @Override + public String type() { + return null; + } + + @Override + public void init(CSInitializerConfig config) { + + } + + @Override + public Transporter buildTransporter() { + return null; + } + + @Override + public void bindHandlers(List actorInfos) { + + } + + @Override + public void close() throws IOException { + + } +} diff --git a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpProtocol.java b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpProtocol.java new file mode 100644 index 00000000..0b15a8a8 --- /dev/null +++ b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpProtocol.java @@ -0,0 +1,17 @@ +package tech.powerjob.remote.http; + +import tech.powerjob.remote.framework.transporter.Protocol; + +/** + * HttpProtocol + * + * @author tjq + * @since 2022/12/31 + */ +public class HttpProtocol implements Protocol { + + @Override + public String name() { + return null; + } +}