Module ImportFrom alias alias alias alias Assign NameStore NameLoad Import alias Import alias Import alias Import alias ImportFrom alias alias Import alias ImportFrom alias ImportFrom alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Assign NameStore Set AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Str ClassDef bases body Assign NameStore NameLoad Expr Str Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr NameLoad Assign NameStore NameLoad For NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Num AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign TupleStore NameStore NameStore NameStore NameStore NameStore NameLoad TryExcept body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Break handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr NameLoad Assign NameStore NameLoad If UnaryOpNot AttributeLoad NameLoad attr body Raise Call AttributeLoad NameLoad attr NameLoad TryExcept body Assert Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type TupleLoad NameLoad NameLoad AttributeLoad NameLoad attr name NameStore body If CompareNotIn Call NameLoad NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Raise Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body TryFinally body If CompareIsNot NameLoad NameLoad body TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler body Pass finalbody Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call NameLoad AttributeLoad NameLoad attr Assign NameStore NameLoad While NameLoad body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Assign NameStore SubscriptLoad NameLoad Slice NameLoad AugAssignSub NameStore NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body If BoolOpAnd UnaryOpNot NameLoad CompareIn AttributeLoad NameLoad attr NameLoad body Continue Raise If UnaryOpNot NameLoad body Raise Call NameLoad Str Return SubscriptLoad Call NameLoad AttributeLoad NameLoad attr Slice NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam defaults body If CompareIsNot AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad TryExcept body Assign NameStore Call AttributeLoad NameLoad attr Num NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr NameLoad orelse Assign NameStore Call AttributeLoad NameLoad attr Call NameLoad NameLoad handlers ExceptHandler type TupleLoad NameLoad NameLoad AttributeLoad NameLoad attr name NameStore body If BoolOpAnd Call NameLoad NameLoad NameLoad CompareIn Str Call NameLoad NameLoad body Raise Call AttributeLoad NameLoad attr If BoolOpAnd CompareNotIn Call NameLoad NameLoad NameLoad UnaryOpNot Call NameLoad NameLoad AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad Raise If CompareEq NameLoad AttributeLoad NameLoad attr body If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Return NameLoad orelse Raise Call NameLoad Call AttributeLoad Str attr Call NameLoad NameLoad decorator_list Call NameLoad Str FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body Raise ExceptHandler type TupleLoad NameLoad NameLoad AttributeLoad NameLoad attr name NameStore body If CompareNotIn Call NameLoad NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Raise decorator_list Call NameLoad Str FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Return NameLoad If UnaryOpNot AttributeLoad NameLoad attr body Return NameLoad TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body Return NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Return Call AttributeLoad NameLoad attr NameLoad NameLoad keyword TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Raise Call NameLoad Str orelse While NameLoad body Assign NameStore Call NameLoad NameLoad If UnaryOpNot NameLoad body Raise Call NameLoad Str Assign NameStore SubscriptLoad NameLoad Slice NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Return Call AttributeLoad NameLoad attr NameLoad NameLoad keyword TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str If Call NameLoad NameLoad NameLoad body Return Call NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad orelse Return Call NameLoad NameLoad NameLoad NameLoad NameLoad decorator_list
N/A __future__ absolute_import division print_function unicode_literals N/A __metaclass__ type N/A errno N/A six N/A socket N/A ssl abc ABCMeta abstractmethod N/A logging threading RLock ssl SSLError N/A datetime N/A time N/A compat proto Frame concurrency synchronized exceptions UnexpectedFrame utils get_errno spec FrameType N/A log N/A N/A logging getLogger amqpy N/A N/A N/A compat patch N/A _UNAVAIL N/A N/A errno EAGAIN N/A errno EINTR N/A errno ENOENT N/A AMQP_PROTOCOL_HEADER AMQP	 Transport N/A N/A N/A __metaclass__ ABCMeta N/A Common superclass for TCP and SSL transports N/A connected False __init__ N/A N/A self host port connect_timeout buf_size N/A N/A N/A 
        :param host: hostname or IP address
        :param port: port
        :param connect_timeout: connect timeout
        :type host: str
        :type port: int
        :type connect_timeout: float or None
         N/A N/A self _rbuf N/A bytearray buf_size N/A N/A self last_heartbeat_sent None N/A N/A self last_heartbeat_received None N/A N/A self last_heartbeat_sent_monotonic 0.0 N/A N/A self _frame_write_lock N/A RLock N/A N/A self _frame_read_lock N/A RLock N/A N/A self sock None N/A last_err None N/A res N/A N/A socket getaddrinfo host port 0 N/A socket SOCK_STREAM N/A socket IPPROTO_TCP N/A N/A N/A af socktype proto canonname sa res N/A N/A N/A N/A self sock N/A N/A socket socket af socktype proto N/A N/A N/A N/A self sock settimeout connect_timeout N/A N/A N/A N/A self sock connect sa N/A N/A N/A N/A N/A socket error N/A exc N/A N/A N/A N/A N/A self sock close N/A N/A self sock None N/A last_err exc N/A N/A N/A self sock N/A N/A N/A N/A socket error last_err N/A N/A N/A N/A isinstance N/A self sock N/A socket socket N/A N/A N/A N/A self sock settimeout None N/A N/A N/A N/A self sock setsockopt N/A socket IPPROTO_TCP N/A socket TCP_NODELAY 1 N/A N/A N/A N/A self sock setsockopt N/A socket SOL_SOCKET N/A socket SO_KEEPALIVE 1 N/A N/A N/A self _setup_transport N/A N/A N/A self write AMQP_PROTOCOL_HEADER N/A N/A N/A N/A OSError IOError N/A socket error N/A exc N/A N/A N/A N/A get_errno exc _UNAVAIL N/A N/A N/A self connected False N/A N/A N/A self connected True N/A __del__ N/A N/A self N/A N/A N/A N/A N/A N/A socket None N/A N/A N/A N/A N/A N/A self close N/A N/A N/A N/A N/A N/A N/A self sock None N/A _read N/A N/A self n initial _errnos N/A N/A N/A Read from socket

        This is the default implementation. Subclasses may implement `read()` to simply call this
        method, or provide their own `read()` implementation.

        Note: According to SSL_read(3), it can at most return 16kB of data. Thus, we use an internal
        read buffer like to get the exact number of bytes wanted.

        Note: ssl.sock.read may cause ENOENT if the operation couldn't be performed (?).

        :param int n: exact number of bytes to read
        :return: data read
        :rtype: memoryview
         N/A mview N/A memoryview N/A self _rbuf N/A to_read n N/A to_read N/A N/A N/A N/A bytes_read N/A N/A N/A self sock recv_into mview to_read N/A mview N/A mview N/A bytes_read N/A to_read bytes_read N/A N/A N/A N/A socket error N/A exc N/A N/A N/A N/A initial N/A N/A exc errno _errnos N/A N/A N/A N/A N/A bytes_read N/A N/A N/A IOError socket closed N/A N/A N/A memoryview N/A self _rbuf N/A n N/A read N/A N/A self n initial N/A False N/A N/A Read exactly `n` bytes from the peer

        :param n: number of bytes to read
        :type n: int
        :return: data read
        :rtype: bytes
         N/A N/A abstractmethod write N/A N/A self s N/A N/A N/A Completely write a string to the peer
         N/A abstractmethod _setup_transport N/A N/A self N/A N/A N/A Do any additional initialization of the class (used by the subclasses)
         N/A N/A close N/A N/A self N/A N/A N/A N/A N/A self sock None N/A N/A N/A N/A N/A self sock shutdown N/A socket SHUT_RDWR N/A N/A N/A N/A self sock close N/A N/A self sock None N/A N/A self connected False N/A read_frame N/A N/A self N/A N/A N/A Read frame from connection

        Note that the frame may be destined for any channel. It is permitted to interleave frames
        from different channels.

        :return: frame
        :rtype: amqpy.proto.Frame
         N/A frame N/A Frame N/A N/A N/A frame_header N/A N/A self read 7 True N/A N/A N/A N/A frame data extend frame_header N/A payload N/A N/A self read N/A frame payload_size N/A N/A N/A N/A frame data extend payload N/A frame_terminator N/A N/A self read 1 N/A N/A N/A N/A frame data extend frame_terminator N/A N/A six PY2 N/A N/A i_last_byte N/A N/A six byte2int frame_terminator N/A N/A i_last_byte N/A N/A six byte2int N/A bytes frame_terminator N/A N/A N/A N/A OSError IOError N/A socket error N/A exc N/A N/A N/A N/A isinstance exc SSLError N/A timed out N/A str exc N/A N/A N/A N/A socket timeout N/A N/A N/A N/A get_errno exc _UNAVAIL N/A N/A isinstance exc N/A socket timeout N/A N/A N/A self connected False N/A N/A N/A i_last_byte N/A FrameType END N/A N/A N/A N/A frame frame_type N/A FrameType HEARTBEAT N/A N/A N/A self last_heartbeat_received N/A N/A N/A datetime datetime now N/A frame N/A N/A N/A UnexpectedFrame N/A N/A Received {} while expecting 0xce (FrameType.END) format N/A hex i_last_byte N/A N/A synchronized _frame_read_lock write_frame N/A N/A self frame N/A N/A N/A Write frame to connection

        Note that the frame may be destined for any channel. It is permitted to interleave frames
        from different channels.

        :param frame: frame
        :type frame: amqpy.proto.Frame
         N/A N/A N/A N/A N/A self write N/A frame data N/A N/A N/A N/A socket timeout N/A N/A N/A N/A N/A OSError IOError N/A socket error N/A exc N/A N/A N/A N/A get_errno exc _UNAVAIL N/A N/A N/A self connected False N/A N/A N/A synchronized _frame_write_lock send_heartbeat N/A N/A self N/A N/A N/A Send a heartbeat to the server
         N/A N/A self last_heartbeat_sent N/A N/A N/A datetime datetime now N/A N/A self last_heartbeat_sent_monotonic N/A N/A time monotonic N/A N/A N/A self write_frame N/A Frame N/A FrameType HEARTBEAT N/A is_alive N/A N/A self N/A N/A N/A Check if connection is alive

        This method is the primary way to check if the connection is alive.

        Side effects: This method may send a heartbeat as a last resort to check if the connection
        is alive.

        :return: True if connection is alive, else False
        :rtype: bool
         N/A N/A N/A self sock N/A N/A False N/A N/A N/A self connected N/A N/A False N/A N/A N/A N/A N/A self send_heartbeat N/A N/A N/A N/A socket error N/A N/A False N/A True N/A N/A SSLTransport N/A Transport N/A N/A Transport that works over SSL
     __init__ N/A N/A self host port connect_timeout frame_max ssl_opts N/A N/A N/A N/A self ssl_opts ssl_opts N/A N/A N/A N/A super SSLTransport self __init__ host port connect_timeout frame_max N/A _setup_transport N/A N/A self N/A N/A N/A Wrap the socket in an SSL object
         N/A N/A self sock N/A N/A ssl wrap_socket N/A self sock N/A self ssl_opts N/A read N/A N/A self n initial N/A False N/A N/A Read from socket

        According to SSL_read(3), it can at most return 16kb of data. Thus, we use an internal read
        buffer like `TCPTransport.read()` to get the exact number of bytes wanted.

        :param int n: exact number of bytes to read
        :return: data read
        :rtype: bytes
         N/A N/A N/A self _read n initial _errnos N/A N/A errno ENOENT N/A errno EAGAIN N/A errno EINTR N/A write N/A N/A self s N/A N/A N/A Write a string out to the SSL socket fully
         N/A N/A N/A write N/A N/A self sock write N/A N/A N/A AttributeError N/A N/A N/A IOError Socket closed N/A N/A s N/A N/A n N/A write s N/A N/A n N/A N/A N/A IOError Socket closed N/A s N/A s N/A n N/A N/A TCPTransport N/A Transport N/A N/A Transport that deals directly with TCP socket
     read N/A N/A self n initial N/A False N/A N/A Read exactly n bytes from the socket

        :param int n: exact number of bytes to read
        :return: data read
        :rtype: bytes
         N/A N/A N/A self _read n initial _errnos N/A N/A errno EAGAIN N/A errno EINTR N/A write N/A N/A self s N/A N/A N/A N/A N/A N/A self sock sendall s N/A N/A create_transport N/A N/A host port connect_timeout frame_max ssl_opts N/A None N/A N/A Given a few parameters from the Connection constructor, select and create a subclass of
    Transport

    If `ssl_opts` is a dict, SSL will be used and `ssl_opts` will be passed to
    :func:`ssl.wrap_socket()`. In all other cases, SSL will not be used.

    :param host: host
    :param connect_timeout: connect timeout
    :param ssl_opts: ssl options passed to :func:`ssl.wrap_socket()`
    :type host: str
    :type connect_timeout: float or None
    :type ssl_opts: dict or None
     N/A N/A isinstance ssl_opts dict N/A N/A N/A SSLTransport host port connect_timeout frame_max ssl_opts N/A N/A N/A TCPTransport host port connect_timeout frame_max N/A