Class MyBeanEmittingPayloadsWithAck
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.channel.MyBeanEmittingPayloadsWithAck
-
@ApplicationScoped public class MyBeanEmittingPayloadsWithAck extends Object
-
-
Constructor Summary
Constructors Constructor Description MyBeanEmittingPayloadsWithAck()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletionStage<Void>
consume(Message<String> s)
Emitter<String>
emitter()
List<String>
list()
void
run()
-