Might it make sense to have an "esper" exchange-type, where the queries would be on the bindings, and the inputs would be what were published to the exchange (and of course other inputs sent to the engine externally)?<br>
<br>Tony<br><br><br><div class="gmail_quote">On 16 March 2012 16:37, Mark Steele <span dir="ltr"><<a href="mailto:msteele@beringmedia.com">msteele@beringmedia.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
<div>Hi folks,</div><div><br></div><div>I'm wondering if anyone has put together an open source integration of RabbitMQ and Esper. </div><div><br></div><div>A couple approaches could be taken to get the data moved around. The cleanest way is probably an Esper input plugin. Would something like this work? (<a href="http://esper.codehaus.org/esperio-4.5.0/doc/reference/en/html/adapter_jms_spring.html" target="_blank">http://esper.codehaus.org/esperio-4.5.0/doc/reference/en/html/adapter_jms_spring.html</a>), if there's already an easy integration path and I'm just too ignorant of java to know it, then please clue me in.</div>
<div><br></div><div>Specifically, what I'm looking for is a daemon that reads messages off AMQP (in XML format), and pushes them into Esper. With outputs of EPL queries being pushed back into AMQP. <br></div>
<div><br></div><div>Example code that does something similar can be found in reconnoiter (<a href="https://labs.omniti.com/labs/reconnoiter/browser" target="_blank">https://labs.omniti.com/labs/reconnoiter/browser</a>), cepmon (<a href="https://github.com/fetep/cepmon" target="_blank">https://github.com/fetep/cepmon</a>) and rocksteady (<a href="http://code.google.com/p/rocksteady/source/browse/" target="_blank">http://code.google.com/p/rocksteady/source/browse/</a>), although a more generic approach using XML as the event format, and XPATH transormations configured in a config file would make it generic.</div>
<div><br></div><div>Another approach could be to use the socket input plugin (<a href="http://esper.codehaus.org/esperio-4.5.0/doc/reference/en/html/adapter_socket.html" target="_blank">http://esper.codehaus.org/esperio-4.5.0/doc/reference/en/html/adapter_socket.html</a>) and build a bridge app to push events in (would still need to figure out how to get the events out).</div>
<div><br></div><div>Once a generic approach like this would be implemented, it would be trivial to integrate various apps to emit to AMQP (eg: collectd/graphite/etc) and then send outputs out (eg: pagerduty/nagios/etc).<br>
</div><div><br></div><div>Mark Steele, CISSP, CSM<br></div>Bering Media Inc.<br><div><br></div>
<br>_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></blockquote></div><br><br clear="all"><br>-- <br>Tony Garnock-Jones<br><a href="mailto:tonygarnockjones@gmail.com" target="_blank">tonygarnockjones@gmail.com</a><br><a href="http://homepages.kcbbs.gen.nz/tonyg/" target="_blank">http://homepages.kcbbs.gen.nz/tonyg/</a><br>