类org.springframework.context.LifecycleProcessor源码实例Demo

下面列出了怎么用org.springframework.context.LifecycleProcessor的API类实例代码及写法,或者点击链接到github查看源代码。

/**
 * Initialize the LifecycleProcessor.
 * Uses DefaultLifecycleProcessor if none defined in the context.
 * @see org.springframework.context.support.DefaultLifecycleProcessor
 */
protected void initLifecycleProcessor() {
	ConfigurableListableBeanFactory beanFactory = getBeanFactory();
	if (beanFactory.containsLocalBean(LIFECYCLE_PROCESSOR_BEAN_NAME)) {
		this.lifecycleProcessor =
				beanFactory.getBean(LIFECYCLE_PROCESSOR_BEAN_NAME, LifecycleProcessor.class);
		if (logger.isTraceEnabled()) {
			logger.trace("Using LifecycleProcessor [" + this.lifecycleProcessor + "]");
		}
	}
	else {
		DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor();
		defaultProcessor.setBeanFactory(beanFactory);
		this.lifecycleProcessor = defaultProcessor;
		beanFactory.registerSingleton(LIFECYCLE_PROCESSOR_BEAN_NAME, this.lifecycleProcessor);
		if (logger.isTraceEnabled()) {
			logger.trace("No '" + LIFECYCLE_PROCESSOR_BEAN_NAME + "' bean, using " +
					"[" + this.lifecycleProcessor.getClass().getSimpleName() + "]");
		}
	}
}
 
/**
 * Initialize the LifecycleProcessor.
 * Uses DefaultLifecycleProcessor if none defined in the context.
 * @see org.springframework.context.support.DefaultLifecycleProcessor
 */
protected void initLifecycleProcessor() {
	ConfigurableListableBeanFactory beanFactory = getBeanFactory();
	if (beanFactory.containsLocalBean(LIFECYCLE_PROCESSOR_BEAN_NAME)) {
		this.lifecycleProcessor =
				beanFactory.getBean(LIFECYCLE_PROCESSOR_BEAN_NAME, LifecycleProcessor.class);
		if (logger.isTraceEnabled()) {
			logger.trace("Using LifecycleProcessor [" + this.lifecycleProcessor + "]");
		}
	}
	else {
		DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor();
		defaultProcessor.setBeanFactory(beanFactory);
		this.lifecycleProcessor = defaultProcessor;
		beanFactory.registerSingleton(LIFECYCLE_PROCESSOR_BEAN_NAME, this.lifecycleProcessor);
		if (logger.isTraceEnabled()) {
			logger.trace("No '" + LIFECYCLE_PROCESSOR_BEAN_NAME + "' bean, using " +
					"[" + this.lifecycleProcessor.getClass().getSimpleName() + "]");
		}
	}
}
 
源代码3 项目: lams   文件: AbstractApplicationContext.java
/**
 * Initialize the LifecycleProcessor.
 * Uses DefaultLifecycleProcessor if none defined in the context.
 * @see org.springframework.context.support.DefaultLifecycleProcessor
 */
protected void initLifecycleProcessor() {
	ConfigurableListableBeanFactory beanFactory = getBeanFactory();
	if (beanFactory.containsLocalBean(LIFECYCLE_PROCESSOR_BEAN_NAME)) {
		this.lifecycleProcessor =
				beanFactory.getBean(LIFECYCLE_PROCESSOR_BEAN_NAME, LifecycleProcessor.class);
		if (logger.isDebugEnabled()) {
			logger.debug("Using LifecycleProcessor [" + this.lifecycleProcessor + "]");
		}
	}
	else {
		DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor();
		defaultProcessor.setBeanFactory(beanFactory);
		this.lifecycleProcessor = defaultProcessor;
		beanFactory.registerSingleton(LIFECYCLE_PROCESSOR_BEAN_NAME, this.lifecycleProcessor);
		if (logger.isDebugEnabled()) {
			logger.debug("Unable to locate LifecycleProcessor with name '" +
					LIFECYCLE_PROCESSOR_BEAN_NAME +
					"': using default [" + this.lifecycleProcessor + "]");
		}
	}
}
 
/**
 * Initialize the LifecycleProcessor.
 * Uses DefaultLifecycleProcessor if none defined in the context.
 * @see org.springframework.context.support.DefaultLifecycleProcessor
 */
protected void initLifecycleProcessor() {
	ConfigurableListableBeanFactory beanFactory = getBeanFactory();
	if (beanFactory.containsLocalBean(LIFECYCLE_PROCESSOR_BEAN_NAME)) {
		this.lifecycleProcessor =
				beanFactory.getBean(LIFECYCLE_PROCESSOR_BEAN_NAME, LifecycleProcessor.class);
		if (logger.isDebugEnabled()) {
			logger.debug("Using LifecycleProcessor [" + this.lifecycleProcessor + "]");
		}
	}
	else {
		DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor();
		defaultProcessor.setBeanFactory(beanFactory);
		this.lifecycleProcessor = defaultProcessor;
		beanFactory.registerSingleton(LIFECYCLE_PROCESSOR_BEAN_NAME, this.lifecycleProcessor);
		if (logger.isDebugEnabled()) {
			logger.debug("Unable to locate LifecycleProcessor with name '" +
					LIFECYCLE_PROCESSOR_BEAN_NAME +
					"': using default [" + this.lifecycleProcessor + "]");
		}
	}
}
 
