diff --git a/sjrpc/core/rpcconnection.py b/sjrpc/core/rpcconnection.py index 2609acaf5685f07ee4ffd3ec1e69887de233d5ce..8640d3bdd60617b59fe60874dadbdbf870dc8b26 100644 --- a/sjrpc/core/rpcconnection.py +++ b/sjrpc/core/rpcconnection.py @@ -290,6 +290,12 @@ class RpcConnection(object): ThreadedRpcCaller(message, self, func).start() else: RpcCaller(message, self, func).start() + else: + self.error( + message['id'], + 'NameError', + "remote name '%s' is not defined" % message['method'], + ) elif set(RpcConnection.RESPONSE_MESSAGE) <= set(message): # Handle response message from the peer: call = self._calls.get(message['id'])