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

All Samples(5)  |  Call(4)  |  Derive(0)  |  Import(1)

src/c/a/captain-HEAD/vendor/lib/python/pika/adapters/blocking_connection.py   captain(Download)
                self._socket_timeouts = 0
        except AttributeError:
            raise exceptions.ConnectionClosed()
        except socket.timeout:
            self._handle_timeout()
        self._remove_connection_callbacks()
        if self.closing[0] not in [0, 200]:
            raise exceptions.ConnectionClosed(*self.closing)
 
    def _send_frame(self, frame_value):

src/p/i/pika-0.9.13/pika/adapters/blocking_connection.py   pika(Download)
                self._socket_timeouts = 0
        except AttributeError:
            raise exceptions.ConnectionClosed()
        except socket.timeout:
            self._handle_timeout()
        self._remove_connection_callbacks()
        if self.closing[0] not in [0, 200]:
            raise exceptions.ConnectionClosed(*self.closing)
 
    def _send_frame(self, frame_value):

src/s/y/synaps-HEAD/synaps/rpc/__init__.py   synaps(Download)
import uuid, time
import pika, json
from pika.exceptions import (ConnectionClosed, AMQPConnectionError, 
                             AMQPChannelError)