search

moleculerjs / moleculer-channels

Reliable messages for Moleculer services via external queue/channel/topic.
MIT License
76 stars 15 forks source link

Feature Request: Add Ability to Pause/Resume Stream Processing #48

Open valeeum opened 2 years ago

valeeum commented 2 years ago

It would be nice to be able to pause/resume processing of messages without unsubscribing from the channel.

intech commented 2 years ago

@valeeum Do I understand that correctly you want to do this inside the handler? Should it work like in Kafka?

valeeum commented 2 years ago

@intech i'd like to do this from a method within my service, i.e., this.pauseChannel("order.created") or this.pauseChannels() to pause all channels defined in the service. i unfortunately don't have much experience with kafka but my use case is to be able to pause processing of events during times of system maintenance.

icebob commented 2 years ago

Good idea.