@Override
    public void disconnect() {
        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/SingleClientDistributedSink.java