This module implements MessageReader and MessageWriter using the Qpid Proton library. It can be used with Qpid Proton or any integrations based on Qpid Proton (e.g vertx-proton).
For Maven based projects, use the following to configure the proton AMQP binding for CloudEvents:
<dependency>
<groupId>io.cloudevents</groupId>
<artifactId>cloudevents-amqp-proton</artifactId>
<version>4.0.1</version>
</dependency>
To send and receive CloudEvents we use MessageWriter and MessageReader, respectively. This module offers factory methods for creation of those in ProtonAmqpMessageFactory.
public class ProtonAmqpMessageFactory {
public static MessageReader createReader(final Message message);
public static MessageReader createReader(final String contentType, final ApplicationProperties props, @Nullable final Section body);
public static MessageWriter createWriter();
}
The example uses the vertx-proton integration to send/receive CloudEvent messages over AMQP:
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4