summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2024-04-04 12:26:47 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2024-04-04 12:26:47 +0200
commit4324d82a2cdf6f79279f9804e9a42dc229813673 (patch)
treeff248e44dc4fe74cad6197f54e98629e47be3b60 /messagebus
parent800b4beb92627d2faad8681ae9a1f04347731c28 (diff)
Always use use protobuf for documentapi mbus protocol.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java16
1 files changed, 1 insertions, 15 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 d55c99c1465..4a312904079 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
@@ -300,21 +300,7 @@ public class RPCNetwork implements Network, MethodHandler {
return false;
}
- private static Version deriveSupportedProtocolVersion() {
- // This is a very leaky abstraction, but since MessageBus only exchanges versions
- // (and not a set of supported protocols), we have to do this workaround.
- // Disallow-version MUST be lower than that used as a protocol lower bound in
- // DocumentProtocol.java and the exact same as that used in C++ for the same purposes.
- // ... Or else!
- // TODO remove this glorious hack once protobuf protocol is enabled by default
- var maybeEnvVal = System.getenv("VESPA_MBUS_DOCUMENTAPI_USE_PROTOBUF");
- if ("true".equals(maybeEnvVal) || "yes".equals(maybeEnvVal)) {
- return new Version(8, 310); // _Allows_ new protobuf protocol
- }
- return new Version(8, 309); // _Disallows_ new protobuf protocol
- }
-
- private static final Version REPORTED_VERSION = deriveSupportedProtocolVersion();
+ private static final Version REPORTED_VERSION = new Version(8, 310);
/**
* Returns the (protocol) version of this network. This gets called when the "mbus.getVersion" method is invoked