|
|
@ -35,12 +35,12 @@ public final class ReactorNettyConfigurations {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Configuration(proxyBeanMethods = false)
|
|
|
|
@Configuration(proxyBeanMethods = false)
|
|
|
|
@EnableConfigurationProperties(ReactorNettyConfigurationProperties.class)
|
|
|
|
@EnableConfigurationProperties(ReactorNettyProperties.class)
|
|
|
|
public static class ReactorResourceFactoryConfiguration {
|
|
|
|
public static class ReactorResourceFactoryConfiguration {
|
|
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
@ConditionalOnMissingBean
|
|
|
|
@ConditionalOnMissingBean
|
|
|
|
ReactorResourceFactory reactorResourceFactory(ReactorNettyConfigurationProperties configurationProperties) {
|
|
|
|
ReactorResourceFactory reactorResourceFactory(ReactorNettyProperties configurationProperties) {
|
|
|
|
ReactorResourceFactory reactorResourceFactory = new ReactorResourceFactory();
|
|
|
|
ReactorResourceFactory reactorResourceFactory = new ReactorResourceFactory();
|
|
|
|
if (configurationProperties.getShutdownQuietPeriod() != null) {
|
|
|
|
if (configurationProperties.getShutdownQuietPeriod() != null) {
|
|
|
|
reactorResourceFactory.setShutdownQuietPeriod(configurationProperties.getShutdownQuietPeriod());
|
|
|
|
reactorResourceFactory.setShutdownQuietPeriod(configurationProperties.getShutdownQuietPeriod());
|
|
|
|