The RabbitMQ Stream Java Client is a Java library to communicate with the RabbitMQ Stream Plugin. It allows to create and delete streams, as well as to publish to and consume from these streams.
The client ships also with a performance tool.
Please refer to the documentation (PDF) to find out more.
The project is in early stages of development and is considered experimental. It is not ready for production use. Features and API are subject to change.
-
For questions: RabbitMQ Users
-
For bugs and feature requests: 8799 GitHub Issues
The project is currently under development, there is no guarantee yet that it will be maintained and supported in the future (read: you are welcome to experiment with it and give feedback, but please do not base your whole business on it).
You need JDK 1.8 or more installed.
To build the JAR file:
./mvnw clean package -DskipITs -DskipTests
Launch the broker:
docker run -it --rm --name rabbitmq --network host pivotalrabbitmq/rabbitmq-stream
Launch the tests:
./mvnw test -Drabbitmqctl.bin=DOCKER:rabbitmq
The project uses the Google Java Format. Read the documentation to support the format in your favorite IDE.
Please launch the ./mvnw spotless:apply command to format your changes before committing.
(c) 2020, VMware Inc or its affiliates.
Double licensed under the MPL2.0 and ASL2. See LICENSE for details.