code: def next(self):
          
          if self.blocking >= 0:
              # returns queue name and item, we just need item
              res = self.redis.blpop([self.name], timeout=self.blocking)
              if res:
                  res = res[1]
          else:
              res = self.redis.lpop(self.name)
          value = self.deserialize(res)
          logger.debug('Popped from "%s": %s', self.name, repr(value))
          return value
docs: Retrieve the next item in the queue.
  
          Returns deserialized value, or None if there were no entries
          in the Queue.