Initiate saga from a Non-Aggregate (eventGateway)

Axon Framework
, , ,
1

I am very new to axon. I have the following query. I am running 2 micro-services viz Payment and Order using Cassandra as an Event Store and Kafka . From the
payment micro-service. I am dispatching an event from eventGateway

    @Component
    @ProcessingGroup("OrderProcessor")
    public class OrderEventHandler {
        @Inject
        private EventGateway eventGateway;
        public void createOrder() {
            OrderCreatedEvent orderCreatedEvent = new OrderCreatedEvent("orderId",
                100,
                "CREATED");
            eventGateway.publish(orderCreatedEvent);
        }

Also, I have configured the sagaStore and repository components
SagaViewRepository

@Repository
 public interface SagaViewRepository extends CassandraRepository<SagaView, String> {
}

SagaStore

public CassandraSagaStore sagaStoreStore() {
    return  CassandraSagaStore(...);
}

How do I listen the above event in SagaEvent Listener present in Order microservice. Below is the implementation

    @Saga
    public class OrderManagementSaga {

        @Inject
        private transient CommandGateway commandGateway;

        @StartSaga
        @SagaEventHandler(associationProperty = "orderId")
        public void handle(OrderCreatedEvent orderCreatedEvent){
            //Saga invoked;
        }

Any hints in the are much appreciated :slight_smile:
Thank You.

Dhaval

2

This is answered here

3

Thanks for linking to the StackOverflow answer I’ve provided @Dhaval_naik. That will give other attendees of the forum sufficient info to figure out the solution. :slight_smile: