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) {