...
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
Code Block |
---|
esper:name[?option1=value[&option2=value2]]options] |
When consuming from an Esper endpoint you must specify a pattern or eql statement to query the event stream.
For Pattern example:
Code Block |
---|
from("esper://cheese?pattern=every event=MyEvent(bar=5)") . to("activemq:Foo"); |
EQL example:
Code Block |
---|
from("esper://esper-dom?eql=insert into DomStream select * from org.w3c.dom.Document")
.to("log://esper-dom?level=INFO");
from("esper://esper-dom?eql=select childNodes from DomStream")
.to("mock:results");
|
Options
Div | ||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|
| ||||||||||||
|
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:
Code Block |
---|
EventBean newEvent = exchange.getIn(EsperMessage.class).getNewEvent();
EventBean oldEvent = exchange.getIn(EsperMessage.class).getOldEvent();
|
By default if you get the body of org.apacheextras.camel.component.esper.EsperMessage
it returns the new EventBean
as in previous versions.
Demo
There is a demo which shows how to work with ActiveMQ, Camel and Esper in the Camel Extra project
Include Page | |||
---|---|---|---|
Include Page | |||
|