CloudEvents AMQP Proton

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>2.3.0</version>
</dependency>

Sending and Receiving CloudEvents

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();
}

Examples:

The example uses the vertx-proton integration to send/receive CloudEvent messages over AMQP:

• Vertx AmqpServer
• Vertx AmqpClient