Commit 92581936 by 韩斌

[20240315007-ZY20240415002] 完成控制端与采集端的指令下达和反馈通信

parent 95490153
...@@ -33,7 +33,7 @@ import static org.gidea.scada.monitor.utils.RabbitExchangeEnum.MonitorCommandSer ...@@ -33,7 +33,7 @@ import static org.gidea.scada.monitor.utils.RabbitExchangeEnum.MonitorCommandSer
@Configuration @Configuration
public class MonitorClientConfig { public class MonitorClientConfig {
@Value("${mqtt.client.id}") @Value("${org.gidea.monitor.client.name}")
private String monitorName; private String monitorName;
@Resource @Resource
private Channel channel; private Channel channel;
......
...@@ -22,7 +22,7 @@ import java.util.concurrent.locks.Lock; ...@@ -22,7 +22,7 @@ import java.util.concurrent.locks.Lock;
@Component @Component
public class MonitorRabbitListener { public class MonitorRabbitListener {
@Value("${org.gidea.monitor.name}") @Value("${org.gidea.monitor.client.name}")
private String monitorName; private String monitorName;
private Map<String, SimpleMessageListenerContainer> queues = new ConcurrentReferenceHashMap<>(); private Map<String, SimpleMessageListenerContainer> queues = new ConcurrentReferenceHashMap<>();
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论