Commit efcc139e authored by afreyssin's avatar afreyssin
Browse files

Minor changes.

parent fbf69f6d
...@@ -185,15 +185,14 @@ public class JMSBridgeQueueImpl extends QueueImpl { ...@@ -185,15 +185,14 @@ public class JMSBridgeQueueImpl extends QueueImpl {
int reqIndex = requests.size() - 1; int reqIndex = requests.size() - 1;
deliverMessages(reqIndex); deliverMessages(reqIndex);
// If the request has not been answered:
if ((requests.size() - 1) == reqIndex) { if ((requests.size() - 1) == reqIndex) {
// If it is an immediate delivery request, requesting the foreign JMS // If the request has not been answered:
// destination for an immediate delivery.
if (not.getTimeOut() == -1) { if (not.getTimeOut() == -1) {
// If it is an immediate delivery request, requesting the foreign JMS
// destination for an immediate delivery.
requests.remove(reqIndex); requests.remove(reqIndex);
org.objectweb.joram.shared.messages.Message message = null; org.objectweb.joram.shared.messages.Message message = null;
try { try {
message = jmsModule.receiveNoWait(); message = jmsModule.receiveNoWait();
} catch (Exception exc) { } catch (Exception exc) {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment