

def _bind(self):
    '\n           Create  socket and bind\n        '
    credentials = pika.PlainCredentials(self.user, self.password)
    params = pika.ConnectionParameters(credentials=credentials, host=self.server, virtual_host=self.vhost, port=self.port)
    self.connection = pika.BlockingConnection(params)
    params.channel = self.connection.channel()
    self.channel.exchange_declare(exchange=self.topic_exchange, exchange_type='topic')

dataset/ETHPy150Open BrightcoveOS/Diamond/src/diamond/handler/rabbitmq_topic.py rmqHandler._bind/VarMisuse@67/91 `self`->`params`