@Override
    public void resume() {
        paused = false;
        try {
            pauseLock.lock();
            unpaused.signalAll();
        } finally {
            pauseLock.unlock();
        }
    }
Implementation of {@link Source} to receive events through in-memory transport.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/InMemorySource.java