@@ -156,27 +156,29 @@ public void testEnsureVersionCompatibility() {
156
156
TcpTransport .ensureVersionCompatibility (VersionUtils .randomVersionBetween (random (), Version .CURRENT .minimumCompatibilityVersion (),
157
157
Version .CURRENT ), Version .CURRENT , randomBoolean ());
158
158
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 );
160
161
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 ());
163
165
164
166
// 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 );
166
168
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 ());
170
172
171
173
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 ());
175
177
176
178
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 ());
180
182
}
181
183
182
184
public void testCompressRequest () throws IOException {
0 commit comments