test/MeterSphere
1
0
Fork 0
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git synced 2024-12-03 20:49:56 +08:00
Code Issues Actions 18 Packages Projects Releases Wiki Activity

chore: 规范group_id名称

Browse Source
This commit is contained in:
CaptainB 2023-03-20 13:35:08 +08:00 committed by f2c-ci-robot[bot]
parent 9d1c7cf2e4
commit 75285f4585
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
system-setting/backend/src/main/java/io/metersphere/listener/PlatformPluginListener.java
View File

@ -18,7 +18,7 @@ public class PlatformPluginListener {
private PlatformPluginService platformPluginService;
// groupId 必须是每个实例唯一
@KafkaListener(id = TEST_TRACK_PLATFORM_PLUGIN, topics = KafkaTopicConstants.PLATFORM_PLUGIN, groupId = TEST_TRACK_PLATFORM_PLUGIN + "_" + "#{T(java.util.UUID).randomUUID()})")
@KafkaListener(id = TEST_TRACK_PLATFORM_PLUGIN, topics = KafkaTopicConstants.PLATFORM_PLUGIN, groupId = TEST_TRACK_PLATFORM_PLUGIN + "_" + "${random.uuid}")
public void handlePluginChange(ConsumerRecord<?, String> record) {
LogUtil.info("track service consume platform_plugin add message, plugin id: " + record);
String[] info = record.value().split(":");

2
test-track/backend/src/main/java/io/metersphere/listener/PlatformPluginListener.java
View File

@ -17,7 +17,7 @@ public class PlatformPluginListener {
private PlatformPluginService platformPluginService;
// groupId 必须是每个实例唯一
@KafkaListener(id = TEST_TRACK_PLATFORM_PLUGIN, topics = KafkaTopicConstants.PLATFORM_PLUGIN, groupId = TEST_TRACK_PLATFORM_PLUGIN + "_" + "#{T(java.util.UUID).randomUUID()})")
@KafkaListener(id = TEST_TRACK_PLATFORM_PLUGIN, topics = KafkaTopicConstants.PLATFORM_PLUGIN, groupId = TEST_TRACK_PLATFORM_PLUGIN + "_" + "${random.uuid}")
public void handlePluginChange(ConsumerRecord<?, String> record) {
LogUtil.info("track service consume platform_plugin add message, plugin id: " + record);
String[] info = record.value().split(":");