/**
 * Return the internal LifecycleProcessor used by the context.
 * @return the internal LifecycleProcessor (never {@code null})
 * @throws IllegalStateException if the context has not been initialized yet
 */
LifecycleProcessor getLifecycleProcessor() throws IllegalStateException {
	if (this.lifecycleProcessor == null) {
		throw new IllegalStateException("LifecycleProcessor not initialized - " +
				"call 'refresh' before invoking lifecycle methods via the context: " + this);
	}
	return this.lifecycleProcessor;
}
 
@Test
public void customLifecycleProcessorInstance() {
	BeanDefinition beanDefinition = new RootBeanDefinition(DefaultLifecycleProcessor.class);
	beanDefinition.getPropertyValues().addPropertyValue("timeoutPerShutdownPhase", 1000);
	StaticApplicationContext context = new StaticApplicationContext();
	context.registerBeanDefinition("lifecycleProcessor", beanDefinition);
	context.refresh();
	LifecycleProcessor bean = context.getBean("lifecycleProcessor", LifecycleProcessor.class);
	Object contextLifecycleProcessor = new DirectFieldAccessor(context).getPropertyValue("lifecycleProcessor");
	assertNotNull(contextLifecycleProcessor);
	assertSame(bean, contextLifecycleProcessor);
	assertEquals(1000L, new DirectFieldAccessor(contextLifecycleProcessor).getPropertyValue(
			"timeoutPerShutdownPhase"));
}
 
/**
 * Return the internal LifecycleProcessor used by the context.
 * @return the internal LifecycleProcessor (never {@code null})
 * @throws IllegalStateException if the context has not been initialized yet
 */
LifecycleProcessor getLifecycleProcessor() throws IllegalStateException {
	if (this.lifecycleProcessor == null) {
		throw new IllegalStateException("LifecycleProcessor not initialized - " +
				"call 'refresh' before invoking lifecycle methods via the context: " + this);
	}
	return this.lifecycleProcessor;
}
 
@Test
public void customLifecycleProcessorInstance() {
	BeanDefinition beanDefinition = new RootBeanDefinition(DefaultLifecycleProcessor.class);
	beanDefinition.getPropertyValues().addPropertyValue("timeoutPerShutdownPhase", 1000);
	StaticApplicationContext context = new StaticApplicationContext();
	context.registerBeanDefinition("lifecycleProcessor", beanDefinition);
	context.refresh();
	LifecycleProcessor bean = context.getBean("lifecycleProcessor", LifecycleProcessor.class);
	Object contextLifecycleProcessor = new DirectFieldAccessor(context).getPropertyValue("lifecycleProcessor");
	assertNotNull(contextLifecycleProcessor);
	assertSame(bean, contextLifecycleProcessor);
	assertEquals(1000L, new DirectFieldAccessor(contextLifecycleProcessor).getPropertyValue(
			"timeoutPerShutdownPhase"));
}
 
源代码9 项目: lams   文件: AbstractApplicationContext.java
/**
 * Return the internal LifecycleProcessor used by the context.
 * @return the internal LifecycleProcessor (never {@code null})
 * @throws IllegalStateException if the context has not been initialized yet
 */
LifecycleProcessor getLifecycleProcessor() throws IllegalStateException {
	if (this.lifecycleProcessor == null) {
		throw new IllegalStateException("LifecycleProcessor not initialized - " +
				"call 'refresh' before invoking lifecycle methods via the context: " + this);
	}
	return this.lifecycleProcessor;
}
 
/**
 * Return the internal LifecycleProcessor used by the context.
 * @return the internal LifecycleProcessor (never {@code null})
 * @throws IllegalStateException if the context has not been initialized yet
 */
LifecycleProcessor getLifecycleProcessor() throws IllegalStateException {
	if (this.lifecycleProcessor == null) {
		throw new IllegalStateException("LifecycleProcessor not initialized - " +
				"call 'refresh' before invoking lifecycle methods via the context: " + this);
	}
	return this.lifecycleProcessor;
}
 
@Test
public void customLifecycleProcessorInstance() {
	BeanDefinition beanDefinition = new RootBeanDefinition(DefaultLifecycleProcessor.class);
	beanDefinition.getPropertyValues().addPropertyValue("timeoutPerShutdownPhase", 1000);
	StaticApplicationContext context = new StaticApplicationContext();
	context.registerBeanDefinition("lifecycleProcessor", beanDefinition);
	context.refresh();
	LifecycleProcessor bean = context.getBean("lifecycleProcessor", LifecycleProcessor.class);
	Object contextLifecycleProcessor = new DirectFieldAccessor(context).getPropertyValue("lifecycleProcessor");
	assertNotNull(contextLifecycleProcessor);
	assertSame(bean, contextLifecycleProcessor);
	assertEquals(1000L, new DirectFieldAccessor(contextLifecycleProcessor).getPropertyValue(
			"timeoutPerShutdownPhase"));
}
 
 类方法
 同包方法