[zeromq-dev] malamute - unsubscribe from stream like raw pub/sub sockets
kevin at spikegadgets.com
Sat Sep 30 14:51:20 CEST 2017
What about the "CANCEL" command in the stream API? There's a block of code in the server that unsubscribes when a client is destroyed. Can't that command be called separately? Other than in the destructor?
What steps do you take before extending it? I've already forked it on my local machine and modified the xml of client, server, and proto such that a remove_consumer works.
I'm new to the development process of the zeromq project, though I find the code generation scripts awesome and useful!
> On Sep 30, 2017, at 3:10 AM, Michal Vyskocil <michal.vyskocil at gmail.com> wrote:
> There is no such possibility in the protocol. The mlm proto and a client server needs to be extended for unsubscribe functionality.
> Workaround is to recreate mlm client each time.
> Dne 27. 9. 2017 10:50 odpoledne napsal uživatel "Kevin Wang" <kevin at spikegadgets.com>:
>> In malamute, the stream pattern is extremely useful for me. I'd like to have each client provide different "events" through the stream, and then each client can subscribe to specific events from different clients' streams. But this approach needs to be more dynamic and requires unsubscribing from a pattern in a stream, or reversing a mlm_set_consumer command.
>> My questions: There doesn't seem to be any option to unsubscribe a pattern from a stream currently. Does anyone have a workaround for this? Has there been discussion previously on this, and the possibility of implementing an unsubscribe option for malamute clients?
>> How difficult would it be? I assumed that if the pub/sub sockets can unsubscribe, then surely malamute clients can as well. Unless I'm missing something on how malamute streams are implemented...
>> zeromq-dev mailing list
>> zeromq-dev at lists.zeromq.org
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the zeromq-dev