'batch_size is the maximum number of work items per scheduling
priority is the Task priority'

def __init__(self, batch_size=1, priority=1, start=True):

    self.queue = deque()
    self.running = True
    self.log = log
    super(BaseConsumer, self).__init__()
    self.priority = priority
    self.batch_size = batch_size
    if start:
        self.start()
