Как вызвать обратный вызов, когда событие происходит с вызываемым? - PullRequest
Новая
       57

Как вызвать обратный вызов, когда событие происходит с вызываемым?

0 голосов
/ 05 августа 2020

Как оповестить звонящего i, если абонент получил сообщение? Я знаю, что когда абонент получил сообщение, он позвонит по номеру message_callback, но как уведомить внешнего вызывающего абонента i? Я надеюсь, что во внешнем может быть обратный вызов, он сработает, как только подписчик получит сообщение. 

class Interface(object):
    def subscriber():
        connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
        channel = connection.channel()
        channel.queue_declare(queue='hello')

        def message_callback(ch, method, properties, body):
            print(" [x] Received %r" % body)

        channel.basic_consume(queue='hello',
                              auto_ack=True,
                              on_message_callback=message_callback)

        print(' [*] Waiting for messages. To exit press CTRL+C')
        channel.start_consuming()


i = Interface()
i.subscriber()
...