RabbitMQ, trouble getting hello world example to work on anything but localhost

Question

I'm learning RabbitMQ and have run the hello world example at http://www.rabbitmq.com/tutorials/tutorial-one-python.html without problems on localhost. Now I want to test messaging from my PC to a different server, receive.py never seems to get any messages. Perhaps I'm not specifying the hostnames correctly?

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))

Chida · Accepted Answer · 2012-08-19T21:12:55.327

3

RabbitMQ -- http://www.rabbitmq.com/configure.html

See the frame_max. Seems like 128KB is supported by default. You may want to check that setting in your installation.

edited Aug 19 '12 at 21:12

answered Aug 19 '12 at 20:29

Chida

2,471
1
16
29

Note I'm using RabbitMQ. File is sent up as a JSON encoded string (for now). – fred basset Aug 19 '12 at 21:07
updated my answer – Chida Aug 19 '12 at 21:13
I created a config file specifyinga large frame_max, didn't seem to affect the behavior however. My config. file is : {rabbit, [{frame_max, 20000000}, {log_levels, [{connection, info}]}]} ]. – fred basset Aug 20 '12 at 20:19
It looks like Pika is limited to 128K data size. Message me if you know how to get around this? – fred basset Aug 22 '12 at 03:12

score 2 · Answer 2 · answered Aug 18 '12 at 03:48

2

Make sure rabbitmq is actually listening on port 5672 and that the port is open in your Linode server's firewall.

In your config, RABBITMQ_NODE_IP_ADDRESS should be blank, RABBITMQ_NODE_PORT should be 5672.

answered Aug 18 '12 at 03:48

Michael Hampton

237,123
42
477
940

I checked I don't have a firewall running and have no rabbitmq config. file. This morning it started working with no changes. My next problem is that smaller log files (~10K) are not being received but larger files (>= ~100K) are sent OK. Is there some type of buffering that prevents smaller data payloads from being sent or received? – fred basset Aug 19 '12 at 18:52
Actually current behavior is that small files (~64 bytes) are being received, but larger files (~52K) are not. What would prevent one file from being transferred over another? – fred basset Aug 19 '12 at 19:55

RabbitMQ, trouble getting hello world example to work on anything but localhost

2 Answers2