Added a poison message handler function which moves any poison messages to a poison queue, defined in the env.json .
The logic which I have used is to first open the main DEV.QUEUE.3 queue and perform a MQGET to retrieve the poison message from the queue, following which I open the POISONING_QUEUE and perform a MQPUT to redirect the poison messages to this queue.
Added a poison message handler function which moves any poison messages to a poison queue, defined in the
env.json
.The logic which I have used is to first open the main
DEV.QUEUE.3
queue and perform aMQGET
to retrieve the poison message from the queue, following which I open thePOISONING_QUEUE
and perform aMQPUT
to redirect the poison messages to this queue.