diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-13 17:40:49 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-13 17:40:49 +0200 |
commit | df13ce307c399c649ae2fb2730557882380998c2 (patch) | |
tree | c20ce83733d8c911c1c78965dd9f36d61106901b /messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java | |
parent | 377749b786f6a24a67b4624d8114878117a4f2ee (diff) |
Use atomic and synchronized sections to do proper accounting of replies. And some geenral code health.
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java')
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java index dbdb6da6477..749ba4f4451 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java @@ -17,7 +17,7 @@ public interface RPCSendAdapter { * * @param net The network to attach to. */ - public void attach(RPCNetwork net); + void attach(RPCNetwork net); /** * Performs the actual sending to the given recipient. @@ -27,5 +27,5 @@ public interface RPCSendAdapter { * @param payload The already serialized payload of the message to send. * @param timeRemaining The time remaining until the message expires. */ - public void send(RoutingNode recipient, Version version, byte[] payload, long timeRemaining); + void send(RoutingNode recipient, Version version, byte[] payload, long timeRemaining); } |