diff --git a/lib/active_remote/rpc_adapters/protobuf_adapter.rb b/lib/active_remote/rpc_adapters/protobuf_adapter.rb index d8bbd69..c47d1ee 100644 --- a/lib/active_remote/rpc_adapters/protobuf_adapter.rb +++ b/lib/active_remote/rpc_adapters/protobuf_adapter.rb @@ -38,6 +38,8 @@ def execute(rpc_method, request_args) private def protobuf_error_class(error) + return ::ActiveRemote::ActiveRemoteError unless error.respond_to?(:error_type) + case error.error_type when ::Protobuf::Socketrpc::ErrorReason::BAD_REQUEST_DATA ::ActiveRemote::BadRequestDataError @@ -60,7 +62,7 @@ def protobuf_error_class(error) when ::Protobuf::Socketrpc::ErrorReason::IO_ERROR ::ActiveRemote::IOError else - ActiveRemoteError + ::ActiveRemote::ActiveRemoteError end end