Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(2)  |  Call(0)  |  Derive(2)  |  Import(0)
A hybrid between a Pika Connection and a Twisted Protocol. Allows using
Twisted's non-blocking connectTCP/connectSSL methods for connecting to the
server.

It has one caveat: TwistedProtocolConnection objects have a ready
instance variable that's a Deferred which fires when the connection is
ready to be used (the initial AMQP handshaking has been done). You *have*
to wait for this Deferred to fire before requesting a channel.

Since it's Twisted handling connection establishing it does not accept(more...)

src/p/i/Piped-HEAD/contrib/amqp/piped_amqp/providers.py   Piped(Download)
class AMQProtocol(twisted_connection.TwistedProtocolConnection):
    """ The AMQP protocol used by Piped. """
 
    def __init__(self, parameters):
        super(AMQProtocol, self).__init__(parameters)

src/p/i/piped.contrib.amqp-0.4.0/piped_amqp/providers.py   piped.contrib.amqp(Download)
class AMQProtocol(twisted_connection.TwistedProtocolConnection):
    """ The AMQP protocol used by Piped. """
 
    def __init__(self, parameters):
        super(AMQProtocol, self).__init__(parameters)