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

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

Author: timfox
Date: 2008-11-06 12:23:18 -0500 (Thu, 06 Nov 2008)
New Revision: 5292

Modified:
   trunk/src/main/org/jboss/messaging/core/remoting/impl/RemotingConnectionImpl.java
Log:
Prevent duplicate confirmations


Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/RemotingConnectionImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/RemotingConnectionImpl.java	2008-11-06 17:10:18 UTC (rev 5291)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/RemotingConnectionImpl.java	2008-11-06 17:23:18 UTC (rev 5292)
@@ -1347,14 +1347,17 @@
             receivedBytes += packet.getPacketSize();
 
             if (receivedBytes >= confWindowSize)
-            {
-               final Packet confirmed = new PacketsConfirmedMessage(lastReceivedCommandID);
-
-               confirmed.setChannelID(id);
-
+            {               
                receivedBytes = 0;
 
-               doWrite(confirmed);
+               if (connection.active)
+               {
+                  final Packet confirmed = new PacketsConfirmedMessage(lastReceivedCommandID);
+   
+                  confirmed.setChannelID(id);
+                  
+                  doWrite(confirmed);
+               }
             }
          }
       }
@@ -1411,12 +1414,6 @@
          {
             switch (packet.getType())
             {
-               case PACKETS_CONFIRMED:
-               {
-                  doWrite(packet);
-
-                  break;
-               }
                case REPLICATION_RESPONSE:
                {
                   replicateResponseReceived();