Repository: karaf Updated Branches: refs/heads/karaf-2.x 83e2c42a2 -> c1bcfc02f
[KARAF-2880] Introduce timeout when consuuming JMS messages Project: http://git-wip-us.apache.org/repos/asf/karaf/repo Commit: http://git-wip-us.apache.org/repos/asf/karaf/commit/c1bcfc02 Tree: http://git-wip-us.apache.org/repos/asf/karaf/tree/c1bcfc02 Diff: http://git-wip-us.apache.org/repos/asf/karaf/diff/c1bcfc02 Branch: refs/heads/karaf-2.x Commit: c1bcfc02fa406d724ba5479c3cbe20825415489d Parents: 83e2c42 Author: Jean-Baptiste Onofré <[email protected]> Authored: Mon Apr 7 08:00:28 2014 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Mon Apr 7 08:00:28 2014 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/karaf/blob/c1bcfc02/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java ---------------------------------------------------------------------- diff --git a/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java b/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java index 4d3caf3..bf31704 100644 --- a/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java +++ b/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java @@ -295,7 +295,7 @@ public class JmsServiceImpl implements JmsService { MessageConsumer consumer = session.createConsumer(session.createQueue(queue), selector); Message message; do { - message = consumer.receiveNoWait(); + message = consumer.receive(5000L); if (message != null) { count++; } @@ -327,7 +327,7 @@ public class JmsServiceImpl implements JmsService { MessageConsumer consumer = session.createConsumer(session.createQueue(sourceQueue), selector); Message message; do { - message = consumer.receiveNoWait(); + message = consumer.receive(5000L); if (message != null) { MessageProducer producer = session.createProducer(session.createQueue(targetQueue)); producer.send(message);
