postcard.setClusterstatus(ping.getClusterStatus());
                    });
                } catch (final Exception e) {
                    logger.warn("Failed to send a test mail.", e);
                } finally {
                    SMailCallbackContext.clearPreparedMessageHookOnThread();
                }
            }
            resultBuf.append("Status of ")

                    httpEntity = response.getEntity();
                    consumer.accept(response, httpEntity);
                } catch (final Exception e) {
                    logger.warn("Failed to authenticate with form-based authentication: scheme={}, url={}", scheme, request.getRequestUri(),
                            e);
                } finally {
                    try {

                    updateMethod.setAccessible(true);
                    updateMethod.invoke(transport, testData);
                } catch (Exception e) {
                    fail("Thread failed: " + e.getMessage());
                } finally {
                    doneLatch.countDown();
                }
            });
        }

        // Start all threads at once

        // Mock transport.connect() to succeed
        doNothing().when(transport).connect();

        // Simulate failed tree connect
        doThrow(new SmbException("Connection failed")).when(session).send(any(ServerMessageBlock.class), any(ServerMessageBlock.class));

        assertThrows(SmbException.class, () -> tree.treeConnect(null, null));

        when(delegate.hasNext()).thenReturn(false);
        doThrow(new CIFSException("Close failed")).when(delegate).close();

        TestIterator iterator = new TestIterator(null);

        CIFSException ex = assertThrows(CIFSException.class, iterator::close);
        assertEquals("Close failed", ex.getMessage());
    }

    @Test
    @DisplayName("Remove delegates to underlying iterator")

            try {
                fileConfigService.store(entity);
                saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL));
            } catch (final Exception e) {
                logger.warn("Failed to process a request.", e);
                throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)),
                        this::asEditHtml);
            }

    client.newCall(Request(url)).enqueue(
      object : Callback {
        override fun onFailure(
          call: Call,
          e: IOException,
        ) {
          println("failed: $e")
        }

        override fun onResponse(
          call: Call,
          response: Response,
        ) {
          println("response: ${response.code}")
          response.close()
        }

                throw new RuntimeException("Delete operation failed");
            }
        };
        ComponentUtil.register(searchEngineClient, "searchEngineClient");

        // Execute the job
        String result = purgeDocJob.execute();

        // Assert error message is in the result
        assertTrue(result.contains("Delete operation failed"));
        assertTrue(result.endsWith("\n"));
    }

                        holder.closed = true;
                        totalReleased.incrementAndGet();
                        cleaned++;
                    } catch (Exception e) {
                        log.error("Failed to auto-close resource: {}", holder.resourceId, e);
                    }
                }
            }
        }

        if (cleaned > 0) {

        });
        try {
            groupService.store(entity);
            saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL));
        } catch (final Exception e) {
            logger.warn("Failed to process a request.", e);
            throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)));
        }