Commit 55c91215 by 张洪旺

test

parent 45f80fe2
...@@ -19,21 +19,11 @@ public class EventProcessorRegister extends ApplicationObjectSupport { ...@@ -19,21 +19,11 @@ public class EventProcessorRegister extends ApplicationObjectSupport {
private static Map<Integer, EventProcessor> processorMap = Maps.newHashMap(); private static Map<Integer, EventProcessor> processorMap = Maps.newHashMap();
EventProcessorRegister() { @PostConstruct
Map<String, EventProcessor> beans = getApplicationContext().getBeansOfType(EventProcessor.class);
log.info("EventProcessorRegister:bean:${}", beans);
if (!CollectionUtils.isEmpty(beans)) {
beans.values().stream().forEach((EventProcessor obj) -> {
processorMap.put(obj.getEvent(), obj);
}
);
}
}
/* @PostConstruct
private void init() { private void init() {
Map<String, EventProcessor> beans = getApplicationContext().getBeansOfType(EventProcessor.class); Map<String, EventProcessor> beans = getApplicationContext().getBeansOfType(EventProcessor.class);
CouponEventProcessor bean = getApplicationContext().getBean(CouponEventProcessor.class);
log.info("CouponEventProcessor:bean:${}",bean);
log.info("EventProcessorRegister:bean:${}",beans); log.info("EventProcessorRegister:bean:${}",beans);
if (!CollectionUtils.isEmpty(beans)) { if (!CollectionUtils.isEmpty(beans)) {
beans.values().stream().forEach((EventProcessor obj) -> { beans.values().stream().forEach((EventProcessor obj) -> {
...@@ -43,7 +33,7 @@ public class EventProcessorRegister extends ApplicationObjectSupport { ...@@ -43,7 +33,7 @@ public class EventProcessorRegister extends ApplicationObjectSupport {
); );
} }
}*/ }
public EventProcessor getEventProcessor(Integer event) { public EventProcessor getEventProcessor(Integer event) {
return processorMap.get(event); return processorMap.get(event);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment