Merge pull request #1174 from rsvoboda/kafka-panache-reactive.context…

….prop.fix Add @ActivateRequestContext to start a request scope explicitly
quarkusio · Sep 13, 2022 · d8b2788 · d8b2788
2 parents f6acff6 + a51d7c9
commit d8b2788
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kafka-panache-reactive-quickstart/src/main/java/org/acme/panache/PriceStorage.java b/kafka-panache-reactive-quickstart/src/main/java/org/acme/panache/PriceStorage.java
@@ -2,16 +2,16 @@
 
 import io.quarkus.hibernate.reactive.panache.Panache;
 import io.smallrye.mutiny.Uni;
-import io.smallrye.reactive.messaging.annotations.Blocking;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 
 import javax.enterprise.context.ApplicationScoped;
-import javax.transaction.Transactional;
+import javax.enterprise.context.control.ActivateRequestContext;
 
 @ApplicationScoped
 public class PriceStorage {
 
     @Incoming("prices")
+    @ActivateRequestContext
     Uni<Void> store(int priceInUsd) {
         Price price = new Price();
         price.value = priceInUsd;