def __init__(self, name, ip, user, password, pqueue=None,<EOL>c_pri=<NUM_LIT:100>, d_pri=<NUM_LIT:100>):
<EOL>self._server_ip = ip<EOL>self._user = user<EOL>self._pwd = password<EOL>self._pq = pqueue<EOL>self._create_pri = c_pri<EOL>self._delete_pri = d_pri<EOL>self._port = <NUM_LIT><EOL>self._dcnm_exchange_name = '<STR_LIT>'<EOL>self._dcnm_queue_name = socket.gethostname()<EOL>key = ('<STR_LIT>'<EOL>'<STR_LIT>')<EOL>self._conn = None<EOL>self.consume_channel = None<EOL>try:<EOL><INDENT>credentials = None<EOL>if self._user:<EOL><INDENT>credentials = pika.PlainCredentials(self._user, self._pwd)<EOL><DEDENT>self._conn = pika.BlockingConnection(<EOL>pika.ConnectionParameters(<EOL>host=self._server_ip,<EOL>port=self._port,<EOL>credentials=credentials))<EOL>self.consume_channel = self._conn.channel()<EOL>self.consume_channel.exchange_declare(<EOL>exchange=self._dcnm_exchange_name,<EOL>exchange_type='<STR_LIT>',<EOL>durable=True,<EOL>auto_delete=False)<EOL>result = self.consume_channel.queue_declare(<EOL>queue=self._dcnm_queue_name,<EOL>durable=True,<EOL>auto_delete=False)<EOL>self._dcnm_queue_name = result.method.queue<EOL>self.consume_channel.queue_bind(exchange=self._dcnm_exchange_name,<EOL>queue=self._dcnm_queue_name,<EOL>routing_key=key)<EOL>msg_count = result.method.message_count<EOL>LOG.debug('<STR_LIT>'<EOL>'<STR_LIT>',<EOL>{'<STR_LIT>': self._dcnm_exchange_name,<EOL>'<STR_LIT>': self._dcnm_queue_name, '<STR_LIT>': msg_count})<EOL>LOG.debug('<STR_LIT>')<EOL><DEDENT>except Exception as ex:<EOL><INDENT>LOG.exception('<STR_LIT>', ex)<EOL><DEDENT>
Create a new instance of AMQP client.

        :param dict params: AMQP configuration parameters,
         e.g. AMQP server ip, port, user name, password, name of AMQP
         exchange and queue for DCNM notification.