public Publisher constructPublisher() {
        Publisher publisher = new Publisher();
        publisher.setStreamJunction(this);
        publishers.add(publisher);
        return publisher;
    }
Create and start disruptor based on annotations given in the streamDefinition.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/StreamJunction.java