彈簧反應堆和啓動依賴關係

啓動是運行彈簧反應堆的先決條件嗎？我想在常規的Web應用程序環境中使用彈簧反應堆。我可以看到反應器配置已創建。消費者已註冊。通知被調用。事件不會被解僱。什麼和如何檢查？彈簧反應堆和啓動依賴關係

配置

@Configuration 
    @EnableReactor 
    public class ReactorConfiguration { 
     @Bean 
     Environment env() { 
      return new Environment(); 
     } 

     @Bean 
     Reactor createReactor(Environment env) { 
      return Reactors.reactor().env(env).dispatcher(Environment.THREAD_POOL) 
        .get(); 
     } 


    }

註冊消費者：

@PostConstruct 
public void onStartUp() { 
    logger.debug("Registering Consumers"); 
    reactor.on(Selectors.T(Envelope.class), processParentRequest()); 
    reactor.on(Selectors.T(Bundle.class), processOptimizerRequest()); 

    reactor.on(Selectors.$(Constants.LOWER_ASG), processLowerAsgsRequest()); 
    reactor.on(Selectors.$(constants.SET_CONSUMPTION_LEVEL), 
      processConsumersRequest()); 
    reactor.on(Selectors.$(constants.SET_GENERATION_LEVEL), 
      processProducersRequest()); 
    reactor.on(Selectors.$(constants.SET_STORAGE_SUPPLY_LEVEL), 
      processStoragesRequest()); 
} 

private Consumer<Event<Envelope>> processParentRequest() { 
    return envelope -> optimizerUpdatingService 
      .processParentRequest(envelope); 
} 

private Consumer<Event<Bundle>> processOptimizerRequest() { 
    return bundle -> eventProcessingDispenser 
      .processOptimizerRequest(bundle); 
} 

private Consumer<Event<Envelope>> processLowerAsgsRequest() { 
    return envelope -> lowerAsgsProcessingService 
      .processLowerAsgRequest(envelope); 
} 

private Consumer<Event<Message>> processConsumersRequest() { 
    return message -> consumersProcessingService 
      .processConsumersRequest(message); 
} 

private Consumer<Event<Message>> processProducersRequest() { 
    return message -> producersProcessingService 
      .processProducersRequest(message); 
} 

private Consumer<Event<Message>> processStoragesRequest() { 
    return message -> storageProcessingService 
      .processStoragesRequest(message); 
}

來源

2014-12-29 JavaSpringNoSqlInMemoryDb

春天引導不是一個先決條件可言，它只是使用Spring與反應堆冷卻時提供了一些便利。

可能有任何數量的事情發生。沒有任何細節，很難給出具體的建議。

來源

2014-12-29 18:29:20

該日誌說：[ConsumerBeanAutoConfiguration] reactorConversionService尚未在上下文中找到。跳繩。 – JavaSpringNoSqlInMemoryDb

案件解決。它具有與Reactor配置無關的內部錯誤。 – JavaSpringNoSqlInMemoryDb

彈簧反應堆和啓動依賴關係

回答

相關問題