moleculer-channels icon indicating copy to clipboard operation
moleculer-channels copied to clipboard

Feature Request: Add Ability to Pause/Resume Stream Processing

Open valeeum opened this issue 2 years ago • 3 comments

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

valeeum avatar Oct 11 '22 02:10 valeeum

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

intech avatar Oct 11 '22 08:10 intech

@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.

valeeum avatar Oct 12 '22 05:10 valeeum

Good idea.

icebob avatar Oct 12 '22 07:10 icebob