def _setup(self):
self._close_sockets()<EOL>create_n_conn = self._socket_factory.create_n_connect<EOL>control_address = self.config['<STR_LIT>']<EOL>publish_address = self.config['<STR_LIT>']<EOL>request_address = self.config['<STR_LIT>']<EOL>command_address = self.config['<STR_LIT>']<EOL>self._messaging_logger.control.info('<STR_LIT>', control_address)<EOL>self.control_socket = create_n_conn(zmq.ROUTER,<EOL>control_address,<EOL>on_error='<STR_LIT>',<EOL>bind=True,<EOL>socket_name='<STR_LIT>')<EOL>self._messaging_logger.publish.info('<STR_LIT>', publish_address)<EOL>self.publish_socket = create_n_conn(zmq.XSUB,<EOL>publish_address,<EOL>bind=True,<EOL>on_error='<STR_LIT>',<EOL>socket_name='<STR_LIT>')<EOL>self._messaging_logger.command.info('<STR_LIT>', command_address)<EOL>self.command_socket = create_n_conn(zmq.ROUTER,<EOL>command_address,<EOL>bind=True)<EOL>self._messaging_logger.request.info('<STR_LIT>', request_address)<EOL>self.request_socket = create_n_conn(zmq.DEALER,<EOL>request_address,<EOL>bind=True,<EOL>socket_name='<STR_LIT>')<EOL>self._setup_subscription_socket()<EOL>self._setup_scheduler()<EOL>
starts/instantiates the messaging