fix: Test clean up

Author: fjuma

tests/server-common/src/test/java/io/a2a/server/apps/common/AbstractA2AServerTest.java

@@ -239,7 +239,7 @@ public void testSendMessageNewMessageSuccess() throws Exception {
 
         // testing the non-streaming send message
         getNonStreamingClient().sendMessage(message, List.of(consumer), null, null);
-        
+
         assertTrue(latch.await(10, TimeUnit.SECONDS));
         assertFalse(wasUnexpectedEvent.get());
         Message messageResponse = receivedMessage.get();
@@ -344,7 +344,7 @@ public void testError() throws A2AClientException {
 
         try {
             getNonStreamingClient().sendMessage(message, null);
-            
+
             // For non-streaming clients, the error should still be thrown as an exception
             fail("Expected A2AClientException for unsupported send message operation");
         } catch (A2AClientException e) {
@@ -407,7 +407,7 @@ public void testSendMessageStreamExistingTaskSuccess() throws Exception {
             assertTrue(latch.await(10, TimeUnit.SECONDS));
             assertFalse(wasUnexpectedEvent.get());
             assertNull(errorRef.get());
-            
+
             Message messageResponse = receivedMessage.get();
             assertNotNull(messageResponse);
             assertEquals(MESSAGE.getMessageId(), messageResponse.getMessageId());
@@ -536,10 +536,10 @@ public void testResubscribeNoExistingTaskError() throws Exception {
 
         try {
             getClient().resubscribe(new TaskIdParams("non-existent-task"), List.of(), errorHandler, null);
-            
+
             // Wait for error to be captured (may come via error handler for streaming)
             boolean errorReceived = errorLatch.await(10, TimeUnit.SECONDS);
-            
+
             if (errorReceived) {
                 // Error came via error handler
                 Throwable error = errorRef.get();
@@ -1028,15 +1028,12 @@ private ClientConfig createClientConfig(boolean streaming) {
 
         // Set transport-specific configuration
         List<ClientTransportConfig> transportConfigs = getClientTransportConfigs();
-        
+
         if (!transportConfigs.isEmpty()) {
             builder.setClientTransportConfigs(transportConfigs);
         }
 
         return builder.build();
     }
 
-    private static class BreakException extends RuntimeException {
-
-    }
 }