acme

Class Receiver

java.lang.Object

acme.Receiver

@ApplicationScoped
public class Receiver
extends Object

Constructor Summary

Constructors

Constructor and Description
Receiver()

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	consume(KafkaRecord<String,String> message)

Methods inherited from class java.lang.Object

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

Constructor Detail

Receiver

public Receiver()

Method Detail

consume

public CompletionStage<Void> consume(KafkaRecord<String,String> message)