diff --git a/owl/owl-broker/src/main/kotlin/dev/usbharu/owl/broker/Main.kt b/owl/owl-broker/src/main/kotlin/dev/usbharu/owl/broker/Main.kt
index 69274668..d5f25364 100644
--- a/owl/owl-broker/src/main/kotlin/dev/usbharu/owl/broker/Main.kt
+++ b/owl/owl-broker/src/main/kotlin/dev/usbharu/owl/broker/Main.kt
@@ -32,6 +32,57 @@ import java.util.*
 
 val logger = LoggerFactory.getLogger("MAIN")
 
+val mainModule = module {
+    single<AssignQueuedTaskDecider> {
+        AssignQueuedTaskDeciderImpl(get(), get())
+    }
+    single<TaskScanner> { TaskScannerImpl(get()) }
+    single<TaskPublishService> { TaskPublishServiceImpl(get(), get(), get()) }
+    single<TaskManagementService> {
+        TaskManagementServiceImpl(
+            taskScanner = get(),
+            queueStore = get(),
+            taskDefinitionRepository = get(),
+            assignQueuedTaskDecider = get(),
+            retryPolicyFactory = get(),
+            taskRepository = get(),
+            queueScanner = get(),
+            taskResultRepository = get()
+        )
+    }
+    single<RegisterTaskService> { RegisterTaskServiceImpl(get()) }
+    single<QueueStore> { QueueStoreImpl(get()) }
+    single<QueueScanner> { QueueScannerImpl(get()) }
+    single<QueuedTaskAssigner> { QueuedTaskAssignerImpl(get(), get()) }
+    single<ProducerService> { ProducerServiceImpl(get()) }
+    single<PropertySerializerFactory> { DefaultPropertySerializerFactory() }
+    single<ConsumerService> { ConsumerServiceImpl(get()) }
+    single {
+        OwlBrokerApplication(
+            assignmentTaskService = get(),
+            definitionTaskService = get(),
+            producerService = get(),
+            subscribeTaskService = get(),
+            taskPublishService = get(),
+            taskManagementService = get(),
+            taskResultSubscribeService = get(),
+            taskResultService = get()
+        )
+    }
+    single { AssignmentTaskService(queuedTaskAssigner = get(), propertySerializerFactory = get()) }
+    single { DefinitionTaskService(registerTaskService = get()) }
+    single { dev.usbharu.owl.broker.interfaces.grpc.ProducerService(producerService = get()) }
+    single { SubscribeTaskService(consumerService = get()) }
+    single {
+        dev.usbharu.owl.broker.interfaces.grpc.TaskPublishService(
+            taskPublishService = get(),
+            propertySerializerFactory = get()
+        )
+    }
+    single { TaskResultService(taskManagementService = get(), propertySerializerFactory = get()) }
+    single { TaskResultSubscribeService(taskManagementService = get(), propertySerializerFactory = get()) }
+}
+
 fun main() {
     val moduleContexts = ServiceLoader.load(ModuleContext::class.java)
 
@@ -47,56 +98,9 @@ fun main() {
             single<RetryPolicyFactory> {
                 DefaultRetryPolicyFactory(mapOf("" to ExponentialRetryPolicy()))
             }
-            single<AssignQueuedTaskDecider> {
-                AssignQueuedTaskDeciderImpl(get(), get())
-            }
-            single<TaskScanner> { TaskScannerImpl(get()) }
-            single<TaskPublishService> { TaskPublishServiceImpl(get(), get(), get()) }
-            single<TaskManagementService> {
-                TaskManagementServiceImpl(
-                    taskScanner = get(),
-                    queueStore = get(),
-                    taskDefinitionRepository = get(),
-                    assignQueuedTaskDecider = get(),
-                    retryPolicyFactory = get(),
-                    taskRepository = get(),
-                    queueScanner = get(),
-                    taskResultRepository = get()
-                )
-            }
-            single<RegisterTaskService> { RegisterTaskServiceImpl(get()) }
-            single<QueueStore> { QueueStoreImpl(get()) }
-            single<QueueScanner> { QueueScannerImpl(get()) }
-            single<QueuedTaskAssigner> { QueuedTaskAssignerImpl(get(), get()) }
-            single<ProducerService> { ProducerServiceImpl(get()) }
-            single<PropertySerializerFactory> { DefaultPropertySerializerFactory() }
-            single<ConsumerService> { ConsumerServiceImpl(get()) }
-            single {
-                OwlBrokerApplication(
-                    assignmentTaskService = get(),
-                    definitionTaskService = get(),
-                    producerService = get(),
-                    subscribeTaskService = get(),
-                    taskPublishService = get(),
-                    taskManagementService = get(),
-                    taskResultSubscribeService = get(),
-                    taskResultService = get()
-                )
-            }
-            single { AssignmentTaskService(queuedTaskAssigner = get(), propertySerializerFactory = get()) }
-            single { DefinitionTaskService(registerTaskService = get()) }
-            single { dev.usbharu.owl.broker.interfaces.grpc.ProducerService(producerService = get()) }
-            single { SubscribeTaskService(consumerService = get()) }
-            single {
-                dev.usbharu.owl.broker.interfaces.grpc.TaskPublishService(
-                    taskPublishService = get(),
-                    propertySerializerFactory = get()
-                )
-            }
-            single { TaskResultService(taskManagementService = get(), propertySerializerFactory = get()) }
-            single { TaskResultSubscribeService(taskManagementService = get(), propertySerializerFactory = get()) }
+
         }
-        modules(module, moduleContext.module())
+        modules(mainModule, module, moduleContext.module())
     }
 
     val application = koin.koin.get<OwlBrokerApplication>()
