migrate_task

Migrate single task message.

def migrate_task(
    producer: kombu.Producer,
    body_: any,
    message: kombu.Message,
    queues: dict = None
) - > null

Migrate single task message.

Parameters

Name	Type	Description
producer	kombu.Producer	The producer instance used to republish the task message to the new destination.
body_	any	The decoded body of the message being migrated.
message	kombu.Message	The original message object containing delivery information such as exchange and routing key.
queues	dict = None	A mapping of old exchange or routing key names to their new destination names.

Returns

Type	Description
null	Nothing is returned; the message is republished to the target exchange and routing key.