import pika

def process_message(ch, method, properties, body):
    print(f"Получено сообщение (Consumer 2): {body.decode('utf-8')}")
    ch.basic_ack(delivery_tag=method.delivery_tag)

def consume_messages(channel, queue_name, exchange_name):
    channel.queue_declare(queue=queue_name)
    channel.queue_bind(exchange=exchange_name, queue=queue_name)
    channel.basic_consume(queue=queue_name, on_message_callback=process_message)

    print("Consumer 2 начал прослушивание сообщений...")
    channel.start_consuming()

def main():
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()

    exchange_name = 'logs'
    queue_name = 'queue2'

    consume_messages(channel, queue_name, exchange_name)

    connection.close()

if __name__ == '__main__':
    main()