[CONF] Apache Camel > Esper

[Claus Ibsen (Confluence)]

Esper Page edited by Claus Ibsen Changes (1) ... You can append query options to the URI in the following format, {{?option=value&option=value&...}} h3. EsperMessage From *Camel 2.12* onwards the esper consumer stores new and old events in the {{org.apacheextras.camel.component.esper.EsperMessage}} message as the input [Message] on the [Exchange]. You can get access to the esper event beans from java code with: {code} EventBean newEvent = exchange.getIn().getBody(EsperMessage.class).getNewEvent(); EventBean oldEvent = exchange.getIn().getBody(EsperMessage.class).getOldEvent(); {code} By default if you get the body of {{org.apacheextras.camel.component.esper.EsperMessage}} it returns the new event bean as in previous versions. h3. Demo ... Full Content Esper The Esper component supports the Esper Library for Event Stream Processing. The camel-esper library is provided by the Camel Extra project which hosts all *GPL related components for Camel. URI format esper:name[?options] When consuming from an Esper endpoint you must specify a pattern or eql statement to query the event stream. For example from("esper://cheese?pattern=every event=MyEvent(bar=5)"). to("activemq:Foo"); Options Name Default Value Description pattern   The Esper Pattern _expression_ as a String to filter events eql   The Esper EQL _expression_ as a String to filter events You can append query options to the URI in the following format, ?option=value&option=value&... EsperMessage From Camel 2.12 onwards the esper consumer stores new and old events in the org.apacheextras.camel.component.esper.EsperMessage message as the input Message on the Exchange. You can get access to the esper event beans from java code with: EventBean newEvent = exchange.getIn().getBody(EsperMessage.class).getNewEvent(); EventBean oldEvent = exchange.getIn().getBody(EsperMessage.class).getOldEvent(); By default if you get the body of org.apacheextras.camel.component.esper.EsperMessage it returns the new event bean as in previous versions. Demo There is a demo which shows how to work with ActiveMQ, Camel and Esper in the Camel Extra project See Also Configuring Camel Component Endpoint Getting Started Esper Camel Demo Stop watching space | Change email notification preferences View Online | View Changes | Add Comment