|
34 | 34 | import org.neo4j.driver.internal.DatabaseName;
|
35 | 35 | import org.neo4j.driver.internal.InternalBookmark;
|
36 | 36 | import org.neo4j.driver.internal.InternalRecord;
|
| 37 | +import org.neo4j.driver.internal.messaging.v3.BoltProtocolV3; |
| 38 | +import org.neo4j.driver.internal.messaging.v4.BoltProtocolV4; |
37 | 39 | import org.neo4j.driver.internal.spi.Connection;
|
38 | 40 | import org.neo4j.driver.internal.util.Clock;
|
39 | 41 | import org.neo4j.driver.internal.util.ServerVersion;
|
@@ -304,18 +306,21 @@ private static RoutingProcedureResponse newRoutingResponse( Throwable error )
|
304 | 306 | private static RoutingProcedureClusterCompositionProvider newClusterCompositionProvider( RoutingProcedureRunner runner, Connection connection )
|
305 | 307 | {
|
306 | 308 | when( connection.serverVersion() ).thenReturn( ServerVersion.v3_5_0 );
|
| 309 | + when( connection.protocol() ).thenReturn( BoltProtocolV3.INSTANCE ); |
307 | 310 | return new RoutingProcedureClusterCompositionProvider( mock( Clock.class ), runner, newMultiDBProcedureRunnerMock() );
|
308 | 311 | }
|
309 | 312 |
|
310 | 313 | private static RoutingProcedureClusterCompositionProvider newClusterCompositionProvider( MultiDatabasesRoutingProcedureRunner runner, Connection connection )
|
311 | 314 | {
|
312 | 315 | when( connection.serverVersion() ).thenReturn( ServerVersion.v4_0_0 );
|
| 316 | + when( connection.protocol() ).thenReturn( BoltProtocolV4.INSTANCE ); |
313 | 317 | return new RoutingProcedureClusterCompositionProvider( mock( Clock.class ), newProcedureRunnerMock(), runner );
|
314 | 318 | }
|
315 | 319 |
|
316 | 320 | private static RoutingProcedureClusterCompositionProvider newClusterCompositionProvider( MultiDatabasesRoutingProcedureRunner runner, Connection connection, Clock clock )
|
317 | 321 | {
|
318 | 322 | when( connection.serverVersion() ).thenReturn( ServerVersion.v4_0_0 );
|
| 323 | + when( connection.protocol() ).thenReturn( BoltProtocolV4.INSTANCE ); |
319 | 324 | return new RoutingProcedureClusterCompositionProvider( clock, newProcedureRunnerMock(), runner );
|
320 | 325 | }
|
321 | 326 | }
|
0 commit comments