aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-13 17:40:49 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-13 17:40:49 +0200
commitdf13ce307c399c649ae2fb2730557882380998c2 (patch)
treec20ce83733d8c911c1c78965dd9f36d61106901b /messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java
parent377749b786f6a24a67b4624d8114878117a4f2ee (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-xmessagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendAdapter.java4
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);
}