You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ff...@apache.org on 2009/03/30 06:59:13 UTC
svn commit: r759840 - in
/servicemix/smx3/branches/servicemix-3.2/deployables:
bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/
serviceengines/servicemix-cxf-se/src/main/java/org/apache/servicemix/cxfse/
Author: ffang
Date: Mon Mar 30 04:59:12 2009
New Revision: 759840
URL: http://svn.apache.org/viewvc?rev=759840&view=rev
Log:
[SMXCOMP-490]ensure cxf bc and se endpoint check exchange status at very first place
Modified:
servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-cxf-se/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java
Modified: servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java?rev=759840&r1=759839&r2=759840&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java Mon Mar 30 04:59:12 2009
@@ -283,7 +283,9 @@
public void process(MessageExchange exchange) throws Exception {
-
+ if (exchange.getStatus() != ExchangeStatus.ACTIVE) {
+ return;
+ }
Message message = messages.remove(exchange.getExchangeId());
synchronized (message.getInterceptorChain()) {
Modified: servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-cxf-se/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-cxf-se/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java?rev=759840&r1=759839&r2=759840&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-cxf-se/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-cxf-se/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java Mon Mar 30 04:59:12 2009
@@ -309,6 +309,9 @@
@Override
public void process(MessageExchange exchange) throws Exception {
+ if (exchange.getStatus() != ExchangeStatus.ACTIVE) {
+ return;
+ }
QName opeName = exchange.getOperation();
EndpointInfo ei = server.getEndpoint().getEndpointInfo();