Add the parameter to configure capacity of queue to await query executions

Author: okumin

README.md

@@ -34,7 +34,8 @@ akka-persistence-sql-async {
   user = "root"
   pass = ""
   url = "jdbc:mysql://localhost/akka_persistence_sql_async"
-  max-pool-size = 4
+  max-pool-size = 4 # total connection count
+  wait-queue-capacity = 10000 # If query cannot be executed soon, it wait in the queue and will be executed later.
   journal-table-name = "journal"
   snapshot-table-name = "snapshot"
 }

src/main/scala/akka/persistence/common/SQLAsyncConfig.scala

@@ -10,6 +10,7 @@ private[persistence] class SQLAsyncConfig(val system: ActorSystem) {
   val pass = config.getString("pass")
   val url = config.getString("url")
   val maxPoolSize = config.getInt("max-pool-size")
+  val waitQueueCapacity = config.getInt("wait-queue-capacity")
   val journalTableName = config.getString("journal-table-name")
   val snapshotTableName = config.getString("snapshot-table-name")
 }

src/main/scala/akka/persistence/common/ScalikeJDBCExtension.scala

@@ -22,6 +22,8 @@ private[persistence] class ScalikeJDBCExtension(system: ExtendedActorSystem) ext
     url = config.url,
     user = config.user,
     password = if (config.pass == "") null else config.pass,
-    settings = AsyncConnectionPoolSettings(maxPoolSize = config.maxPoolSize)
+    settings = AsyncConnectionPoolSettings(
+      maxPoolSize = config.maxPoolSize,
+      maxQueueSize = config.waitQueueCapacity)
   )
 }

src/test/resources/mysql-application.conf

@@ -8,6 +8,7 @@ akka-persistence-sql-async {
   pass = ""
   url = "jdbc:mysql://localhost/akka_persistence_sql_async"
   max-pool-size = 4
+  wait-queue-capacity = 10000
   journal-table-name = "journal"
   snapshot-table-name = "snapshot"
 }

src/test/resources/postgresql-application.conf

@@ -8,6 +8,7 @@ akka-persistence-sql-async {
   pass = ""
   url = "jdbc:postgresql://localhost/akka_persistence_sql_async"
   max-pool-size = 4
+  wait-queue-capacity = 10000
   journal-table-name = "journal"
   snapshot-table-name = "snapshot"
 }