@Override
    public void publish(Object payload, DynamicOptions dynamicOptions, State s) throws ConnectionUnavailableException {
        try {
            InMemoryBroker.publish(topicOption.getValue(dynamicOptions), payload);
        } catch (SubscriberUnAvailableException e) {
            onError(payload, dynamicOptions, new ConnectionUnavailableException(e.getMessage(), e));
        }
    }
Implementation of {@link Sink} which represents in-memory transport. This implementation can send incoming objects
to in-memory transport within JVM.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/sink/InMemorySink.java