public void onError(ConnectionUnavailableException e) {
            disconnectSource();
            isConnected.set(false);
            retryWithBackoff(e);
        }
Callback class used to pass connection exception during message retrieval
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/Source.java