diff --git a/internal/server/rpc/rpc_gateway_servlet_handlers.go b/internal/server/rpc/rpc_gateway_servlet_handlers.go index dc59d12..b05fba7 100644 --- a/internal/server/rpc/rpc_gateway_servlet_handlers.go +++ b/internal/server/rpc/rpc_gateway_servlet_handlers.go @@ -68,10 +68,12 @@ func (sh *RPCGatewayServletHandlers) OnConnect(soc cwf.Socket) { func (sh *RPCGatewayServletHandlers) Handle(soc cwf.Socket, stopChan <-chan struct{}, doneChan chan<- error) { var err error - rpcServlet := retainRPCServlet(sh.gwRPCSH, sh.rpcRWCSH) + // rpcServlet := retainRPCServlet(sh.gwRPCSH, sh.rpcRWCSH) + + rpcServlet := cRPC.NewServlet(sh.gwRPCSH, sh.rpcRWCSH) defer func() { - releaseRPCServlet(rpcServlet) + // releaseRPCServlet(rpcServlet) doneChan <- err }()