qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rgodf...@apache.org
Subject svn commit: r1677960 - /qpid/branches/0.32.x/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/LinkEndpoint.java
Date Wed, 06 May 2015 11:21:25 GMT
Author: rgodfrey
Date: Wed May  6 11:21:25 2015
New Revision: 1677960

URL: http://svn.apache.org/r1677960
Log:
Merge changes from trunk

Modified:
    qpid/branches/0.32.x/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/LinkEndpoint.java

Modified: qpid/branches/0.32.x/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/LinkEndpoint.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.32.x/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/LinkEndpoint.java?rev=1677960&r1=1677959&r2=1677960&view=diff
==============================================================================
--- qpid/branches/0.32.x/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/LinkEndpoint.java
(original)
+++ qpid/branches/0.32.x/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/LinkEndpoint.java
Wed May  6 11:21:25 2015
@@ -176,7 +176,7 @@ public abstract class LinkEndpoint<T ext
         return _linkCredit;
     }
 
-    public void remoteDetached(Detach detach)
+    public void remoteDetached(final Detach detach)
     {
         synchronized (getLock())
         {
@@ -187,7 +187,14 @@ public abstract class LinkEndpoint<T ext
                     break;
                 case ATTACHED:
                     _state = State.DETACH_RECVD;
-                    _linkEventListener.remoteDetached(this, detach);
+                    getSession().getConnection().addPostLockAction(new Runnable()
+                    {
+                        @Override
+                        public void run()
+                        {
+                            _linkEventListener.remoteDetached(LinkEndpoint.this, detach);
+                        }
+                    });
                     break;
             }
             getLock().notifyAll();



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message