def migrate_task(producer, body_, message, queues=None):
 info = message.delivery_info
 queues = ({} if (queues is None) else queues)
 republish(producer, message, exchange=queues.get(info[u'exchange']), routing_key=queues.get(info[u'routing_key']))

def migrate_task ( producer , body_ , message , queues = None ) : info = message . delivery_info queues = ( { } if ( queues is None ) else queues ) republish ( producer , message , exchange = queues . get ( info [ u'exchange' ] ) , routing_key = queues . get ( info [ u'routing_key' ] ) )
migrate single task message .