|
@@ -34,16 +34,8 @@ public class MessageProcesser {
|
|
|
rabbitTemplate.convertAndSend(exchange, orgRoutingKey, message);
|
|
|
}
|
|
|
|
|
|
- private static final Set<String> beanNames = new HashSet<>();
|
|
|
-
|
|
|
- static {
|
|
|
- }
|
|
|
-
|
|
|
public void listen(DmpMessage message) {
|
|
|
String type = message.getType();
|
|
|
- if (!beanNames.contains(type)) {
|
|
|
- return;
|
|
|
- }
|
|
|
|
|
|
String executorName = type + "Executor";
|
|
|
MessageExecutor executor = SpringUtils.getBean(executorName, MessageExecutor.class);
|