private void findLock()

in spi/src/main/java/org/opensearch/jobscheduler/spi/utils/LockService.java [224:248]

25 lines of code
3 McCabe index (conditional complexity)


    private void findLock(final String lockId, ActionListener<LockModel> listener) {
        GetRequest getRequest = new GetRequest(LOCK_INDEX_NAME).id(lockId);
        client.get(getRequest, ActionListener.wrap(
                response -> {
                    if (!response.isExists()) {
                        listener.onResponse(null);
                    } else {
                        try {
                            XContentParser parser = XContentType.JSON.xContent()
                                    .createParser(NamedXContentRegistry.EMPTY, LoggingDeprecationHandler.INSTANCE,
                                            response.getSourceAsString());
                            parser.nextToken();
                            listener.onResponse(LockModel.parse(parser, response.getSeqNo(), response.getPrimaryTerm()));
                        } catch (IOException e) {
                            logger.error("IOException occurred finding lock", e);
                            listener.onResponse(null);
                        }
                    }
                },
                exception -> {
                    logger.error("Exception occurred finding lock", exception);
                    listener.onFailure(exception);
                }
        ));
    }