Merge pull request #29 from bluegroundltd/fix/missing-threadpoolsize-…

…param

Fix missing threadPoolSize param in TransactionalOutboxBuilder.build

README.md

@@ -27,7 +27,7 @@ Transactional Outbox is published on `mavenCentral`. In order to use it just add
 
 ```gradle
 
-implementation("io.github.bluegroundltd:transactional-outbox-core:2.0.3")
+implementation("io.github.bluegroundltd:transactional-outbox-core:2.0.4")
 
 ```
 

core/gradle.properties

@@ -1,6 +1,6 @@
 GROUP=io.github.bluegroundltd
 POM_ARTIFACT_ID=transactional-outbox-core
-VERSION_NAME=2.0.3
+VERSION_NAME=2.0.4
 
 POM_NAME=Transactional Outbox Core
 POM_DESCRIPTION=Easily implement the transactional outbox pattern in your JVM application

core/src/main/kotlin/io/github/bluegroundltd/outbox/TransactionalOutboxBuilder.kt

@@ -7,7 +7,6 @@ import io.github.bluegroundltd.outbox.item.factory.OutboxItemFactory
 import io.github.bluegroundltd.outbox.store.OutboxStore
 import java.time.Clock
 import java.time.Duration
-import kotlin.properties.Delegates
 
 /**
  * Builder for [TransactionalOutbox].
@@ -36,7 +35,7 @@ class TransactionalOutboxBuilder(
   InstantOutboxPublisherStep,
   BuildStep {
   private val handlers: MutableMap<OutboxType, OutboxHandler> = mutableMapOf()
-  private var threadPoolSize by Delegates.notNull<Int>()
+  private var threadPoolSize: Int? = null
   private var threadPoolTimeOut: Duration = DEFAULT_THREAD_POOL_TIMEOUT
   private var decorators: MutableList<OutboxItemProcessorDecorator> = mutableListOf()
   private lateinit var monitorLocksProvider: OutboxLocksProvider
@@ -157,7 +156,7 @@ class TransactionalOutboxBuilder(
    * Builds the outbox.
    */
   override fun build(): TransactionalOutbox {
-    val executorServiceFactory = FixedThreadPoolExecutorServiceFactory()
+    val executorServiceFactory = FixedThreadPoolExecutorServiceFactory(threadPoolSize)
     val outboxItemFactory = OutboxItemFactory(clock, handlers.toMap(), rerunAfterDuration)
 
     return TransactionalOutboxImpl(

core/src/main/kotlin/io/github/bluegroundltd/outbox/executor/FixedThreadPoolExecutorServiceFactory.kt

@@ -10,9 +10,10 @@ import java.util.concurrent.Executors
  * Creates a fixed thread pool executor service, using a default pool size and name format for threads.
  */
 internal class FixedThreadPoolExecutorServiceFactory(
-  private val threadPoolSize: Int = DEFAULT_THREAD_POOL_SIZE,
+  threadPoolSize: Int? = null,
   private val threadNameFormat: String = DEFAULT_THREAD_NAME_FORMAT
 ) {
+  private val threadPoolSize = threadPoolSize ?: DEFAULT_THREAD_POOL_SIZE
 
   companion object {
     private const val DEFAULT_THREAD_POOL_SIZE = 10