How to Safely Use Kombu in a Multithreaded Environment?

[worl2160]

I’m working on a project where I need to use the Kombu library for message passing, but I’ve encountered issues when running it in a multithreaded environment. After some research, I found out that Kombu is not thread-safe by design, which might explain the problems I’m facing, such as:

• Unexpected behavior when multiple threads try to publish messages simultaneously.
• Occasional crashes when accessing Kombu connections from different threads.

I understand that Kombu uses AMQP connections and channels, which are not thread-safe. However, I need to use threading in my application to achieve concurrent processing.

Could someone provide guidance or best practices on how to handle Kombu in a multithreaded context?