diff --git a/Partner-Core/src/main/java/work/slhaf/partner/runtime/PartnerAgentBootstrap.java b/Partner-Core/src/main/java/work/slhaf/partner/runtime/PartnerAgentBootstrap.java index 72986f71..ce74d586 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/runtime/PartnerAgentBootstrap.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/runtime/PartnerAgentBootstrap.java @@ -12,7 +12,7 @@ public final class PartnerAgentBootstrap extends Agent.AgentBootstrap { @Override protected void bootstrap() { - addGatewayRegistration(WebSocketGatewayRegistration.INSTANCE); + addGatewayRegistration(new WebSocketGatewayRegistration()); addConfigurable(new VectorClientRegistry()); } } diff --git a/Partner-Core/src/main/java/work/slhaf/partner/runtime/gateway/WebSocketGateway.java b/Partner-Core/src/main/java/work/slhaf/partner/runtime/gateway/WebSocketGateway.java index e2a76285..096c8fe0 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/runtime/gateway/WebSocketGateway.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/runtime/gateway/WebSocketGateway.java @@ -10,7 +10,6 @@ import org.java_websocket.handshake.ClientHandshake; import org.java_websocket.server.WebSocketServer; import org.jetbrains.annotations.NotNull; import work.slhaf.partner.framework.agent.interaction.AgentGateway; -import work.slhaf.partner.framework.agent.interaction.AgentGatewayRegistration; import work.slhaf.partner.framework.agent.interaction.data.InputData; import work.slhaf.partner.framework.agent.interaction.data.InteractionEvent; import work.slhaf.partner.runtime.PartnerRunningFlowContext; @@ -49,7 +48,6 @@ public class WebSocketGateway extends WebSocketServer implements AgentGateway void launch(); - AgentGatewayRegistration registration(); - - @Override - default void register() { - registration().register(); - } - default void receive(I inputData) { C parsedContext = parseRunningFlowContext(inputData); AgentRuntime.INSTANCE.submit(parsedContext); diff --git a/Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/ResponseChannel.kt b/Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/ResponseChannel.kt index 2257467f..e4623724 100644 --- a/Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/ResponseChannel.kt +++ b/Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/ResponseChannel.kt @@ -10,9 +10,6 @@ interface ResponseChannel { fun response(event: InteractionEvent) - fun register() { - AgentRuntime.registerResponseChannel(channelName, this) - } } object LogChannel : ResponseChannel { @@ -22,10 +19,6 @@ object LogChannel : ResponseChannel { override val channelName: String get() = "log_channel" - init { - register() - } - override fun response(event: InteractionEvent) { log.info(JSONObject.toJSONString(event)) }