Merge pull request #45220 from ozangunalp/messaging_vt_class_fix

Messaging RunOnVirtualThreads fix on class annotation
quarkusio · Jan 6, 2025 · 66c4aad · 66c4aad
2 parents 3cd83ac + 0bd5d2a
commit 66c4aad
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...va/io/quarkus/smallrye/reactivemessaging/deployment/QuarkusMediatorConfigurationUtil.java b/...va/io/quarkus/smallrye/reactivemessaging/deployment/QuarkusMediatorConfigurationUtil.java
@@ -204,7 +204,8 @@ && hasBlockingPayloadSignature(methodInfo)) {
         AnnotationInstance transactionalAnnotation = methodInfo.annotation(TRANSACTIONAL);
         AnnotationInstance runOnVirtualThreadAnnotation = methodInfo.annotation(RUN_ON_VIRTUAL_THREAD);
         // IF @RunOnVirtualThread is used on the declaring class, it forces all @Blocking method to be run on virtual threads.
-        AnnotationInstance runOnVirtualThreadClassAnnotation = methodInfo.declaringClass().annotation(RUN_ON_VIRTUAL_THREAD);
+        AnnotationInstance runOnVirtualThreadClassAnnotation = methodInfo.declaringClass()
+                .declaredAnnotation(RUN_ON_VIRTUAL_THREAD);
         if (blockingAnnotation != null || smallryeBlockingAnnotation != null || transactionalAnnotation != null
                 || runOnVirtualThreadAnnotation != null) {
             mediatorConfigurationSupport.validateBlocking(validationOutput);