public void unsubscribe(StreamCallback streamCallback) {
        List<Receiver> newReceivers = new LinkedList<>(receivers);
        newReceivers.remove(streamCallback);
        receivers = newReceivers;
    }
Create and start disruptor based on annotations given in the streamDefinition.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/StreamJunction.java