diff --git a/orders-and-customers-spring-reactive/src/main/java/io/eventuate/examples/tram/sagas/ordersandcustomers/spring/reactive/customers/CustomerConfiguration.java b/orders-and-customers-spring-reactive/src/main/java/io/eventuate/examples/tram/sagas/ordersandcustomers/spring/reactive/customers/CustomerConfiguration.java
index bb787ce..8be3faa 100644
--- a/orders-and-customers-spring-reactive/src/main/java/io/eventuate/examples/tram/sagas/ordersandcustomers/spring/reactive/customers/CustomerConfiguration.java
+++ b/orders-and-customers-spring-reactive/src/main/java/io/eventuate/examples/tram/sagas/ordersandcustomers/spring/reactive/customers/CustomerConfiguration.java
@@ -30,7 +30,7 @@ public CustomerCommandHandler customerCommandHandler(CustomerService customerSer
     return new CustomerCommandHandler(customerService);
   }
 
-  @Bean
+  @Bean(initMethod = "initialize")
   public ReactiveCommandDispatcher consumerCommandDispatcher(CustomerCommandHandler target,
                                                              ReactiveSagaCommandDispatcherFactory sagaCommandDispatcherFactory) {