kombu
kombu copied to clipboard
How To Set consumer_tag
How To Set consumer_tag in this code every queue consumer_tag is different
video_queue = Queue('video', exchange=media_exchange, key='video')
image_queue = Queue('image', exchange=media_exchange, key='image')
with connection.Consumer([video_queue, image_queue],
callbacks=[process_media]) as consumer: