def __init__(self, host='localhost', port=5672, ssl=None, connect_timeout=None,
                 userid='guest', password='guest', login_method='AMQPLAIN', virtual_host='/',
                 locale='en_US',
                 channel_max=65535, frame_max=131072,
                 heartbeat=0,
                 client_properties=None,
                 on_blocked=None, on_unblocked=None):
        log.debug('amqpy {} Connection.__init__()'.format(__version__))
        #: Map of `{channel_id: Channel}` for all active channels
        #:
        #: :type: dict[int, Channel]
        self.channels = {}  # dict of {channel_id int: Channel}

        # the connection object itself is treated as channel 0
        super(Connection, self).__init__(self, 0)  # also sets channels[0] = self

        # instance variables
        #: :type: amqpy.transport.Transport
        self.transport = None
        self.method_reader = None
        self.method_writer = None
        self._wait_tune_ok = None

        # properties set in the start method, after a connection is established
        self.version_major = 0
        self.version_minor = 0
        self.server_properties = {}
        self.mechanisms = []
        self.locales = []

        # properties set in the Tune method
        self.channel_max = channel_max
        self.frame_max = frame_max
        if six.PY2:
            self._avail_channel_ids = array(b'H', range(self.channel_max, 0, -1))
        else:
            self._avail_channel_ids = array('H', range(self.channel_max, 0, -1))
        self._heartbeat_final = 0  # final heartbeat interval after negotiation
        self._heartbeat_server = None

        # save connection parameters
        self._host = host
        self._port = port
        self._connect_timeout = connect_timeout
        self._ssl = ssl
        self._userid = userid
        self._password = password
        self._login_method = login_method
        self._virtual_host = virtual_host
        self._locale = locale
        self._heartbeat_client = heartbeat  # original heartbeat interval value proposed by client
        self._client_properties = client_properties

        # callbacks
        self.on_blocked = on_blocked
        self.on_unblocked = on_unblocked

        # heartbeat
        self._close_event = Event()
        self._heartbeat_thread = None

        self.connect()
Select an appender and append the content to parent.
dataset/ETHPy150Open veegee/amqpy/amqpy/connection.py/Connection.__init__--crossover with--dataset/ETHPy150Open CouchPotato/CouchPotatoServer/libs/suds/mx/appender.py/ContentAppender.append