rocketmq

RocketMQ + CloudEvents Sample

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

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"

Name		Name	Last commit message	Last commit date
parent directory ..
src/main/java/io/cloudevents/examples/rocketmq		src/main/java/io/cloudevents/examples/rocketmq
README.md		README.md
pom.xml		pom.xml