Last week I was building up a RabbitMQ cluster with shovel from New York to Los Angeles. As we use a dual stack environment ipv4\/v6, I expected that RabbitMQ would resolve the ipv6 address\u00a0 first as normal Linux systems do. So I begun to do my tests and realized, that it didn’t.<\/p>\n
My publisher\u00a0 (see code below) sends messages to the following host: “‘rabbitmq0.domb.net<\/strong><\/em>‘”<\/p>\n [cc lang=”python”] conn = amqp.Connection(‘rabbitmq0.domb.net’, userid=”logger”, password=”test”, virtual_host=”\/”, insist=False) for i in range(1000): [\/cc]<\/p>\n Executing that code I got the following error:<\/p>\n Here an example with a ipv6 address:<\/p>\n [cc lang=”python”] conn = amqp.Connection(‘[2625:103:2012::205a]:5672’, userid=”logger”, password=”test”, virtual_host=”\/”, insist=False) for i in range(1000): [\/cc]<\/p>\n Yes it does.<\/p>\n As I need ipv6 and couldn’t find the code where the erlang parameter gets passed I wrote to the RabbitMQ mailing list.<\/p>\n http:\/\/comments.gmane.org\/gmane.comp.networking.rabbitmq.general\/18437<\/p>\n And got a fast response and a fix from Emile Joubert from rabbitmq 4 days later. Thank you very much!!!\u00a0 Will test the patch this week.<\/p>\n Here is the patch<\/p>\n http:\/\/hg.rabbitmq.com\/rabbitmq-erlang-client\/rev\/7f53561c0c11<\/p>\n If you don’t know howto rebuild the rpm you can have mine until the official comes out. Use it at your own risk!<\/p>\n
\nfrom amqplib import client_0_8 as amqp
\nimport sys<\/p>\n
\nchan = conn.channel()<\/p>\n
\n#msg = amqp.Message(sys.argv[1])
\nsendmsg = “paket ny:” + str(i)
\nmsg = amqp.Message(sendmsg)
\nmsg.properties[“delivery_mode”] = 2
\nchan.basic_publish(msg,exchange=”incoming_orders”,routing_key=”warehouse”)
\nchan.close()
\nconn.close()<\/p>\n
\n{rabbit_shovel_worker,handle_cast,2},
\n{gen_server2,handle_msg,2},
\n{proc_lib,init_p_do_apply,3}]}<\/p>\n
\nfrom amqplib import client_0_8 as amqp
\nimport sys<\/p>\n
\nchan = conn.channel()<\/p>\n
\n#msg = amqp.Message(sys.argv[1])
\nsendmsg = “paket ny:” + str(i)
\nmsg = amqp.Message(sendmsg)
\nmsg.properties[“delivery_mode”] = 2
\nchan.basic_publish(msg,exchange=”incoming_orders”,routing_key=”warehouse”)
\nchan.close()
\nconn.close()<\/p>\n