package io.quarkus.smallrye.reactivemessaging.kafka.deployment.testing;

//
//import io.smallrye.reactive.messaging.annotations.Broadcast;
//import org.eclipse.microprofile.reactive.messaging.Incoming;
//import org.eclipse.microprofile.reactive.messaging.Outgoing;
//
//import javax.enterprise.context.ApplicationScoped;
//
//@ApplicationScoped
public class PriceConverter {
    //    private static final double CONVERSION_RATE = 0.88;
    //
    //    @Incoming("prices")
    //    @Outgoing("processed-prices")
    //    @Broadcast
    //    public double process(int priceInUsd) {
    //        return priceInUsd * CONVERSION_RATE;
    //    }
}