Класс обработчика

class pikahandler.PikaHandler(server='localhost', port=5672, host='/', user=None, password=None, connection=None)

Класс, который будет отвечать за расределение запросов к вашим функциям. Важная вещь, не надо его обижать. Вызывать в начале кода и потом использовать для декорирования.

Передавать либо server, port, host, user (optional), password (optional), либо connection=connection, где значение connection - pika.BlockingConnection(pika.ConnectionParameters(<..>))

Агрументы и атрибуты

Параметры:

• server (str, optional) – домен или IP сервера, по умолчанию „localhost“
• port (int, optional) – порт сервера, по умолчанию „5672“
• host (str, optional) – адрес очережи, по умолчанию - /
• user (str, optional) – пользователь
• password (str, optional) – пароль
• connection (pika.BlockingConnection, optional) – объект соединения

handler(queue: str, func=None)

Декоратор для сохранения функции в список обрабатываемых

Аргументы

Параметры:

• queue (str) – название очереди
• func – лямбда-функция или обычная функция, принимающая в себя один аргумент - класс с ключами ch, method, properties, body.

start()

Запускает приём и обработку сообщений из очереди.