'Locks and gets an entry from the queue. If a previously got entry
was not consumed, this method will return that entry.
:param timeout:
Maximum waiting time in seconds. If None then it will wait
untill an entry appears in the queue.
:returns: A locked entry value or None if the timeout was reached.
:rtype: bytes'

def get(self, timeout=None):

    self._ensure_paths()
    if (not (self.processing_element is None)):
        return self.processing_element[1]
    else:
        return self._inner_get(timeout)
