public static void publish(String topic, Object message) throws SubscriberUnAvailableException {
        broker.publish(topic, message);
    }
In-memory broker to support in-memory transport.
modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/InMemoryBroker.java