fix: 修复循环依赖问题

This commit is contained in:
landaiqing
2024-06-25 16:12:31 +08:00
parent 283e7cad98
commit 6298f9038b
9 changed files with 47 additions and 54 deletions

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>

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-producer")
//@Slf4j
//public class TestConsumer implements RocketMQListener<String> {
// @Override
// public void onMessage(String s) {
// log.info("接收到ma消息{}", s);
// }
//}

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>

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-producer