Current implementation leaves the invalid messages to the queue by not acknowledging them and that causes weird errors and would require manual purging of the messages.
Possible solutions:
Error queues
acknowledge and raise error
can validation be implemented in the broker?
how are the messages in the error queue processed?
The basic.ack or basic.reject should come after the processing of the message.
The message should be rejected, error logged and if there is an RPC style of communication a reply message sent back.
Description
Current implementation leaves the invalid messages to the queue by not acknowledging them and that causes weird errors and would require manual purging of the messages.
Possible solutions:
DoD
Better error handling for services
Testing
Integration testing