I recently went through figuring out how to use MQ with camel 1.6. Below is
how I did it. Hope it helps.
MQQueueConnectionFactory cf = new MQQueueConnectionFactory();
JmsConfiguration jc = new JmsConfiguration(cf);
cf.setHostName("server");
cf.setPort( 1415);
cf.setQueueManager( "queueManager");
cf.setChannel("channel");
cf.setTransportType(1);
// org.springframework.jms.connection.JmsTransactionManager102
JmsTransactionManager102 jtm = new JmsTransactionManager102(cf,
false);
JmsComponent ibmmq = new JmsComponent(jc);
ibmmq.setAcknowledgementModeName("AUTO_ACKNOWLEDGE");
ibmmq.setUseVersion102(true);
// make it transacted
ibmmq.setTransacted(true);
ibmmq.setTransactionManager(jtm);
CamelContext camel = new DefaultCamelContext();
camel.addComponent("ibmmq", ibmmq);
camel.addRoutes( new RouteBuilder() {
public void configure() {
from("ibmmq:TEST.QUEUE").to("file://C:/cameltest");
}
});
camel.start();
--
View this message in context:
http://www.nabble.com/Camel-and-IBM-MQ-Series-tp24524277p24540278.html
Sent from the Camel - Users mailing list archive at Nabble.com.
