Я новичок в apache camel и хотел бы прочитать файл из mq и передать его методу java. Это то, что у меня есть до сих пор, но я не уверен, работает ли он так, как я ожидал:
<camel:camelContext id="updates-user"
xmlns="http://camel.apache.org/schema/spring">
<dataFormats>
<json id="updates-user-json" library="Jackson" />
</dataFormats>
<route>
<from uri="jms:WEB.FROM.FILESYS" />
<unmarshal ref="updates-user-json" />
<to uri="bean:updateService?method=importUserUpdates()" />
</route>
</camel:camelContext>
<bean id="updateService" class="project.misc.impl.UserUpdatesService"
p:camel-context-ref="updates-user" />
В коде java у меня есть экземпляр шаблона потребителя:
public void setCamelContext(CamelContext camelContext) {
consumerTemplate = new DefaultConsumerTemplate((camelContext));
}
А дальше в методе:
String jsonData = consumerTemplate.receiveBody("jms:EP.FROM.PRISM").toString();
Спасибо за помощь.