Test librabbitmq: https://github.com/rapyuta-robotics/librabbitmq

pub.py

from librabbitmq import Connection

conn = Connection(
    host='<host>:443',
    userid='<userid>',
    password='<password>',
    virtual_host='/',
    ssl={
        'server_hostname': '<host>'
    },
)


channel = conn.channel()
channel.exchange_declare(exchange='exch')
result = channel.queue_declare(queue='')
channel.queue_bind(queue=result.queue, exchange='exch', routing_key='')
channel.basic_publish(exchange='exch', routing_key='', body='body msg')
conn.close()

sub.py

from librabbitmq import Connection

conn = Connection(
    host='<host>:443',
    userid='<userid>',
    password='<password>',
    virtual_host='/',
    ssl={
        'server_hostname': '<host>'
    },
)


channel = conn.channel()
channel.exchange_declare(exchange='exch')
result = channel.queue_declare(queue='')
channel.queue_bind(queue=result.queue, exchange='exch', routing_key='')


def callback(message):
    print("Body:'%s', Properties:'%s', DeliveryInfo:'%s'" % (
          message.body.tobytes(), message.properties, message.delivery_info))


channel.basic_consume(queue=result.queue, callback=callback)

print 'loop'
conn.drain_events()
conn.close()