How to implement saga pattern with Kafka and Camunda BPM

aravindhrs · January 13, 2021, 1:15pm

@Adel16 retrievePaymentAdapter is a Java delegate.

berndruecker/flowing-retail/blob/6bb334477a1ef6896dd9c31d35e624f2ff1c31d2/kafka/java/order-camunda/src/main/java/io/flowing/retail/order/flow/RetrievePaymentAdapter.java#L14


      
          import org.camunda.bpm.engine.delegate.JavaDelegate;
          import org.springframework.beans.factory.annotation.Autowired;
          import org.springframework.stereotype.Component;
          
          import io.flowing.retail.order.domain.Order;
          import io.flowing.retail.order.messages.Message;
          import io.flowing.retail.order.messages.MessageSender;
          import io.flowing.retail.order.persistence.OrderRepository;
          
          @Component
          public class RetrievePaymentAdapter implements JavaDelegate {
            
            @Autowired
            private MessageSender messageSender;  
          
            @Autowired
            private OrderRepository orderRepository;  
          
            @Override
            public void execute(DelegateExecution context) throws Exception {
              Order order = orderRepository.findById( //

Try configuring like below in the implementation type as Delegate Expression

${retrievePaymentAdapter}