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: [email protected]
For additional commands, e-mail: [email protected]
