(self)
Create  socket and bind
Create  socket and bind
Create socket and bind
def _bind(self):
        """
           Create  socket and bind
        """

        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")
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" )