Schisandra-Cloud-Storage/schisandra-cloud-storage
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: add RocketMQ

Browse Source
This commit is contained in:
landaiqing
2024-06-25 17:09:49 +08:00
parent 6298f9038b
commit a64b1f9533
5 changed files with 44 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/pom.xml
View File

@@ -19,10 +19,10 @@
</properties>
<dependencies>
<!-- <dependency>-->
<!-- <groupId>com.schisandra</groupId>-->
<!-- <artifactId>schisandra-cloud-storage-auth-domain</artifactId>-->
<!-- <version>1.0-SNAPSHOT</version>-->
<!-- </dependency>-->
<dependency>
<groupId>com.schisandra</groupId>
<artifactId>schisandra-cloud-storage-auth-domain</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project>

50
schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/src/main/java/com/schisandra/auth/application/mq/TestConsumer.java
View File

@@ -1,25 +1,25 @@
//package com.schisandra.auth.application.mq;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Component;
//
///**
// * @Classname TestConsumer
// * @BelongsProject: schisandra-cloud-storage
// * @BelongsPackage: com.schisandra.auth.application.mq
// * @Author: landaiqing
// * @CreateTime: 2024-06-25 14:39
// * @Description: TODO
// * @Version: 1.0
// */
//@Component
//@RocketMQMessageListener(topic = "first-topic", consumerGroup = "schisandra-cloud-storage-auth-producer")
//@Slf4j
//public class TestConsumer implements RocketMQListener<String> {
// @Override
// public void onMessage(String s) {
// log.info("接收到ma消息：{}", s);
// }
//}
package com.schisandra.auth.application.mq;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
/**
* @Classname TestConsumer
* @BelongsProject: schisandra-cloud-storage
* @BelongsPackage: com.schisandra.auth.application.mq
* @Author: landaiqing
* @CreateTime: 2024-06-25 14:39
* @Description: TODO
* @Version: 1.0
*/
@Component
@RocketMQMessageListener(topic = "first-topic", consumerGroup = "schisandra-cloud-storage-auth-consumer-group")
@Slf4j
public class TestConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String s) {
log.info("接收到ma消息：{}", s);
}
}

10
schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/pom.xml
View File

@@ -67,10 +67,10 @@
<artifactId>schisandra-cloud-storage-auth-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.apache.rocketmq</groupId>-->
<!-- <artifactId>rocketmq-spring-boot-starter</artifactId>-->
<!-- <version>2.1.1</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.1.1</version>
</dependency>
</dependencies>
</project>

5
schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/pom.xml
View File

@@ -54,6 +54,11 @@
<artifactId>schisandra-cloud-storage-auth-infra</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.schisandra</groupId>
<artifactId>schisandra-cloud-storage-auth-application-mq</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>

8
schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/src/main/resources/application.yml
View File

@@ -103,7 +103,7 @@ web:
cipher:
salt: E2754BC007CA407190E85DFF6E566003
#rocketmq:
# name-server: 1.95.0.111:9876
# producer:
# group: schisandra-cloud-storage-auth-producer
rocketmq:
name-server: 1.95.0.111:9876
producer:
group: schisandra-cloud-storage-auth-group