Hello:
My Broker receive a message and generate a list of Objects:
from("seda:analisarColeta?concurrentConsumers=" +
execucoesSimultaneas).process(new Processor() {
public void process(Exchange exchange) throws Exception {
AnalisarColetaReq req = (AnalisarColetaReq)
exchange.getIn().getBody();
Executer exec = new Executer();
exchange.getOut().setBody(exec.analisarColeta(req));
}
});
The problem is my client:
Endpoint endpoint =
com.vpidata.ibope.broker.stuffs.CamelStart.camelContext.getEndpoint("activemq:analisarColeta"
+ campanha.servidor.id + ":analisarColeta");
Exchange exchange = endpoint.createExchange(ExchangePattern.InOut);
exchange.getIn().setBody(req);
Producer producer = endpoint.createProducer();
producer.start();
// In this part my app stuck, Broker receive the message, process but I
can't get de out.
producer.process(exchange);
producer.stop();
List<ResourceProperties> response = new
ArrayList<ResourceProperties>();
response = (List<ResourceProperties>) exchange.getOut().getBody();
I think this happens because it`s a heavy array list sended
--
View this message in context:
http://camel.465427.n5.nabble.com/Sending-a-ArrayList-Object-takes-so-long-tp5157568p5157612.html
Sent from the Camel - Users mailing list archive at Nabble.com.
