mirror of
https://github.com/slhaf/Partner.git
synced 2026-05-12 16:53:04 +08:00
refactor(gateway): remove duplicate response channel register
This commit is contained in:
@@ -11,7 +11,6 @@ import org.java_websocket.server.WebSocketServer;
|
|||||||
import org.jetbrains.annotations.NotNull;
|
import org.jetbrains.annotations.NotNull;
|
||||||
import work.slhaf.partner.framework.agent.interaction.AgentGateway;
|
import work.slhaf.partner.framework.agent.interaction.AgentGateway;
|
||||||
import work.slhaf.partner.framework.agent.interaction.AgentGatewayRegistration;
|
import work.slhaf.partner.framework.agent.interaction.AgentGatewayRegistration;
|
||||||
import work.slhaf.partner.framework.agent.interaction.AgentRuntime;
|
|
||||||
import work.slhaf.partner.framework.agent.interaction.data.InputData;
|
import work.slhaf.partner.framework.agent.interaction.data.InputData;
|
||||||
import work.slhaf.partner.framework.agent.interaction.data.InteractionEvent;
|
import work.slhaf.partner.framework.agent.interaction.data.InteractionEvent;
|
||||||
import work.slhaf.partner.runtime.PartnerRunningFlowContext;
|
import work.slhaf.partner.runtime.PartnerRunningFlowContext;
|
||||||
@@ -50,7 +49,6 @@ public class WebSocketGateway extends WebSocketServer implements AgentGateway<In
|
|||||||
}
|
}
|
||||||
this.start();
|
this.start();
|
||||||
startHeartbeatThread();
|
startHeartbeatThread();
|
||||||
AgentRuntime.INSTANCE.registerResponseChannel(getChannelName(), this);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
Reference in New Issue
Block a user