|
@@ -26,9 +26,11 @@ public class JmsConfig {
|
|
|
@Value("${persagy.dmp.exchange}")
|
|
|
private String exchange;
|
|
|
|
|
|
- private String adminRoutingKey = "routing-dmp-admin";
|
|
|
+ @Value("${persagy.dmp.admin.routingKey}")
|
|
|
+ private String adminRoutingKey;
|
|
|
|
|
|
- private String adminQueue = "queue-dmp-admin";
|
|
|
+ @Value("${persagy.dmp.admin.queue}")
|
|
|
+ private String adminQueue;
|
|
|
|
|
|
@Autowired
|
|
|
private MessageProcesser messageProcesser;
|
|
@@ -49,7 +51,7 @@ public class JmsConfig {
|
|
|
return BindingBuilder.bind(queue()).to(exchage()).with(adminRoutingKey);
|
|
|
}
|
|
|
|
|
|
- @RabbitListener(queues = "queue-dmp-admin") //监听器监听指定的Queue
|
|
|
+ @RabbitListener(queues = "${persagy.dmp.admin.queue}") //监听器监听指定的Queue
|
|
|
public void processC(DmpMessage message) {
|
|
|
log.info("============================== Receive {}: {}", adminQueue, JacksonMapper.toSimpleJson(message));
|
|
|
messageProcesser.listen(message);
|