log.info("RDMA connection established to {}", delegate.getRemoteAddress());
            } catch (IOException e) {
                log.warn("Failed to establish RDMA connection: {}", e.getMessage());
                throw e;
            }
        }
    }

    /**
     * Checks if RDMA connection is available.
     *
     * @return true if RDMA connection is active
     */

            pluginManager.setupPluginRealm(pluginDescriptor, session, null, null, null);
        } catch (Exception e) {
            throw new PluginManagerException(plugin, e.getMessage(), e);
        }

        ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
        try {
            Thread.currentThread().setContextClassLoader(pluginDescriptor.getClassRealm());

        sqlException2.setNextException(sqlException3);

        final SQLRuntimeException sqlRuntimeException = new SQLRuntimeException(sqlException);

        // ## Act ##
        final String message = sqlRuntimeException.getMessage();

        // ## Assert ##
        System.out.println(message);
        assertContains(message, "ErrorCode=7650");
        assertContains(message, "SQLState=fooState");
        assertContains(message, "some reason");

        try {
            notificationHelper.sendToSlack(null, discloser);
        } catch (Exception e) {
            fail("sendToSlack() should not throw an exception with blank URLs: " + e.getMessage());
        }
    }

    public void test_sendToSlack_withNullWebhookUrls() {
        // Setup mock configuration with null webhook URLs
        ComponentUtil.setFessConfig(new MockFessConfig() {

            fail("Should have thrown InvalidQueryException");
        } catch (InvalidQueryException e) {
            // Expected exception
            assertTrue(e.getMessage().contains("Unknown q:"));
            assertTrue(e.getMessage().contains("TermQuery"));
        }
    }

    public void test_execute_withNullQuery() {
        // Test that execute handles null query

        request.param("key", "value");

        try {
            request.encoding("ISO-8859-1");
            fail("Expected CurlException");
        } catch (CurlException e) {
            assertTrue(e.getMessage().contains("must be called before param method"));
        }
    }

    @Test
    public void testThresholdMethod() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");

                    assertThrows(SMBProtocolDecodingException.class, () -> response.readBytesWireFormat(buffer, bufferIndex));
            assertEquals("Expected structureSize = 4", exception.getMessage());
        }

        @ParameterizedTest
        @ValueSource(ints = { 0, 1, 2, 3, 5, 6, 100, 255, 65535 })
        @DisplayName("Should throw exception for various invalid structure sizes")

        } catch (NoSuchFieldException | IllegalAccessException e) {
            log.error("Failed to reset SingletonContext instance", e);
            fail("Failed to reset SingletonContext instance: " + e.getMessage());
        }
        // Clear system properties that might affect the test
        System.clearProperty("jcifs.properties");
        System.clearProperty("java.protocol.handler.pkgs");

        assertEquals("MESSAGE", problem.getMessage());

        problem = new DefaultProblem(null, null, null, -1, -1, new Exception());
        assertEquals("", problem.getMessage());

        problem = new DefaultProblem(null, null, null, -1, -1, new Exception("EXCEPTION MESSAGE"));
        assertEquals("EXCEPTION MESSAGE", problem.getMessage());
    }

    /**
     * Constructs a new ExtractException with the specified message and cause.
     *
     * @param message the detail message. The detail message is saved for later retrieval by the {@link #getMessage()} method.
     * @param cause the cause (which is saved for later retrieval by the {@link #getCause()} method).
     *              (A {@code null} value is permitted, and indicates that the cause is nonexistent or unknown.)