def _process(self, metric):
        """
        We skip any locking code due to the fact that this is now a single
        process per collector
        """
        try:
            self.queue.put(metric, block=False)
        except Queue.Full:
            self._throttle_error('Queue full, check handlers for delays')

        We skip any locking code due to the fact that this is now a single
        process per collector
        
src/diamond/handler/queue.py