implement unsubscribing from a topic. And getting current topic

[dams]

[dams]

ping ?

[dams]

Any progress ?

[objectuser]

@dams This doesn't quite work. It leaves orphaned processes for the unsubscribed topic. This can be seen using :observer.

Looking more closely now.

[objectuser]

It looks like the subscribers and workers need to be terminated, so I think this is a bit more complicated.

[dams]

Ah that's why I also saw strange behaviours... Don't we have a hook to these subscribers and workers ?

[objectuser]

Yes, Kaffe.GroupMember knows all the subscribers and Kaffe.WorkerManager has a table of the workers.

I'm not sure the supervision tree is optimized for shutting them down, so it might be a bit more manual.

[dams]

I don't think it's a problem if it requires the user to write some code to properly shut down the subscribers/workers. But it would be g reat to at least document what to do when shutting down a consumer