amqp_send.py # vim: fileencoding=utf8 from amqplib import client_0_8 as amqp kUserId = 'guest' kPassword = 'guest' kHost = 'dev.rabbitmq.com' def main(): message_body = u'あいうえお' connection = amqp.Connection(kHost, userid=kUserId, password=kPassword, ssl=False) channel = connection.channel() channel.access_request('/data', active=True, write=True) channel.exchange_declare('myfan', 'fanout', auto_de