search

reactive-ipc / reactive-ipc-jvm

Reactive IPC for the JVM
Apache License 2.0
55 stars 13 forks source link

ZeroMQ support #12

Open jbrisbin opened 9 years ago

jbrisbin commented 9 years ago

Following the mention of Kafka support in #6, it would be useful to many people to support ZeroMQ as a transport as well. It has well-established non-blocking usage patterns that would map very easily onto Reactive Streams.

Having more than one transport supported OOTB would also serve the very useful purpose of guiding abstractions that need to live in higher-level modules like the tcp and core modules.

NiteshKant commented 9 years ago

@jbrisbin are you referring to zeroMQ codec support similar to what spotify provides here over netty or a ZeroMQ client & server SPI?

jbrisbin commented 9 years ago

ZeroMQ could function as a transport library just like Netty, the only meaningful difference being the real data type passed into the connection Subscriber. In the Netty case, that would be a ByteBuf and in the ZMQ case, that would be a Frame.

jbrisbin commented 9 years ago

This also illustrates the need to handle a Buffer of bytes in two radically different ways but from a common abstraction. :)