Repository: karaf Updated Branches: refs/heads/karaf-3.0.x a8b428941 -> 6e1fb913e
[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/6e1fb913 Tree: http://git-wip-us.apache.org/repos/asf/karaf/tree/6e1fb913 Diff: http://git-wip-us.apache.org/repos/asf/karaf/diff/6e1fb913 Branch: refs/heads/karaf-3.0.x Commit: 6e1fb913e157d47caff4121e89333d43296c1cb8 Parents: a8b4289 Author: Jean-Baptiste Onofré <[email protected]> Authored: Mon Apr 7 06:35:55 2014 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Mon Apr 7 06:37:47 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/6e1fb913/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 d51bc75..fe4b43d 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 @@ -258,7 +258,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++; } @@ -279,7 +279,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);
