base/common/src/main/com/thesett/common/util/queues/WrapperQueue.java
public E take() throws InterruptedException
    {
        if (!isBlockingQueue)
        {
            throw new UnsupportedOperationException("This operation is only supported on blocking queues.");
        }

        return ((java.util.concurrent.BlockingQueue<E>) queue).take();
    }
public E take() throws InterruptedException
    {
        if (!isBlockingQueue)
        {
            throw new UnsupportedOperationException("This operation is only supported on blocking queues.");
        }

        return ((java.util.concurrent.BlockingQueue<E>) queue).take();
    }
{@inheritDoc}