@Override
    public void disconnect() {
        transports.forEach(Sink::disconnect);
    }
Will be called after all publishing is done, or when ConnectionUnavailableException is thrown
modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/MultiClientDistributedSink.java