public void setStreamId(String streamId) {
        this.streamId = streamId;
    }
StreamCallback is used to receive events from {@link StreamJunction}. This class should be extended if one intends
to get events from a Siddhi Stream.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/StreamCallback.java