与Camunda集成的Spring Boot独立应用程序可以使用来自JbossFuse的JMS消息吗？

Question

我的JbossFuse中有一个activemq:queue inQueue。如何使用那些进入队列的JMS消息，以便在与Camunda集成的Spring引导应用程序中触发流程实例？任何参考资料或样本的链接都会有帮助？

目前，我可以使用来自activemq的消息，但我不确定如何使用来自Jboss Fuse ActiveMQ的消息？

@Component
public class ActiveMQConsumer {

@Autowired
CamelContext camelContext;
@Autowired
ProducerTemplate producerTemplate;

@SuppressWarnings("unchecked")
@JmsListener(destination = "inQueue")
public void consumeMessage(JSONObject employeeRecord) throws Exception {

    if (employeeRecord instanceof JSONObject) {
        HashMap<String, Object> employeeRecordMap = (HashMap<String, Object>) employeeRecord.toMap();
        Exchange exchange = ExchangeBuilder.anExchange(camelContext).withBody(employeeRecordMap).build();
        HashMap<String, Object> employeeDetails = (HashMap<String, Object>) employeeRecordMap.get("employeeDetails");
        exchange.setProperty("CamundaBpmBusinessKey", employeeDetails.get("employeeADId"));
        producerTemplate.send("camunda-bpm:start?processDefinitionKey=camunda-camel-activeMQ", exchange);
    }
    }
}

application.properties

# activeMQ config
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

预期使用来自JbossFuse的消息。

Answer 1

我推荐使用maven原型io.Fabric 8.archetypes spring-boot-camel-amq-archetype version 2.2.197。您可以找到以下内容：

Spring Boot example running a Camel route connecting to ActiveMQ
http://repo1.maven.org/maven2/

这将为您提供一个很好的样例项目，其中包含所有Camel和Spring依赖项以及一些很好的样例。