code: def _bind(self):
          
  
          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)
          self.channel = self.connection.channel()
  
          # NOTE : PIKA version uses 'exchange_type' instead of 'type'
  
          self.channel.exchange_declare(exchange=self.topic_exchange,
                                        exchange_type="topic")
docs: Create  socket and bind