weiaisuosi/nanguangszwlback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqbug

Browse Source
This commit is contained in:
王奎兴
2025-12-16 23:22:32 +08:00
parent 2b3fa73db1
commit 7ed03628fa
11 changed files with 51 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mhd_product/src/main/java/com/linke/product/application/event/menu/publish/MenuPublish.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.application.event.menu.publish;
import com.linke.product.infrastructure.util.mq.MenuChannel;
@@ -6,13 +7,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;
*/
/**
* 消息发布
*
* 2022-12-21
*
* @author 王子豪
*/
*//*
@EnableBinding(value = { MenuChannel.class })
@Service
public class MenuPublish {
@@ -27,3 +30,4 @@ public class MenuPublish {
source.outputLog().send(MessageBuilder.withPayload(content).build());
}
}
*/
mhd_product/src/main/java/com/linke/product/application/event/menu/subscribe/MenuSubscribe.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.application.event.menu.subscribe;
import com.linke.product.infrastructure.util.mq.MenuChannel;
@@ -5,13 +6,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
*/
/**
* 消息接收
*
* 2022-12-1
*
* @author 王子豪
*/
*//*
@EnableBinding(value = { MenuChannel.class })
public class MenuSubscribe {
@@ -29,3 +32,4 @@ public class MenuSubscribe {
// menuApplicationService.selectTreeMenu();
}
}
*/
mhd_product/src/main/java/com/linke/product/application/event/modules/publish/ModulesPublish.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.application.event.modules.publish;
import com.linke.product.infrastructure.util.mq.ModulesChannel;
@@ -6,13 +7,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;
*/
/**
* 消息发布
*
* 2022-12-1
*
* @author 王子豪
*/
*//*
@EnableBinding(value = { ModulesChannel.class })
@Service
public class ModulesPublish {
@@ -27,3 +30,4 @@ public class ModulesPublish {
source.outputLog().send(MessageBuilder.withPayload(content).build());
}
}
*/
mhd_product/src/main/java/com/linke/product/application/event/modules/subscribe/ModulesSubscribe.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.application.event.modules.subscribe;
import com.linke.product.infrastructure.util.mq.ModulesChannel;
@@ -5,13 +6,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
*/
/**
* 消息接收
*
* 2022-12-1
*
* @author 王子豪
*/
*//*
@EnableBinding(value = { ModulesChannel.class })
public class ModulesSubscribe {
@@ -29,3 +32,4 @@ public class ModulesSubscribe {
// sysModulesApplicationService.selectTreeModules();
}
}
*/
mhd_product/src/main/java/com/linke/product/application/event/organization/publish/OrganizationPublish.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.application.event.organization.publish;
import com.linke.product.infrastructure.util.mq.OrganizationChannel;
@@ -6,13 +7,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;
*/
/**
* 消息发布
*
* 2022-11-22
*
* @author 王子豪
*/
*//*
@EnableBinding(value = { OrganizationChannel.class })
@Service
public class OrganizationPublish {
@@ -27,3 +30,4 @@ public class OrganizationPublish {
source.outputLog().send(MessageBuilder.withPayload(content).build());
}
}
*/
mhd_product/src/main/java/com/linke/product/application/event/organization/subscribe/OrganizationSubscribe.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.application.event.organization.subscribe;
import com.linke.product.application.service.organization.OrganizationApplicationService;
@@ -8,13 +9,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
*/
/**
* 消息接收
*
* 2022-11-25
*
* @author 王子豪
*/
*//*
@EnableBinding(value = { OrganizationChannel.class })
public class OrganizationSubscribe {
@@ -32,3 +35,4 @@ public class OrganizationSubscribe {
// organizationASvc.selectTreeOrganization();
}
}
*/
mhd_product/src/main/java/com/linke/product/application/service/modules/SysModulesApplicationService.java
+3 -3
View File
@@ -1,6 +1,6 @@
package com.linke.product.application.service.modules;
import com.linke.product.application.event.modules.publish.ModulesPublish;
//import com.linke.product.application.event.modules.publish.ModulesPublish;
import com.linke.product.domain.modules.entity.ModulesMenu;
import com.linke.product.domain.modules.entity.SysModules;
import com.linke.product.domain.modules.service.ModulesMenuDomainService;
@@ -27,8 +27,8 @@ public class SysModulesApplicationService {
private SysModulesDomainService iSysModulesSvc;
@Autowired
private ModulesMenuDomainService iModulesMenuSvc;
@Autowired
private ModulesPublish modulesPublish;
/*@Autowired
private ModulesPublish modulesPublish;*/
/**
* 查询产品中台-模块
mhd_product/src/main/java/com/linke/product/application/service/organization/OrganizationApplicationService.java
+3 -3
View File
@@ -4,7 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.linke.product.application.event.organization.publish.OrganizationPublish;
//import com.linke.product.application.event.organization.publish.OrganizationPublish;
import com.linke.product.domain.common.entity.DataPermission;
import com.linke.product.domain.customAuth.service.CustomAuthDomainService;
import com.linke.product.domain.customAuth.service.CustomAuthOrganizationDomainService;
@@ -72,8 +72,8 @@ public class OrganizationApplicationService {
private OrganizationWlhyDomainService organizationWlhyDomainService;
@Autowired
private OrganizationMenuDomainService iOrganizationMenuSvc;
@Autowired
private OrganizationPublish organizationPublish;
/* @Autowired
private OrganizationPublish organizationPublish;*/
@Autowired
private MenuDomainService menuDomainService;
@Autowired
mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/MenuChannel.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.infrastructure.util.mq;
import org.springframework.cloud.stream.annotation.Input;
@@ -5,6 +6,7 @@ import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
*/
/**
* 自定义消息通道
*
@@ -12,7 +14,8 @@ import org.springframework.messaging.SubscribableChannel;
* 2022-12-1
*
* @author 王子豪
*/
*//*
public interface MenuChannel {
String INPUT_LOG = "inputMenu";
@@ -22,3 +25,4 @@ public interface MenuChannel {
@Output(OUTPUT_LOG)
MessageChannel outputLog();
}
*/
mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/ModulesChannel.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.infrastructure.util.mq;
import org.springframework.cloud.stream.annotation.Input;
@@ -5,6 +6,7 @@ import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
*/
/**
* 自定义消息通道
*
@@ -12,7 +14,8 @@ import org.springframework.messaging.SubscribableChannel;
* 2022-12-1
*
* @author 王子豪
*/
*//*
public interface ModulesChannel {
String INPUT_LOG = "inputModules";
@@ -22,3 +25,4 @@ public interface ModulesChannel {
@Output(OUTPUT_LOG)
MessageChannel outputLog();
}
*/
mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/OrganizationChannel.java
+5 -1
View File
@@ -1,3 +1,4 @@
/*
package com.linke.product.infrastructure.util.mq;
import org.springframework.cloud.stream.annotation.Input;
@@ -5,6 +6,7 @@ import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
*/
/**
* 自定义消息通道
*
@@ -12,7 +14,8 @@ import org.springframework.messaging.SubscribableChannel;
* 2022-11-22
*
* @author 王子豪
*/
*//*
public interface OrganizationChannel {
String INPUT_LOG = "inputOrganization";
@@ -22,3 +25,4 @@ public interface OrganizationChannel {
@Output(OUTPUT_LOG)
MessageChannel outputLog();
}
*/