RabbitMQ, dificuldade para obter um exemplo hello world para trabalhar em qualquer coisa, exceto localhost

4

Estou aprendendo o RabbitMQ e corri o exemplo do hello world no link sem problemas localhost. Agora eu quero testar mensagens do meu PC para um servidor diferente, o receive.py nunca parece receber mensagens. Talvez eu não esteja especificando os nomes de host corretamente?

Receive.py:


#!/usr/bin/env python
import pika
import json

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='66.175.x.x'))
channel = connection.channel()

channel.queue_declare(queue='hello')

print ' [*] Waiting for messages. To exit press CTRL+C'

def callback(ch, method, properties, body):
    data = json.loads(body)
    print "Log filename is " + data["filename"]
    print data["content"]

channel.basic_consume(callback,
                      queue='hello',
                      no_ack=True)

channel.start_consuming()

send.py:


#!/usr/bin/env python
import pika
import json
import sys

filename = sys.argv[1]
logdata = open(filename, 'r').read()

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='66.175.x.x'))
channel = connection.channel()

channel.queue_declare(queue='logupload')
n = filename.rfind('\')
if n != -1:
    filename = filename[n + 1:]
data = {"filename":filename, "logdata":logdata}

channel.basic_publish(exchange='',
                      routing_key='logupload',
                      body=json.dumps(data))
connection.close()
print "sent %s %d bytes" % (filename, len(logdata))
    
por fred basset 18.08.2012 / 05:45

2 respostas

3

RabbitMQ - link

Veja o frame_max. Parece que 128KB é suportado por padrão. Você pode querer verificar essa configuração na sua instalação.

    
por 19.08.2012 / 22:29
2

Certifique-se de que rabbitmq esteja realmente escutando na porta 5672 e que a porta esteja aberta no firewall do seu servidor Linode.

Em sua configuração, RABBITMQ_NODE_IP_ADDRESS deve estar em branco, RABBITMQ_NODE_PORT deve ser 5672.

    
por 18.08.2012 / 05:48