Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: error (athena.apache.org: encountered temporary error during SPF
 processing of domain of ntnhan94@gmail.com)
Date: Sun, 4 Aug 2013 01:04:48 -0700 (PDT)
From: Nhan Nguyen <ntnhan94@gmail.com>
To: users@camel.apache.org
Message-ID: <1375603487590-5736733.post@n5.nabble.com>
Subject: The producer sent only one message but the comsumer received
 multiple messages with same content.
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hi all,

I am using a Topic to send and receive the message:

from("jms:topic:topic1").process(new Processor() {
					
	@Override
	public void process(Exchange exchange) throws Exception {
		System.out.println(exchange.getIn().getBody());
	}
});


The code to send the message:

endPoint = getCamelContext().getEndpoint("jms:topic:topic1",
JmsEndpoint.class);
producer = getCamelContext().createProducerTemplate();
int i = 0;
while(true){
	Exchange exchange = endpoint.createExchange();
        exchange.setPattern(ExchangePattern.InOnly);
	exchange .setBody(i++);
	m_producer.send(endPoint, exchange);
	Thread.sleep(1000);
}

I sent a message, wait for 1second, then send another with the content is
i++. And the output I saw:

0
1
1
2
2
2
3
3
3
3

Why did I receive so many same messages? I expected the result must be:
0
1
2
3


Can someone help me on this? Thanks!


--
View this message in context: http://camel.465427.n5.nabble.com/The-producer-sent-only-one-message-but-the-comsumer-received-multiple-messages-with-same-content-tp5736733.html
Sent from the Camel - Users mailing list archive at Nabble.com.