You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2008/09/16 14:48:23 UTC
svn commit: r695849 -
/servicemix/components/engines/servicemix-drools/trunk/src/main/java/org/apache/servicemix/drools/DroolsEndpoint.java
Author: gnodet
Date: Tue Sep 16 05:48:22 2008
New Revision: 695849
URL: http://svn.apache.org/viewvc?rev=695849&view=rev
Log:
SM-1576: Change endpoints lifecycle to use activate / start / stop / deactivate
Modified:
servicemix/components/engines/servicemix-drools/trunk/src/main/java/org/apache/servicemix/drools/DroolsEndpoint.java
Modified: servicemix/components/engines/servicemix-drools/trunk/src/main/java/org/apache/servicemix/drools/DroolsEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-drools/trunk/src/main/java/org/apache/servicemix/drools/DroolsEndpoint.java?rev=695849&r1=695848&r2=695849&view=diff
==============================================================================
--- servicemix/components/engines/servicemix-drools/trunk/src/main/java/org/apache/servicemix/drools/DroolsEndpoint.java (original)
+++ servicemix/components/engines/servicemix-drools/trunk/src/main/java/org/apache/servicemix/drools/DroolsEndpoint.java Tue Sep 16 05:48:22 2008
@@ -218,7 +218,11 @@
} else {
MessageUtil.transferOutToOut(exchange, original);
}
- send(original);
+ // TODO: remove this sendSync() and replace by a send()
+ // TODO: there is a need to store the exchange and send the DONE
+ // TODO: when the original comes back
+ sendSync(original);
+ done(exchange);
}
} else {
logger.debug("No pending exchange found for " + correlation + ", no additional rules will be triggered");
@@ -230,7 +234,7 @@
drools(exchange);
} else {
//must be a DONE/ERROR so removing any pending contexts
- pending.remove(exchange.getExchangeId());
+ DroolsExecutionContext drools = pending.remove(exchange.getExchangeId());
}
}