[sci-flex commit] r423 - plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper...

[codesite...@google.com]

Author: harsha.halgaswatta
Date: Wed Jan 28 03:42:24 2009
New Revision: 423

Modified:

plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/AxiomMediator.java

plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/XMLMediator.java

Log:
Fixing mediator sequencing problem

Modified:
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/AxiomMediator.java
==============================================================================
---
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/AxiomMediator.java
(original)
+++
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/AxiomMediator.java
Wed Jan 28 03:42:24 2009
@@ -392,7 +392,7 @@
public boolean mediate(MessageContext mc) {
if (activityMonitor != null
&& !activityMonitor.getIsMediatorActive()) {
log.warn("Cannot mediate. Mediator is inactive");
- return false;
+ return true;
}
long activityStamp = System.currentTimeMillis();
log.trace("Beginning Mediation");

Modified:
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/XMLMediator.java
==============================================================================
---
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/XMLMediator.java
(original)
+++
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/XMLMediator.java
Wed Jan 28 03:42:24 2009
@@ -371,7 +371,7 @@
public boolean mediate(MessageContext mc) {
if (activityMonitor != null
&& !activityMonitor.getIsMediatorActive()) {
log.warn("Cannot mediate. Mediator is inactive");
- return false;
+ return true;
}
long activityStamp = System.currentTimeMillis();
log.trace("Beginning Mediation");