test.py

import pika
from pika.adapters import TwistedConnection

from twisted.internet import task


def ok(ret):
    print "published"
    return ret


def ko(f):
    print "FAILED", f


def publish(channel):
    d = channel.basic_publish('exchange', '1', 'foo')
    return d.addCallback(ok).addErrback(ko)


def start_publishing(channel):
    print "channel open"
    lc = task.LoopingCall(publish, channel)
    lc.start(1)


def start(conn):
    print "connected"
    return conn.channel().addCallback(start_publishing)


params = pika.ConnectionParameters()
conn = TwistedConnection(params, start)

conn.ioloop.start()