MicroProfile® Reactive Messaging 1.0

This is the first release of MicroProfile Reactive Messaging https://github.com/eclipse/microprofile-reactive-messaging. The release includes API, TCK and Spec.

The Reactive Messaging specification defines a development model for declaring CDI beansproducing, consuming and processing messages. The communication between these componentsuses Reactive Streams. This specification relies on Eclipse MicroProfile Reactive Streams Operators and CDI.

The main APIs are @Incoming @Outgoing annotations together with some SPIs for connectors to link up with messaging providers.

An example of usage:

@Incoming("my-channel")

public CompletionStage<Void>consume(Message<String>message {

       returnmessage.ack();

}

 

Release Date
Release Type
Major release (API breakage)