带有rabbitmq控制异步的Camunda流

Question

大家好，我正在使用 camunda 工作流和 rabbitmq 开发微服务应用程序。我的问题是我不知道如何停止流量并继续发送兔子消息。

我有这个简单的流程：

public class RulesDelegate implements JavaDelegate {

@Override
public void execute(DelegateExecution delegateExecution) throws Exception {

}

public class NotificationDelegate implements JavaDelegate {

@Override
public void execute(DelegateExecution delegateExecution) throws Exception {

}

我需要实现当我启动流程时评估规则服务任务并通过rabbitmp向micorservices发送AMQP消息的行为。然后流程应该等待响应或一些事件通知逻辑完成，它可以继续通知服务任务和那里一样。

当我开始流时它不等待并且它完成并且我不知道如何停止它，它必须通过从服务到兔子的异步请求。 请问有什么建议吗？ 谢谢

Answer 1

您需要使用消息接收事件来等待 BPMN 中的响应 (https://docs.camunda.org/manual/7.12/reference/bpmn20/events/message-events/#message-intermediate-catching-event)

您可以在此示例中看到：https://github.com/berndruecker/camunda-spring-boot-amqp-microservice-cloud-example/ - “等待货物发货”任务确实在等待 RabbitMQ 上的响应。