@Override
    public Exception getException() {
        return exception;
    }

    @Override
    public String getMessage() {
        String msg;

        if (message != null && !message.isEmpty()) {
            msg = message;
        } else {
            msg = exception.getMessage();

            if (msg == null) {
                msg = "";
            }
        }

        return msg;

                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");

        NullPointerException npe = assertThrows(NullPointerException.class, () -> locator.handleDFSReferral(referral, null));
        assertTrue(npe.getMessage() == null || npe.getMessage().contains("reqPath"));
        verify(locator).handleDFSReferral(referral, null);
        verifyNoMoreInteractions(locator);
    }

        byte[] empty = new byte[0];

        // Act + Assert
        PACDecodingException ex = assertThrows(PACDecodingException.class, () -> new KerberosApRequest(empty, new KerberosKey[0]));
        assertTrue(ex.getMessage().contains("Empty kerberos ApReq"));
    }

    @Test
    @DisplayName("byte[] ctor: malformed DER is wrapped as PACDecodingException (IOException path)")
    void byteArrayConstructor_malformedDER_throwsWrapped() {

        // Act & Assert
        NullPointerException npe = assertThrows(NullPointerException.class, () -> creds.unwrap(null));
        assertEquals("type", npe.getMessage());
    }

    @Test
    @DisplayName("clone returns a distinct copy with same properties")
    void clone_returns_copy() {
        // Arrange
        Subject subject = new Subject();

            // Try to get server message from SMB exception
            return cause.getMessage();
        }
        return null;
    }

    private void logError() {
        if (errorCode.category == ErrorCategory.TRANSIENT) {
            log.debug("Transient SMB error: {} (attempt {}/{})", getMessage(), attemptNumber, retryPolicy.getMaxAttempts());
        } else if (isRetryable()) {

        try {
            crawlJob.execute();
            fail("Should throw JobProcessingException");
        } catch (JobProcessingException e) {
            assertTrue(e.getMessage().contains("10 crawler processes are running"));
            assertTrue(e.getMessage().contains("Max processes are 5"));
        }
    }

    // Test execute method with no max process limit
    public void test_execute_noMaxProcessLimit() {

        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());
    }