hub / github.com/apache/rocketmq-spring

github.com/apache/rocketmq-spring @rocketmq-spring-all-2.3.6

Chat with this repo

repository ↗ · DeepWiki ↗ · release rocketmq-spring-all-2.3.6 ↗ · + Follow

797 symbols 1,788 edges 106 files 47 documented · 6%

What it actually does AI analysis from the code graph — generated when you open this

loading…

README

RocketMQ-Spring

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

Features

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

Prerequisites

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

Usage

Add a dependency using maven:


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

Samples

Please see the rocketmq-spring-boot-samples.

User Guide

Please see the wiki page.

Contributing

We are always very happy to have contributions, whether for trivial cleanups or big new features. Please see the RocketMQ main website to read the details.

License

Apache License, Version 2.0 Copyright (C) Apache Software Foundation

Extension points exported contracts — how you extend this code

RocketMQReplyListener (Interface)

The consumer supporting request-reply should implement this interface. @param the type of data received by the list [22 …

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQReplyListener.java

RocketMQListener (Interface)

(no doc) [5 implementers]

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQListener.java

RocketMQLocalRequestCallback (Interface)

Classes implementing this interface are used for processing callback events after receiving reply messages from consumer [4 …

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQLocalRequestCallback.java

RocketMQTransactionChecker (Interface)

(no doc) [2 implementers]

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQTransactionChecker.java

RocketMQLocalTransactionListener (Interface)

(no doc) [14 implementers]

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQLocalTransactionListener.java

RocketMQConsumerLifecycleListener (Interface)

(no doc) [2 implementers]

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQConsumerLifecycleListener.java

RocketMQListener (Interface)

(no doc) [4 implementers]

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQListener.java

RocketMQPushConsumerLifecycleListener (Interface)

(no doc) [1 implementers]

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQPushConsumerLifecycleListener.java

Core symbols most depended-on inside this repo

getName

called by 30

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java

resolvePlaceholders

called by 29

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtConsumerResetConfiguration.java

toRocketHeaderKey

called by 22

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java

resolvePlaceholders

called by 21

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java

run

called by 21

rocketmq-spring-boot-samples/rocketmq-consume-demo/src/main/java/org/apache/rocketmq/samples/springboot/ConsumerApplication.java

getProducer

called by 19

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

syncSend

called by 18

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

sendAndReceive

called by 14

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

Shape

Method 645

Class 133

Interface 14

Enum 5

Languages

Java100%

Modules by API surface

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java74 symbols

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/RocketMQProperties.java74 symbols

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java54 symbols

rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfigurationTest.java54 symbols

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java49 symbols

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java34 symbols

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java32 symbols

rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java18 symbols

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListenerBeanPostProcessor.java15 symbols

rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-producer-demo/src/main/java/org/apache/rocketmq/samples/springboot/producer/SQL92ProducerApplication.java15 symbols

rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java15 symbols

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java14 symbols

For agents

$ claude mcp add rocketmq-spring \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact