I am using camel 2.8.1 version and i am using ActiveMQ. Here is the peice of
code i am using
DefaultCamelContext camelContext=new DefaultCamelContext();
ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://IP:port");
camelContext.addComponent("test-jms",
JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
from("file url")
.unmarshal().csv()
//Split the message into a number of pieces
.split(body(List.class))
.convertBodyTo(A.class)
.to( "test-jms:queue:queueA?maxMessagesPerTask=-1" );
--
View this message in context:
http://camel.465427.n5.nabble.com/Rate-of-messages-sent-to-JMS-tp4935053p4935854.html
Sent from the Camel - Users mailing list archive at Nabble.com.
