You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ge...@apache.org on 2011/09/14 16:52:01 UTC
svn commit: r1170662 - in
/servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component:
WSNComponent.java WSNEndpoint.java
Author: gertv
Date: Wed Sep 14 14:52:00 2011
New Revision: 1170662
URL: http://svn.apache.org/viewvc?rev=1170662&view=rev
Log:
SMXCOMP-903: Wait for pending exchanges to get done before unregistering subscription endpoint
Modified:
servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNComponent.java
servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNEndpoint.java
Modified: servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNComponent.java
URL: http://svn.apache.org/viewvc/servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNComponent.java?rev=1170662&r1=1170661&r2=1170662&view=diff
==============================================================================
--- servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNComponent.java (original)
+++ servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNComponent.java Wed Sep 14 14:52:00 2011
@@ -292,6 +292,8 @@ public class WSNComponent extends Defaul
public void run() {
try {
Endpoint ep = (Endpoint) endpoint;
+ // let's wait for pending exchanges to be done before actually removing the endpoint
+ WSNComponent.this.prepareShutdown(ep);
WSNComponent.this.removeEndpoint(ep);
} catch (Exception e) {
logger.error("Unable to deactivate endpoint", e);
Modified: servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNEndpoint.java?rev=1170662&r1=1170661&r2=1170662&view=diff
==============================================================================
--- servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNEndpoint.java (original)
+++ servicemix/components/trunk/engines/servicemix-wsn2005/src/main/java/org/apache/servicemix/wsn/component/WSNEndpoint.java Wed Sep 14 14:52:00 2011
@@ -217,7 +217,7 @@ public class WSNEndpoint extends Provide
JbiWrapperHelper.wrap(doc);
}
msg.setContent(new DOMSource(doc));
- sendSync(exchange);
+ send(exchange);
}
}