You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2007/03/27 19:51:30 UTC
svn commit: r523020 -
/incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
Author: gnodet
Date: Tue Mar 27 10:51:29 2007
New Revision: 523020
URL: http://svn.apache.org/viewvc?view=rev&rev=523020
Log:
Fix compilation errors
Modified:
incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
Modified: incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java?view=diff&rev=523020&r1=523019&r2=523020
==============================================================================
--- incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java (original)
+++ incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java Tue Mar 27 10:51:29 2007
@@ -393,7 +393,7 @@
if (broadcast) {
log.debug(broker.getContainer().getName() + ": broadcasting info for " + event);
ObjectMessage msg = broadcastSession.createObjectMessage(event);
- synchronized (topicProducer) {}
+ synchronized (topicProducer) {
topicProducer.send(msg);
}
}
@@ -412,7 +412,7 @@
if (broadcast) {
ObjectMessage msg = broadcastSession.createObjectMessage(event);
log.debug(broker.getContainer().getName() + ": broadcasting info for " + event);
- synchronized (topicProducer) {}
+ synchronized (topicProducer) {
topicProducer.send(msg);
}
}
@@ -508,7 +508,7 @@
Queue queue = inboundSession.createQueue(destination);
ObjectMessage msg = inboundSession.createObjectMessage(me);
- synchronized (queueProducer) {}
+ synchronized (queueProducer) {
queueProducer.send(queue, msg);
}
} catch (JMSException e) {