return registration;
                } else {
                    String errorMsg = response != null ? response.getError() : "Response was null";
                    throw new IOException("Witness registration failed: " + errorMsg);
                }

            } catch (Exception e) {

                    
                    return registration;
                } else {
                    throw new IOException("Witness registration failed: " + response.getError());
                }
                
            } catch (Exception e) {
                log.error("Failed to register for witness notifications", e);
                throw new RuntimeException(e);
            }

        // Setup mock RPC response for failure
        WitnessRegisterResponse mockResponse = mock(WitnessRegisterResponse.class);
        when(mockResponse.isSuccess()).thenReturn(false);
        when(mockResponse.getError()).thenReturn("Registration failed");

        WitnessRpcClient mockRpc = mock(WitnessRpcClient.class);
        lenient().when(mockRpc.register(any(WitnessRegisterRequest.class))).thenReturn(mockResponse);

                response.setContextHandle(contextHandle);

                log.debug("Witness registration successful: {}", registrationId);
            } else {
                response.setError(message.getErrorMessage());
                log.warn("Witness registration failed: {}", message.getErrorMessage());
            }

            return response;

        } catch (Exception e) {

        }

        final SuggestDeleteResponse deleteResponse = deleteByQuery(boolQuery);
        if (deleteResponse.hasError()) {
            throw new SuggestIndexException(deleteResponse.getErrors().get(0));
        }

        final List<SuggestItem> updateItems = new ArrayList<>();
        SearchResponse response = client.prepareSearch(index)
                .setSize(500)

     */
    public boolean deleteAllWords() {
        final SuggestDeleteResponse response = suggester.indexer().deleteAll();
        if (response.hasError()) {
            logger.warn("Failed to delete all words.", response.getErrors().get(0));
            return false;
        }
        refresh();
        return true;
    }

    /**
     * Deletes all document-based words from the suggest index.
     *

                            }
                            return null;
                        }

                        final List<String> errors = auth.getErrors();
                        if (!errors.isEmpty()) {
                            logger.warn("{}", errors.stream().collect(Collectors.joining(", ")));

     */
    public long getRequestsReceived() {
        return requestsReceived.get();
    }

    /**
     * Get number of errors
     *
     * @return error count
     */
    public long getErrors() {
        return errors.get();
    }

    /**
     * Add bytes sent
     *
     * @param bytes number of bytes
     */
    public void addBytesSent(long bytes) {

    @Test
    public void test_indexFromSearchWord() throws Exception {
        SuggestIndexResponse indexResponse = suggester.indexer().indexFromSearchWord("検索　 エンジン", null, null, null, 1, null);
        indexResponse.getErrors();
        suggester.refresh();

        final SuggestResponse response = suggester.suggest().setQuery("検索").setSuggestDetail(true).execute().getResponse();
        final List<SuggestItem> items = response.getItems();