[jboss-cvs] JBoss Messaging SVN: r4123 - trunk/src/main/org/jboss/messaging/core/remoting/impl/mina.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2008-04-28 08:09:50 -0400 (Mon, 28 Apr 2008)
New Revision: 4123

Modified:
   trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaSession.java
Log:
use an AtomicLong to represent the correlationCounter

Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaSession.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaSession.java	2008-04-28 08:50:28 UTC (rev 4122)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaSession.java	2008-04-28 12:09:50 UTC (rev 4123)
@@ -7,6 +7,7 @@
 package org.jboss.messaging.core.remoting.impl.mina;
 
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicLong;
 
 import org.apache.mina.common.IoSession;
 import org.apache.mina.filter.reqres.Request;
@@ -28,7 +29,7 @@
 
    private final IoSession session;
 
-   private long correlationCounter;
+   private AtomicLong correlationCounter;
    
    // Static --------------------------------------------------------
 
@@ -39,7 +40,7 @@
       assert session != null;
 
       this.session = session;
-      correlationCounter = 0;
+      correlationCounter = new AtomicLong(0);
    }
 
    // Public --------------------------------------------------------
@@ -56,7 +57,7 @@
 
    public Object writeAndBlock(Packet packet, long timeout, TimeUnit timeUnit) throws Exception
    {
-      packet.setCorrelationID(correlationCounter++);
+      packet.setCorrelationID(correlationCounter.incrementAndGet());
       Request req = new Request(packet.getCorrelationID(), packet, timeout, timeUnit);
       session.write(req);
       Response response = req.awaitResponse();