inbound

Class KafkaPriceMessageConsumer

java.lang.Object

inbound.KafkaPriceMessageConsumer

@ApplicationScoped
public class KafkaPriceMessageConsumer
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaPriceMessageConsumer()

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	consume(Message<Double> price)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaPriceMessageConsumer

public KafkaPriceMessageConsumer()

Method Detail

consume

public CompletionStage<Void> consume(Message<Double> price)