RabbitMQ

Erlang installation on Slackware

Requires Erlang:

• su
• cd /tmp

• wget http://slackbuilds.org/slackbuilds/13.0/development/erlang-otp.tar.gz

• tar xvzf erlang-otp.tar.gz
• cd erlang-otp

• wget http://www.erlang.org/download/otp_src_R13B03.tar.gz

• wget http://www.erlang.org/download/otp_doc_man_R13B03.tar.gz

• ./erlang-otp.SlackBuild

• installpkg /tmp/erlang-otp-13B03-i486-1_SBo.tgz

Slackbuild

• wget http://slackbuilds.org/slackbuilds/14.1/development/erlang-otp.tar.gz

• tar xvzf erlang-otp.tar.gz
• cd erlang-otp

• wget http://www.erlang.org/download/otp_src_R16B02.tar.gz

• wget http://www.erlang.org/download/otp_doc_man_R16B02.tar.gz

• ./erlang-otp.SlackBuild

• installpkg /tmp/erlang-otp-16B02-x86_64-1_SBo.tgz

UNIX server installation

• cd /opt

• wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.3.1/rabbitmq-server-generic-unix-3.3.1.tar.gz

• tar xvzf rabbitmq-server-generic-unix-3.3.1.tar.gz
• ln -s rabbitmq_server-3.3.1 rabbitmq
• /opt/rabbitmq/sbin/rabbitmq-server

Python client

• pip install pika # python client

Examples

http://www.rabbitmq.com/tutorials/tutorial-one-python.html

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
print ' [*] Waiting for messages. To exit press CTRL+C'

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)

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

channel.start_consuming()