@@ -366,6 +366,15 @@ private BoltConnectionSourceFactory createPooledBoltConnectionSource(
366
366
boltConnectionProviderFactory );
367
367
var listeningBoltConnectionProvider = BoltConnectionListener .listeningBoltConnectionProvider (
368
368
boltConnectionProvider , boltConnectionListener );
369
+ var connectTimeoutMillisAdjusted = connectTimeoutMillis ;
370
+ var connectionAcquisitionTimeoutMillis = config .connectionAcquisitionTimeoutMillis ();
371
+ if (connectTimeoutMillisAdjusted == 0 && connectionAcquisitionTimeoutMillis > 0 ) {
372
+ connectTimeoutMillisAdjusted = (int ) connectionAcquisitionTimeoutMillis ;
373
+ if (connectTimeoutMillisAdjusted != connectionAcquisitionTimeoutMillis ) {
374
+ throw new IllegalStateException (
375
+ "Failed to determine connection timeout from acquisition timeout due to overflow, set connection timeout to non zero value" );
376
+ }
377
+ }
369
378
return new PooledBoltConnectionSource (
370
379
loggingProvider ,
371
380
clock ,
@@ -374,14 +383,14 @@ private BoltConnectionSourceFactory createPooledBoltConnectionSource(
374
383
authTokenManager ,
375
384
createSecurityPlanSupplierWithHostname (securityPlanSupplier , expectedVerificationHostname ),
376
385
config .maxConnectionPoolSize (),
377
- config . connectionAcquisitionTimeoutMillis () ,
386
+ connectionAcquisitionTimeoutMillis ,
378
387
config .maxConnectionLifetimeMillis (),
379
388
config .idleTimeBeforeConnectionTest (),
380
389
observationProvider ,
381
390
routingContextAddress ,
382
391
boltAgent ,
383
392
userAgent ,
384
- connectTimeoutMillis ,
393
+ connectTimeoutMillisAdjusted ,
385
394
notificationConfig ,
386
395
PooledBoltConnectionSource .TimeoutPolicy .DEFAULT );
387
396
};
0 commit comments