Skip to content

Commit 128eea4

Browse files
authored
chore: ConnectionPoolSettings from ConnectionFactoryProvider (#442)
* for the new closeCallsExceeding paramater in R2dbcExecutor, needed from R2dbcProjection
1 parent 98df32f commit 128eea4

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

core/src/main/scala/akka/persistence/r2dbc/ConnectionFactoryProvider.scala

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import scala.concurrent.Future
2222
import scala.concurrent.duration.Duration
2323

2424
import akka.annotation.InternalApi
25+
import akka.annotation.InternalStableApi
2526

2627
object ConnectionFactoryProvider extends ExtensionId[ConnectionFactoryProvider] {
2728
def createExtension(system: ActorSystem[_]): ConnectionFactoryProvider = new ConnectionFactoryProvider(system)
@@ -71,6 +72,13 @@ class ConnectionFactoryProvider(system: ActorSystem[_]) extends Extension {
7172
}
7273
}
7374

75+
/**
76+
* INTERNAL API
77+
*/
78+
@InternalStableApi
79+
def connectionPoolSettingsFor(configLocation: String): ConnectionPoolSettings =
80+
connectionFactorySettingsFor(configLocation).poolSettings
81+
7482
private def createConnectionPoolFactory(
7583
settings: ConnectionPoolSettings,
7684
connectionFactory: ConnectionFactory): ConnectionPool = {

0 commit comments

Comments
 (0)