import logging
import multiprocessing

try:
    from setproctitle import setproctitle
except ImportError:
    def setproctitle(title):
        pass

try:
    import queue
except ImportError:
    import Queue as queue


log = logging.getLogger(__name__)


class Processor(multiprocessing.Process):
    def __init__(self, in_queue, out_queue, cfg):
        super(Processor, self).__init__()
        self.daemon = True
        self.in_queue = in_queue
        self.out_queue = out_queue
        self.drop_on_error = cfg.processor_drop_on_error

    def run(self):
        setproctitle("bucky: %s" % self.__class__.__name__)
        while True:
            try:
                sample = self.in_queue.get(True, 1)
                if not sample:
                    break
            except queue.Empty:
                pass
            else:
                try:
                    sample = self.process(*sample)
                except Exception as exc:
                    log.error("Error processing sample %s: %r", sample, exc)
                    if self.drop_on_error:
                        sample = None
                if sample is not None:
                    self.out_queue.put(sample)

    def process(self, host, name, val, time):
        raise NotImplementedError


class CustomProcessor(Processor):
    def __init__(self, in_queue, out_queue, cfg):
        super(CustomProcessor, self).__init__(in_queue, out_queue, cfg)
        self.function = cfg.processor

    def process(self, host, name, val, time):
        return self.function(host, name, val, time)

@@ -1268,16 +1268,18 @@
 tedError
+()
 %0A%0A%0Aclass

Raise NotImplementedError properly in processor