@@ -156,27 +156,29 @@ public void testEnsureVersionCompatibility() {
156156 TcpTransport .ensureVersionCompatibility (VersionUtils .randomVersionBetween (random (), Version .CURRENT .minimumCompatibilityVersion (),
157157 Version .CURRENT ), Version .CURRENT , randomBoolean ());
158158
159- TcpTransport .ensureVersionCompatibility (Version .fromString ("6.0.0" ), Version .fromString ("7.0.0" ), true );
159+ final Version version = Version .fromString ("7.0.0" );
160+ TcpTransport .ensureVersionCompatibility (Version .fromString ("6.0.0" ), version , true );
160161 IllegalStateException ise = expectThrows (IllegalStateException .class , () ->
161- TcpTransport .ensureVersionCompatibility (Version .fromString ("6.0.0" ), Version .fromString ("7.0.0" ), false ));
162- assertEquals ("Received message from unsupported version: [6.0.0] minimal compatible version is: [6.5.0]" , ise .getMessage ());
162+ TcpTransport .ensureVersionCompatibility (Version .fromString ("6.0.0" ), version , false ));
163+ assertEquals ("Received message from unsupported version: [6.0.0] minimal compatible version is: ["
164+ + version .minimumCompatibilityVersion () + "]" , ise .getMessage ());
163165
164166 // For handshake we are compatible with N-2
165- TcpTransport .ensureVersionCompatibility (Version .fromString ("5.6.0" ), Version . fromString ( "7.0.0" ) , true );
167+ TcpTransport .ensureVersionCompatibility (Version .fromString ("5.6.0" ), version , true );
166168 ise = expectThrows (IllegalStateException .class , () ->
167- TcpTransport .ensureVersionCompatibility (Version .fromString ("5.6.0" ), Version . fromString ( "7.0.0" ) , false ));
168- assertEquals ("Received message from unsupported version: [5.6.0] minimal compatible version is: [6.5.0]" ,
169- ise .getMessage ());
169+ TcpTransport .ensureVersionCompatibility (Version .fromString ("5.6.0" ), version , false ));
170+ assertEquals ("Received message from unsupported version: [5.6.0] minimal compatible version is: ["
171+ + version . minimumCompatibilityVersion () + "]" , ise .getMessage ());
170172
171173 ise = expectThrows (IllegalStateException .class , () ->
172- TcpTransport .ensureVersionCompatibility (Version .fromString ("2.3.0" ), Version . fromString ( "7.0.0" ) , true ));
173- assertEquals ("Received handshake message from unsupported version: [2.3.0] minimal compatible version is: [6.5.0]" ,
174- ise .getMessage ());
174+ TcpTransport .ensureVersionCompatibility (Version .fromString ("2.3.0" ), version , true ));
175+ assertEquals ("Received handshake message from unsupported version: [2.3.0] minimal compatible version is: ["
176+ + version . minimumCompatibilityVersion () + "]" , ise .getMessage ());
175177
176178 ise = expectThrows (IllegalStateException .class , () ->
177- TcpTransport .ensureVersionCompatibility (Version .fromString ("2.3.0" ), Version . fromString ( "7.0.0" ) , false ));
178- assertEquals ("Received message from unsupported version: [2.3.0] minimal compatible version is: [6.5.0]" ,
179- ise .getMessage ());
179+ TcpTransport .ensureVersionCompatibility (Version .fromString ("2.3.0" ), version , false ));
180+ assertEquals ("Received message from unsupported version: [2.3.0] minimal compatible version is: ["
181+ + version . minimumCompatibilityVersion () + "]" , ise .getMessage ());
180182 }
181183
182184 public void testCompressRequest () throws IOException {
0 commit comments