Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import qpid
- import sys
- import os
- from random import randint
- from qpid.util import connect
- from qpid.connection import Connection
- from qpid.datatypes import Message, RangedSet, uuid4
- from qpid.queue import Empty
- host = "127.0.0.1"
- port = 5672
- user = "guest"
- password = "guest"
- # Estabelece a conexao com o broker ...
- socket = connect(host, port)
- connection = Connection (sock = socket, username = user, password = password)
- connection.start()
- session = connection.session(str(uuid4()))
- # Cria e declara as queues no broker ...
- session.queue_declare(queue = "message_queue")
- session.exchange_bind(exchange = "amq.direct", queue = "message_queue", binding_key = "routing_key")
- # Cria um listener local para a queue definida ...
- local_queue_name = "local_queue"
- queue = session.incoming(local_queue_name)
- session.message_subscribe(queue = "message_queue", destination = local_queue_name)
- queue.start()
- # Le as mensagens ate que o flag seja enviado ...
- final = "___final___"
- content = ""
- message = None
- while content != final:
- message = queue.get(timeout = 10)
- content = message.body
- session.message_accept(RangedSet(message.id))
- print content
- # Fecha a conexao com o Broker ...
- session.close(timeout = 10)
Add Comment
Please, Sign In to add comment