@Override
    public Class[] getSupportedInputEventClasses() {
        return transports.get(0).getSupportedInputEventClasses();
    }
This is the distributed transport to publish to multiple endpoints using client/publisher for each endpoint. There
will be a separate independent {@link Sink} instance connecting to each destination. This class interacts
with Sink interface and it does not make any assumptions on the underlying transport implementation.
modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/MultiClientDistributedSink.java