@Override
    public void connect() throws ConnectionUnavailableException {
        sink.connectWithRetry();
    }
Will be called to connect to the backend before events are published

@throws ConnectionUnavailableException if it cannot connect to the backend
modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/SingleClientDistributedSink.java