diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-01 11:10:06 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-01 11:10:06 +0200 |
commit | 01d0993aa195fbdc2a01591ffb059d8e6917ba68 (patch) | |
tree | 1862de701387cb2b3863c41d68c0e76fda7a6bda /src/main/java/com/orbekk/protobuf/RpcChannel.java | |
parent | e77a91ea3842e46e93e03ce89fb6b4b0d90c2999 (diff) |
Add support for RPC logging.
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/RpcChannel.java')
-rw-r--r-- | src/main/java/com/orbekk/protobuf/RpcChannel.java | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/main/java/com/orbekk/protobuf/RpcChannel.java b/src/main/java/com/orbekk/protobuf/RpcChannel.java index 594cff8..c30254b 100644 --- a/src/main/java/com/orbekk/protobuf/RpcChannel.java +++ b/src/main/java/com/orbekk/protobuf/RpcChannel.java @@ -238,6 +238,11 @@ public class RpcChannel implements com.google.protobuf.RpcChannel { addTimeoutHandler(request_); ongoingRequests.put(id, request_); + if (logger.isLoggable(Level.FINER)) { + logger.finer(String.format("O(%d) => %s(%s)", + id, method.getFullName(), requestMessage)); + } + Data.Request requestData = Data.Request.newBuilder() .setRequestId(id) .setFullServiceName(method.getService().getFullName()) @@ -275,6 +280,11 @@ public class RpcChannel implements com.google.protobuf.RpcChannel { try { Message responsePb = request.responsePrototype.toBuilder() .mergeFrom(response.getResponseProto()).build(); + if (logger.isLoggable(Level.FINER)) { + logger.finer(String.format("O(%d) <= %s", + response.getRequestId(), + responsePb)); + } request.rpc.readFrom(response); request.done.run(responsePb); request.rpc.complete(); |