Home

RocketMQ-Spring

This project aims to help developers quickly integrate RocketMQ with Spring Boot.

Features

• Send messages synchronously
• Send messages asynchronously
• Send messages in one-way mode
• Send ordered messages
• Send batched messages
• Send transactional messages
• Send scheduled messages with delay level
• Consume messages with concurrently mode (broadcasting/clustering)
• Consume messages with push/pull mode
• Consume ordered messages
• Filter messages using the tag or sql92 expression
• Support message tracing
• Support authentication and authorization
• Support request-reply message exchange pattern

Prerequisites

• JDK 1.8 and above
• Maven 3.0 and above
• Spring Boot 2.0 and above

Usage

Add a dependency using maven:

<!--add dependency in pom.xml-->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>${RELEASE.VERSION}</version>
</dependency>