diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-21 12:00:00 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-21 12:00:00 +0200 |
| commit | 41a73280f4cee04cfa25458c4b2afa7167225958 (patch) | |
| tree | 22bd938d67313b41e451bf5d6bba6c7296793dfa /messagebus | |
| parent | 3b2cdad302c83fcb12f653ed67980b80ebdcce80 (diff) | |
Version 6.149 is using new compressed protocol.
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 2 | ||||
| -rwxr-xr-x | messagebus/src/test/java/com/yahoo/messagebus/network/rpc/SendAdapterTestCase.java | 9 |
2 files changed, 6 insertions, 5 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java index b70b61d4f57..96a0a5fecef 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java @@ -184,7 +184,7 @@ public class RPCNetwork implements Network, MethodHandler { RPCSendAdapter adapter1 = new RPCSendV1(); RPCSendAdapter adapter2 = new RPCSendV2(); addSendAdapter(new Version(5), adapter1); - addSendAdapter(new Version(6,148), adapter2); + addSendAdapter(new Version(6,149), adapter2); } @Override diff --git a/messagebus/src/test/java/com/yahoo/messagebus/network/rpc/SendAdapterTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/network/rpc/SendAdapterTestCase.java index ee90939a61b..c8185aaeaf4 100755 --- a/messagebus/src/test/java/com/yahoo/messagebus/network/rpc/SendAdapterTestCase.java +++ b/messagebus/src/test/java/com/yahoo/messagebus/network/rpc/SendAdapterTestCase.java @@ -82,8 +82,8 @@ public class SendAdapterTestCase { public void requireCorrectVersionSelection() { assertNull(srcServer.net.getSendAdapter(new Version(4,999))); assertTrue(srcServer.net.getSendAdapter(new Version(5,0)) instanceof RPCSendV1); - assertTrue(srcServer.net.getSendAdapter(new Version(6,147)) instanceof RPCSendV1); - assertTrue(srcServer.net.getSendAdapter(new Version(6,148)) instanceof RPCSendV2); + assertTrue(srcServer.net.getSendAdapter(new Version(6,148)) instanceof RPCSendV1); + assertTrue(srcServer.net.getSendAdapter(new Version(6,149)) instanceof RPCSendV2); assertTrue(srcServer.net.getSendAdapter(new Version(9,9999)) instanceof RPCSendV2); } @@ -91,8 +91,9 @@ public class SendAdapterTestCase { public void requireThatMessagesCanBeSentAcrossAllSupportedVersions() throws Exception { List<Version> versions = Arrays.asList( new Version(5, 0), - new Version(6, 147), - new Version(6, 148) + new Version(6, 148), + new Version(6, 149), + new Version(9, 999) ); for (Version srcVersion : versions) { |