search

moleculerjs / moleculer-channels

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

Store the failed consumer "group" in headers #17

Closed icebob closed 2 years ago

icebob commented 2 years ago

Before we push the failed message to the dead-letter topic, we should store the failed "x-original-group" name into the message header, similar to "x-original-channel" name.

icebob commented 2 years ago

I've added in AMQP, NATS and Kafka adapters.

icebob commented 2 years ago

For Redis, would be better to implement #14 at first, and store these parameters into the headers like in other adapters.