diff --git a/rpc-server.go b/rpc-server.go index 6eeadb4..ef9d419 100644 --- a/rpc-server.go +++ b/rpc-server.go @@ -48,7 +48,9 @@ func (h *GrainHandler) RemoteHandleMessageHandler(data *FrameWithPayload, result } replyData, err := h.pool.Process(cartData.Id, msg) - + if err != nil { + return err + } resultChan <- *replyData return err }