def stop_consumer(self):
        """Stop the consumer object and allow it to do a clean shutdown if it
        has the ability to do so.

        """
        try:
            LOGGER.info('Shutting down the consumer')
            self.consumer.shutdown()
        except __HOLE__:
            LOGGER.debug('Consumer does not have a shutdown method')
dataset/ETHPy150Open gmr/rejected/rejected/process.py/Process.stop_consumer