}

    @Override
    public synchronized void insert(final StopwordsItem item) {
        try (StopwordsUpdater updater = new StopwordsUpdater(item)) {
            reload(updater);
        }
    }

    @Override
    public synchronized void update(final StopwordsItem item) {
        try (StopwordsUpdater updater = new StopwordsUpdater(item)) {
            reload(updater);
        }
    }

        }

        try {
            metadata.storeInLocalRepository(localRepository, deploymentRepository);
        } catch (RepositoryMetadataStoreException e) {
            throw new RepositoryMetadataDeploymentException("Error installing metadata: " + e.getMessage(), e);
        }

        try {
            wagonManager.putArtifactMetadata(file, metadata, deploymentRepository);

    monitor.enter();
    try {
      return q.poll();
    } finally {
      monitor.leave();
    }
  }

  @CanIgnoreReturnValue // pushed down from class to method
  @Override
  public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {
    Monitor monitor = this.monitor;
    if (monitor.enterWhen(notEmpty, timeout, unit)) {
      try {
        return q.poll();

        int max = this.transportContext.getConfig().getWinsServers().length;

        if (max == 0) {
            max = 1; /* No WINs, try only bcast addr */
        }

        synchronized (response) {
            while (max-- > 0) {
                try {
                    synchronized (this.LOCK) {
                        request.nameTrnId = getNextNameTrnId();
                        nid = request.nameTrnId;

    public void test_rethrow() {
        // Test rethrowing the exception
        DictionaryExpiredException originalException = null;
        DictionaryExpiredException rethrownException = null;

        try {
            try {
                throw new DictionaryExpiredException();
            } catch (DictionaryExpiredException e) {
                originalException = e;
                throw e;
            }

            if (log.isDebugEnabled()) {
                log.debug("Trying address {}", addr);
            }
            try (SmbTransportImpl trans = getSmbTransport(tf, addr, port, exclusive, forceSigning).unwrap(SmbTransportImpl.class)) {
                try {
                    trans.ensureConnected();
                } catch (final IOException e) {
                    removeTransport(trans);

    // This class can make no hard guarantees.  The methods in this class are inherently flaky, but
    // we try hard to make them robust in practice.  We could additionally try to add in a system
    // load timeout multiplier.  Or we could try to use a CPU time bound instead of wall clock time
    // bound.  But these ideas are harder to implement.  We do not try to detect or handle a
    // user-specified -XX:+DisableExplicitGC.
    //

        assertNull(result);
    }

    @Test
    void testGetByNameWithValidEntry() throws IOException {
        // Create a temporary lmhosts file
        File lmhostsFile = tempDir.resolve("lmhosts").toFile();
        try (FileWriter writer = new FileWriter(lmhostsFile)) {
            writer.write("192.168.1.100 TESTHOST\n");
            writer.write("10.0.0.1      SERVER01\n");
        }

        final ZipEntry entry = new ZipEntry(id + "/es_" + v1 + "_" + v2 + ".json");
        try {
            zos.putNextEntry(entry);
            try (CurlResponse response = ComponentUtil.getCurlHelper().get("/_" + v1 + "/" + v2).execute()) {
                CopyUtil.copy(response.getContentAsStream(), zos);
            }

    }

    @Override
    public synchronized void insert(final StemmerOverrideItem item) {
        try (StemmerOverrideUpdater updater = new StemmerOverrideUpdater(item)) {
            reload(updater);
        }
    }

    @Override
    public synchronized void update(final StemmerOverrideItem item) {
        try (StemmerOverrideUpdater updater = new StemmerOverrideUpdater(item)) {
            reload(updater);
        }