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. This library requires at least Java 11 but Java 21 or more is recommended. See the overview for a quick glance at the features.
Stream PerfTest is a performance testing tool based on this client library.
Please refer to the documentation to find out more.
-
For questions: RabbitMQ Users
-
For bugs and feature requests: GitHub Issues
See the RabbitMQ Java libraries support page for the support timeline of this library.
This library uses semantic versioning.
You need JDK 11 or later installed.
To build the JAR file:
./mvnw clean package -DskipITs -DskipTests
Launch the broker:
docker run -it --rm --name rabbitmq -p 5552:5552 -p 5672:5672 \
-e RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS='-rabbitmq_stream advertised_host localhost' \
rabbitmq:4.1
Enable the stream plugin:
docker exec rabbitmq rabbitmq-plugins enable 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-2025 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
Double licensed under the MPL2.0 and ASL2. See LICENSE for details.
