if ((exceptionMessage == null || exceptionMessage.isEmpty())
                        || longMessage.contains(exceptionMessage)) {
                    exceptionMessage = longMessage;
                } else if (!exceptionMessage.contains(longMessage)) {
                    exceptionMessage = join(exceptionMessage, System.lineSeparator() + longMessage);
                }
            }

            assertEquals("", exception.getMessage());
        });

        // Test long message
        String longMessage = createTestString(1000);
        assertDoesNotThrow(() -> {
            RuntimeCIFSException exception = new RuntimeCIFSException(longMessage);
            assertEquals(longMessage, exception.getMessage());
        });

        // Test message with special characters

        @Test
        @DisplayName("Should handle very long messages")
        void testVeryLongMessage() {
            StringBuilder longMessage = new StringBuilder();
            for (int i = 0; i < 10000; i++) {
                longMessage.append("x");
            }
            String message = longMessage.toString();

            TransportException exception = new TransportException(message);

    # Normally only one language, but still
    for lang in langs:
        if lang not in lang_to_discussion_map:
            log_message = f"Could not find discussion for language: {lang}"
            logging.error(log_message)
            raise RuntimeError(log_message)
        discussion = lang_to_discussion_map[lang]
        logging.info(

     * Test constructor with very long message
     */
    public void test_constructor_withVeryLongMessage() {
        StringBuilder longMessage = new StringBuilder();
        for (int i = 0; i < 10000; i++) {
            longMessage.append("Very long error message ");
        }
        String message = longMessage.toString();

        CrawlerSystemException exception = new CrawlerSystemException(message);

        assertNotNull(exception);

		strconv.FormatInt(bytesProcessed, 10) + `</BytesProcessed><BytesReturned>` +
		strconv.FormatInt(bytesReturned, 10) + `</BytesReturned></Stats>`)
	return genMessage(statsHeader, payload)
}

// endMessage - indicates that the request is complete, and no more messages will be sent.
// You should not assume that the request is complete until the client receives an End message.
//
// Header specification:

  @Throws(IOException::class)
  override fun onReadMessage(text: String) {
    listener.onMessage(this, text)
  }

  @Throws(IOException::class)
  override fun onReadMessage(bytes: ByteString) {
    listener.onMessage(this, bytes)
  }

  @Synchronized override fun onReadPing(payload: ByteString) {

        override fun onOpen(
          webSocket: WebSocket,
          response: Response,
        ) = TODO()

        override fun onMessage(
          webSocket: WebSocket,
          text: String,
        ) = TODO()

        override fun onMessage(
          webSocket: WebSocket,
          bytes: ByteString,
        ) = TODO()

        override fun onClosing(

public void setPluginContext(java.util.Map); } org/apache/maven/plugin/AbstractMojoExecutio.class package org.apache.maven.plugin; public abstract synchronized class AbstractMojoExecutio extends Exception { protected Object source; protected String longMessage; public void AbstractMojoExecutio(String); public void AbstractMojoExecutio(String, Throwable); public String getLongMessage(); public Object getSource(); } org/apache/maven/plugin/ContextEnabled.class package org.apache.maven.plugin; public abstract...

    clientListener.assertOpen()
    val server = serverListener.assertOpen()
    val e = RuntimeException()
    clientListener.setNextEventDelegate(
      object : WebSocketListener() {
        override fun onMessage(
          webSocket: WebSocket,
          text: String,
        ): Unit = throw e
      },
    )
    server.send("Hello, WebSockets!")
    clientListener.assertFailure(e)