Modified:
plugins/synapse/esper/trunk/java/mediators/src/main/java/org/sciflex/plugins/synapse/esper/mediators/AxiomMediator.java
plugins/synapse/esper/trunk/java/pom.xml
sci-flex/trunk/java/demo/conf/synapse.xml
Log:
Few temporal fixes
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 04:08:23 2009
@@ -392,7 +392,7 @@
public boolean mediate(MessageContext mc) {
if (activityMonitor != null
&& !activityMonitor.getIsMediatorActive()) {
log.warn("Cannot mediate. Mediator is inactive");
- return true;
+ return false;
}
long activityStamp = System.currentTimeMillis();
log.trace("Beginning Mediation");
Modified: plugins/synapse/esper/trunk/java/pom.xml
==============================================================================
--- plugins/synapse/esper/trunk/java/pom.xml (original)
+++ plugins/synapse/esper/trunk/java/pom.xml Wed Jan 28 04:08:23 2009
@@ -623,12 +623,12 @@
<version>${junit.version}</version>
<scope>test</scope>
</dependency>
- <dependency>
+ <!--dependency>
<groupId>com.clarkware</groupId>
<artifactId>junitperf</artifactId>
<version>${junitperf.version}</version>
<scope>test</scope>
- </dependency>
+ </dependency-->
</dependencies>
<modules>
Modified: sci-flex/trunk/java/demo/conf/synapse.xml
==============================================================================
--- sci-flex/trunk/java/demo/conf/synapse.xml (original)
+++ sci-flex/trunk/java/demo/conf/synapse.xml Wed Jan 28 04:08:23 2009
@@ -48,6 +48,18 @@
<xpath-property property-name="extra"
xpath="//packet/extra/@information" type="string"/>
</xml-dom>
</event-type>
+ <plugin-event-representation
uri="type://xml/apacheaxiom/OMNode"
+
class-name="com.espertech.esperio.representation.axiom.AxiomEventRepresentation"/>
+ <plugin-event-type alias="AxiomEvent">
+ <resolution-uri
value="type://xml/apacheaxiom/OMNode"/>
+ <initializer>
+ <xml-axiom root-element-name="tick"
default-namespace="http://mycom.com/ns/tick">
+ <namespace-prefix prefix="t"
namespace="http://mycom.com/ns/tick"/>
+ <xpath-property property-name="symbol"
xpath="//t:tick/t:s" type="string"/>
+ <xpath-property property-name="price"
xpath="//t:tick/t:p" type="number"/>
+ </xml-axiom>
+ </initializer>
+ </plugin-event-type>
</esper-configuration>
</property>
<property name="InstanceURI" value="urn:CEPInstance"/>
@@ -87,7 +99,7 @@
<property name="EventToAddress"
value="urn:trafficInformation7"/>
<property name="Inactive" value="true"/>
</class>
- <class
name="org.sciflex.plugins.synapse.esper.mediators.XMLMediator">
+ <class
name="org.sciflex.plugins.synapse.esper.mediators.AxiomMediator">
<property name="InstanceURI" value="urn:CEPInstance"/>
<property name="Statement" value="select * from packets"/>
<property name="EventToAddress"
value="urn:trafficInformation8"/>
@@ -115,6 +127,18 @@
</case>
</switch>
<log level="full"/>
+
+ <!--header action="set" name="Action" value="urn:Home"/>
+ <property name="transport.xmpp.ServerUrl" value="gmail.com"
scope="transport"/>
+ <property name="transport.xmpp.ServerAccountUserName" value="sciflex"
scope="transport"/>
+ <property name="transport.xmpp.ServerAccountPassword" value="usersag4"
scope="transport"/>
+ <property name="transport.xmpp.ServerType"
value="transport.xmpp.ServerType.Jabber" scope="transport"/>
+ <send>
+ <endpoint>
+ <address uri="xmpp://sena...@gmail.com/Home"/>
+ </endpoint>
+ </send-->
+
<property action="set" name="OUT_ONLY" value="true"/>
<property name="Subject" value="SCI-Flex Alert" scope="transport"/>
<property name="ContentType" value="text/html" scope="axis2"/>
@@ -123,6 +147,7 @@
<address uri="mailto:sci...@gmail.com" format="pox"/>
</endpoint>
</send>
+
<!--out>
<property action="set" name="OUT_ONLY" value="true"/>
<property name="Subject" value="SCI-Flex Alert" scope="transport"/>