Hi Tim,
I did not look into Pushstreams in detail. Does Pushstreams also support
the reactive streams API?
My goal was to create a component API that is independent of a specific
stream DSL.
You mentioned that push streams are simpler to use. How would a
component look like for push streams. Can such a component then also be
run with the reactor DSL?
For my experiments with the DSL I chose reactor as it will get a lot of
attention as the core of spring 5.
Christian
On 29.06.2017 11:10, Timothy Ward wrote:
Hi Christian,
Did you also take a look at the OSGi produced reactive libraries? PushStreams
seem to be a much more elegant solution for what you’re trying to do, and would
let you simplify the connectors quite a lot. I think the client examples would
also be quite a lot simpler. There’s also an OSGi RFC for messaging that might
be helpful to look at
https://github.com/osgi/design/blob/36a3ee74db246c5a73f8d043c7172494fefee948/rfcs/rfc0229/RFC0229-MQTT.pdf.
Regards,
Tim
On 26 Jun 2017, at 17:12, Christian Schneider
<[email protected]<mailto:[email protected]>> wrote:
I recently looked into ways to combine messaging and streaming on OSGi.
Interestingly the best streaming solution I found for my case was Reactor (by
Pivotal) which is the core of spring 5. It works out of the box on OSGi and
only has a single dependency.
The next thing was how to combine this with messaging in a loosely coupled way.
I really like Apache Camel but I think it is not up to date any more and also
acquired a lot of weight over time (especially in camel-core). So I was looking
into providing a light weight component API and combine it with Reactor.
The result is this project:
https://github.com/cschneider/streaming-osgi/tree/master/reactortest
This is the Component API:
https://github.com/cschneider/streaming-osgi/blob/master/reactortest/src/main/java/component/api/MComponent.java
Actually I am unsure if the converter must be part of the API but this is the
current state.
I created some POC components for Mqtt, EventAdmin and Mail.
and finally two examples:
Listen on eventadmin topic, log and forward to other topic:
https://github.com/cschneider/streaming-osgi/blob/master/reactortest/src/main/java/reactortest/ExampleEventAdmin.java
Listen to mqtt, compute average over sliding window and forward to other topic:
https://github.com/cschneider/streaming-osgi/blob/master/reactortest/src/main/java/reactortest/MqttExampleComponent.java
I think there is a lot of potential in Reactor and also in messaging components
that do not couple your code to the technology.
I would be happy about any feedback on the prototype. Beware the code is not
yet split into bundles but I hope the intention is still visible.
Best
Christian
--
Christian Schneider
http://www.liquid-reality.de
Open Source Architect
http://www.talend.com
--
Christian Schneider
http://www.liquid-reality.de
Open Source Architect
http://www.talend.com
