public void publish(String topic, Object msg) throws SubscriberUnAvailableException {
            broadcast(topic, msg);
        }
Subscriber interface to be implemented to subscribe to in-memory broker.
modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/InMemoryBroker.java