Change SubscriptionExceptionMiddleware to use the client's RabbitMQ
username instead of the user_id of the message that caused the
exception when publishing to the default error exchange.
Change RetryLaterMiddleware to use the client's RabbitMQ
username instead of the user_id of the message that caused the
exception when publishing to the retry exchange.
Description
When republishing a message after an exception to either the default error exchange or retry exchange the relevant middleware uses the user_id of the incoming message that caused the exception. If the user_id of that message is not the same as the consumer's login RabbitMQ will reject the message and close the connection.
This commit will override the user_id of the message properties just before re-publishing it so that RabbitMQ will accept it.
Change SubscriptionExceptionMiddleware to use the client's RabbitMQ username instead of the user_id of the message that caused the exception when publishing to the default error exchange.
Change RetryLaterMiddleware to use the client's RabbitMQ username instead of the user_id of the message that caused the exception when publishing to the retry exchange.
Description
When republishing a message after an exception to either the default error exchange or retry exchange the relevant middleware uses the user_id of the incoming message that caused the exception. If the user_id of that message is not the same as the consumer's login RabbitMQ will reject the message and close the connection.
This commit will override the user_id of the message properties just before re-publishing it so that RabbitMQ will accept it.
Check List
stablebranch.