activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r587396 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
Date Tue, 23 Oct 2007 05:38:38 GMT
Author: rajdavies
Date: Mon Oct 22 22:38:36 2007
New Revision: 587396

URL: http://svn.apache.org/viewvc?rev=587396&view=rev
Log:
synchronize doMessageSend() to ensure messages are stored and dispatched
in the right order

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java?rev=587396&r1=587395&r2=587396&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
Mon Oct 22 22:38:36 2007
@@ -380,7 +380,15 @@
         }
     }
 
-    void doMessageSend(final ProducerBrokerExchange producerExchange, final Message message)
throws IOException, Exception {
+    /**
+     * do send the message - this needs to be synchronized to ensure messages are stored
AND dispatched in 
+     * the right order
+     * @param producerExchange
+     * @param message
+     * @throws IOException
+     * @throws Exception
+     */
+    synchronized void doMessageSend(final ProducerBrokerExchange producerExchange, final
Message message) throws IOException, Exception {
         final ConnectionContext context = producerExchange.getConnectionContext();
         message.setRegionDestination(this);
 



Mime
View raw message