History

github-actions[bot] a718c015ab Bump to 4.0.2-SNAPSHOT (#655 ) Signed-off-by: GitHub <noreply@github.com> Co-authored-by: pierDipi <pierDipi@users.noreply.github.com>		2024-07-03 15:31:33 +02:00
..
src/main/java/io/cloudevents/examples/rocketmq	feat: add rocketmq binding (#554 )	2023-05-23 10:49:08 +02:00
README.md	feat: add rocketmq binding (#554 )	2023-05-23 10:49:08 +02:00
pom.xml	Bump to 4.0.2-SNAPSHOT (#655 )	2024-07-03 15:31:33 +02:00

RocketMQ + CloudEvents Sample

This example demonstrates the integration of RocketMQ 5.x client library with CloudEvents to create a RocketMQ binding.

Building the Project

mvn package

Follow the quickstart guide on the official RocketMQ website to set up the necessary components, including nameserver, proxy, and broker.

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.rocketmq.RocketmqProducer" -Dexec.args="foobar:8081 sample-topic"

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.rocketmq.RocketmqConsumer" -Dexec.args="foobar:8081 sample-topic sample-consumer-group"