|
@ -23,7 +23,7 @@ public class EndpointEventRouter extends RouteBuilder {
|
|
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
|
|
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
|
|
activemqConfiguration.getUser(), activemqConfiguration.getPassword(),activemqConfiguration.getBrokerURL());
|
|
activemqConfiguration.getUser(), activemqConfiguration.getPassword(),activemqConfiguration.getBrokerURL());
|
|
// Note we can explicit name the component
|
|
// Note we can explicit name the component
|
|
context.addComponent("service-event", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
|
|
|
|
|
|
context.addComponent("endpoint-event", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
|
|
from("service-event:queue:configuration.endpoint")
|
|
from("service-event:queue:configuration.endpoint")
|
|
.to("bean:endpointService?method=trigger"); //TODO:这边可以做Message Filter,减化trigger逻辑
|
|
.to("bean:endpointService?method=trigger"); //TODO:这边可以做Message Filter,减化trigger逻辑
|
|
}
|
|
}
|