@@ -275,6 +275,24 @@ public void testGetTask_MethodNameSetInContext() {
         verify(mockHttpResponse).putHeader(CONTENT_TYPE, APPLICATION_JSON);
     }
 
+    @Test
+    public void testGetTask_ForwardsTransportPolicyErrorAndResponseId() {
+        String jsonRpcRequest = """
+                {"jsonrpc":"2.0","id":"request-id","method":"GetTask","params":{"id":"task"}}
+                """;
+        GetTaskResponse policyResponse = new GetTaskResponse("policy-error-id",
+                new org.a2aproject.sdk.spec.UnsupportedOperationError());
+        when(mockJsonRpcHandler.onGetTask(any(GetTaskRequest.class), any(ServerCallContext.class)))
+                .thenReturn(policyResponse);
+
+        routes.invokeJSONRPCHandler(jsonRpcRequest, mockRoutingContext);
+
+        verify(mockJsonRpcHandler).onGetTask(any(GetTaskRequest.class), any(ServerCallContext.class));
+        JsonObject response = captureResponse();
+        assertEquals("policy-error-id", response.get("id").getAsString());
+        assertTrue(response.has("error"));
+    }
+
     @Test
     public void testCancelTask_MethodNameSetInContext() {
         // Arrange - using protobuf JSON format
 
@@ -519,6 +519,24 @@ public void testSendMessage_UnsupportedProtocolVersion_ReturnsVersionNotSupporte
         verify(mockResponse).setStatusCode(400);
     }
 
+    @Test
+    public void testSendMessage_ForwardsTransportPolicyResponseWithoutRouteValidation() {
+        HTTPRestResponse policyResponse = mock(HTTPRestResponse.class);
+        when(policyResponse.getStatusCode()).thenReturn(422);
+        when(policyResponse.getContentType()).thenReturn(APPLICATION_JSON);
+        when(policyResponse.getBody()).thenReturn("{\"error\":{\"code\":422,\"status\":\"INVALID_ARGUMENT\"}}");
+        when(mockRoutingContext.pathParam("tenant")).thenReturn("bad?tenant");
+        when(mockRestHandler.sendMessage(any(ServerCallContext.class), eq("bad?tenant"), anyString()))
+                .thenReturn(policyResponse);
+
+        routes.sendMessage("{}", mockRoutingContext);
+
+        verify(mockRestHandler).sendMessage(any(ServerCallContext.class), eq("bad?tenant"), eq("{}"));
+        verify(mockResponse).setStatusCode(422);
+        verify(mockResponse).putHeader(io.vertx.core.http.HttpHeaders.CONTENT_TYPE, APPLICATION_JSON);
+        verify(mockResponse).end("{\"error\":{\"code\":422,\"status\":\"INVALID_ARGUMENT\"}}");
+    }
+
     /**
      * Helper method to set a field via reflection for testing purposes.
      */