fix(misc): Use the connection pool specified instead of using the default
@@ -169,6 +169,7 @@ class SqlStorageService(
// using a lower `chunkSize` to avoid exceeding default packet size limits.
allItems.chunked(100).forEach { items ->
try {
+ withPool(poolName) {
jooq.transactional(sqlRetryProperties.transactions) { ctx ->
try {
ctx.batch(
@@ -217,6 +218,7 @@ class SqlStorageService(
}
}
}
+ }
} catch (e: Exception) {
log.error("Unable to store objects (objectType: {}, objectKeys: {})", objectType, items.map { it.id })
throw e
