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

All Samples(9)  |  Call(9)  |  Derive(0)  |  Import(0)
AMQP Protocol header frame class which provides a pythonic interface
for creating AMQP Protocol headers

src/p/i/pika-HEAD/pika/connection.py   pika(Download)
        if (value.method.version_major,
            value.method.version_minor) != spec.PROTOCOL_VERSION[0:2]:
            raise exceptions.ProtocolVersionMismatch(frame.ProtocolHeader(),
                                                     value)
 
 
        # Start the communication with the RabbitMQ Broker
        self._send_frame(frame.ProtocolHeader())
 
    def _on_connection_closed(self, method_frame, from_adapter=False):

src/c/a/captain-HEAD/vendor/lib/python/pika/connection.py   captain(Download)
        if (value.method.version_major,
            value.method.version_minor) != spec.PROTOCOL_VERSION[0:2]:
            raise exceptions.ProtocolVersionMismatch(frame.ProtocolHeader(),
                                                     value)
 
 
        # Start the communication with the RabbitMQ Broker
        self._send_frame(frame.ProtocolHeader())
 
    def _on_connection_closed(self, method_frame, from_adapter=False):

src/o/p/openquake-packages-HEAD/pika-0.9.5/pika/connection.py   openquake-packages(Download)
        """
        # Start the communication with the RabbitMQ Broker
        self._send_frame(pika.frame.ProtocolHeader())
 
        # Let our reconnection_strategy know we're connected
        if (frame.method.version_major,
            frame.method.version_minor) != spec.PROTOCOL_VERSION[0:2]:
            raise ProtocolVersionMismatch(pika.frame.ProtocolHeader(), frame)
 
        # Get our server properties for use elsewhere

src/p/i/pika-0.9.13/pika/connection.py   pika(Download)
        if (value.method.version_major,
            value.method.version_minor) != spec.PROTOCOL_VERSION[0:2]:
            raise exceptions.ProtocolVersionMismatch(frame.ProtocolHeader(),
                                                     value)
 
 
        # Start the communication with the RabbitMQ Broker
        self._send_frame(frame.ProtocolHeader())
 
    def _on_connection_closed(self, method_frame, from_adapter=False):

src/p/i/pika-HEAD/tests/frame_tests.py   pika(Download)
    def protocol_header_marshal_test(self):
        protocol_header = frame.ProtocolHeader()
        self.assertEqual(protocol_header.marshal(), self.PROTOCOL_HEADER)
 
    def decode_protocol_header_instance_test(self):