Hi,
I've been trying to use the MINA component for UDP data delivery but have
been having some issues and was wondering if anyone else has seen this
error.
I'm sending small packets (<100Bytes) as fast as I can (sequentially from a
single client) but after around 35,000 packets sent, the Camel client
abruptly stops without any errors/exceptions. I first tried this with the
1.6 release and saw this problem and recently downloaded and compiled the
2.0 core and components but still have the same issue. When I use MINA with
TCP, I don't have this problem...
Here's what I have for code:
-----------------
public void init( String serverIP, int serverPort ) {
uri = "mina:udp://" + serverIP + ":" + serverPort +
"?sync=false";
System.out.println("Camel URI: " + uri);
}
public void sendMessages(int numOfMessages, int messageSize) throws
Exception {
CamelContext context = new DefaultCamelContext();
context.start();
Endpoint endpoint = context.getEndpoint(uri);
Exchange exchange =
endpoint.createExchange(ExchangePattern.InOnly);
Producer producer = endpoint.createProducer();
producer.start();
for (int i = 0; i < numOfMessages; i++) {
String s = "[Publisher]: Test Body Message: " + i;
exchange.getIn().setBody(s);
producer.process(exchange);
}
producer.stop();
}
I looked through various forums and saw some memory leak issues, but wasn't
sure if this is related?
If anyone can help, would be much appreciated!!
Orton
--
View this message in context:
http://www.nabble.com/Camel-1.6-2.0-MINA-UDP-issue-tp22426433p22426433.html
Sent from the Camel - Development (activemq) mailing list archive at Nabble.com.
