consumer.py - master - george2066/FARMQTeleBot

consumer.py

24 строки691 B

George Rodionov

broker messages: RabbitMQ

19 окт 2025, 17:34

19 окт 2025, 17:344d832df

from pika import ConnectionParameters, BlockingConnection

connection_params = ConnectionParameters(
    host = "localhost",
    port = 5672,
)

def process_message(ch, method, properties, body):
    print(f'Received message: {body.decode()}')
    ch.basic_ack(delivery_tag=method.delivery_tag)

def main():
    with BlockingConnection(connection_params) as conn:
        with conn.channel() as ch:
            ch.queue_declare(queue="messages")
            ch.basic_consume(
                queue='messages',
                on_message_callback=process_message,
            )
            print("Awaiting new messages")
            ch.start_consuming()

if __name__ == '__main__':
    main()