diff --git a/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedGrpcOwlProducer.kt b/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedGrpcOwlProducer.kt
index c30cb199..cbf29443 100644
--- a/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedGrpcOwlProducer.kt
+++ b/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedGrpcOwlProducer.kt
@@ -17,6 +17,7 @@
 package dev.usbharu.owl.producer.embedded
 
 import dev.usbharu.owl.broker.OwlBrokerApplication
+import dev.usbharu.owl.broker.mainModule
 import dev.usbharu.owl.common.retry.RetryPolicyFactory
 import dev.usbharu.owl.common.task.PublishedTask
 import dev.usbharu.owl.common.task.Task
@@ -41,7 +42,7 @@ class EmbeddedGrpcOwlProducer(
                     config.retryPolicyFactory
                 }
             }
-            modules(module, config.moduleContext.module())
+            modules(mainModule, module, config.moduleContext.module())
         }.koin
 
         application.get<OwlBrokerApplication>().start(config.port.toInt())
diff --git a/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedOwlProducer.kt b/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedOwlProducer.kt
index c3323c8f..c9a30c9c 100644
--- a/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedOwlProducer.kt
+++ b/owl/owl-producer/owl-producer-embedded/src/main/kotlin/dev/usbharu/owl/producer/embedded/EmbeddedOwlProducer.kt
@@ -19,6 +19,7 @@ package dev.usbharu.owl.producer.embedded
 import dev.usbharu.owl.broker.OwlBrokerApplication
 import dev.usbharu.owl.broker.domain.exception.InvalidRepositoryException
 import dev.usbharu.owl.broker.domain.model.producer.ProducerRepository
+import dev.usbharu.owl.broker.mainModule
 import dev.usbharu.owl.broker.service.*
 import dev.usbharu.owl.common.property.PropertySerializerFactory
 import dev.usbharu.owl.common.retry.RetryPolicyFactory
@@ -59,7 +60,7 @@ class EmbeddedOwlProducer(
                     embeddedOwlProducerConfig.propertySerializerFactory
                 }
             }
-            modules(module, embeddedOwlProducerConfig.moduleContext.module())
+            modules(mainModule, module, embeddedOwlProducerConfig.moduleContext.module())
         }.koin
 
         application.getOrNull<ProducerRepository>()