amqp-proton

AMQP 1.0 + CloudEvents sample

This example uses the vertx-proton library and the AMQP 1.0 protocol binding for cloud events to implement a client and server that communicates over AMQP to exchange cloud event messages.

The vertx-proton library makes it easy to create (reactive) AMQP clients and servers and is a wrapper around Qpid proton--a library used to implement the AMQP 1.0 protocol binding for cloud events.

Build

mvn package

Start AMQP Server

Starts the AMQP server on 127.0.0.1 to listen for incoming connections on the default (insecure) AMQP port 5672. Once the server is started, it can either receive or send messages to a connected client. The opening and closing of a connection is initiated by a client.

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.amqp.vertx.AmqpServer"

Start AMQP Client

The client simply opens a connection with the server and either sends or receives a message containing a cloud event. Once the client completes sending or receiving a message, it initiates the closing of the connection by emitting the AMQP CLOSE frame.

Send a message to the server.

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.amqp.vertx.AmqpClient" -Dexec.args="send"

Receive a message from the server.

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.amqp.vertx.AmqpClient" -Dexec.args="receive"