How does Lifecycle interface work in Spring? What are "top-level singleton beans"?
You should use SmartLifecycle
instead of Lifecycle
. Only the former is working as you expected Lifecycle
to work. Make sure you return true in your isRunning()
implementation.
I have used SmartLifecycle
for asynchronous jobs for which it sounds like designed for. I suppose it will work for you but at the same time you may have a look at ApplicationListener
and events like ContextStoppedEvent
.
You can examine AbstractApplicationContext.doClose()
method and see that no interruption of application context closing has been provided by the Spring developers
protected void doClose() { boolean actuallyClose; synchronized (this.activeMonitor) { actuallyClose = this.active && !this.closed; this.closed = true; } if (actuallyClose) { if (logger.isInfoEnabled()) { logger.info("Closing " + this); } try { // Publish shutdown event. publishEvent(new ContextClosedEvent(this)); } catch (Throwable ex) { logger.warn("Exception thrown from ApplicationListener handling ContextClosedEvent", ex); } // Stop all Lifecycle beans, to avoid delays during individual destruction. try { getLifecycleProcessor().onClose(); } catch (Throwable ex) { logger.warn("Exception thrown from LifecycleProcessor on context close", ex); } // Destroy all cached singletons in the context's BeanFactory. destroyBeans(); // Close the state of this context itself. closeBeanFactory(); // Let subclasses do some final clean-up if they wish... onClose(); synchronized (this.activeMonitor) { this.active = false; } }}
So you can't prevent the application context from closing.
Testing the service with TestContext framework
If you are using Spring test context framework with JUnit, I think you can use it to test services that implement Lifecycle, I used the technique from one of the internal Spring tests
Slightly modified LifecycleBean(I've added waitForTermination()
method):
public class LifecycleBean implements Lifecycle { private static final Logger log = LoggerFactory .getLogger(LifecycleBean.class); private final Thread thread = new Thread("Lifecycle") { { setDaemon(false); setUncaughtExceptionHandler(new UncaughtExceptionHandler() { @Override public void uncaughtException(Thread t, Throwable e) { log.error("Abnormal thread termination", e); } }); } public void run() { for (int i = 0; i < 10 && !isInterrupted(); ++i) { log.info("Hearbeat {}", i); try { sleep(1000); } catch (InterruptedException e) { return; } } }; }; @Override public void start() { log.info("Starting bean"); thread.start(); } @Override public void stop() { log.info("Stopping bean"); thread.interrupt(); waitForTermination(); } @Override public boolean isRunning() { return thread.isAlive(); } public void waitForTermination() { try { thread.join(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); return; } }}
Test class:
@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration("classpath:Test-context.xml")public class LifecycleBeanTest { @Autowired LifecycleBean bean; Lifecycle appContextLifeCycle; @Autowired public void setLifeCycle(ApplicationContext context){ this.appContextLifeCycle = (Lifecycle)context; } @Test public void testLifeCycle(){ //"start" application context appContextLifeCycle.start(); bean.waitForTermination(); }}
Test-context.xml content:
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"><bean class="LifecycleBean"/></beans>
P.S. starting and stopping the context is not a thing you may want to do many times on the same application context, so you may need to put @DirtiesContext
annotation on your test methods for the best results.
Answer to the new version of the question
DefaultLifecycleProcessor uses beanFactory.getBeanNamesForType(Lifecycle.class, false, false);
to retrieve the list of the beans implementing LifecycleFrom getBeanNamesForType javadoc:
NOTE: This method introspects top-level beans only. It does not check nested beans which might match the specified type as well.
So this method does not list the inner beans (they were called nested when only xml configuration was available - they are declared as nested bean xml elements).
Consider the following example from the documentation
<bean id="outer" class="..."> <!-- Instead of using a reference to target, just use an inner bean --> <property name="target"> <bean class="com.mycompany.PersonImpl"> <property name="name"><value>Tony</value></property> <property name="age"><value>51</value></property> </bean> </property></bean>
Start() and Stop() are merely events that are propagated by the application context they are not connected with lifetime of the application context, for example you can implement a download manager with some service beans - when the user hits "pause" button, you will broadcast the "stop" event, then when the user hits "start" button, you can resume the processing by broadcasting the "start" event. Spring is usable here, because it dispatches events in the proper order.
I never used Lifecycle
interface and I am not sure how it is suppose to work. But it looks like simply calling start()
on context calls these callbacks:
AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("...");ctx.start();
However typically I use @PostConstruct
/@PreDestroy
annotations or implement InitializingBean
or DisposableBean
:
public class LifecycleBean implements InitializingBean, DisposableBean { @Override public void afterPropertiesSet() { //... } @Override public void destroy() { //... }}
Notice I don't call close()
on application context. Since you are creating non-daemon thread in LifecycleBean
the JVM remains running even when main
exits.
When you stop that thread JVM exists but does not close application context properly. Basically last non-daemon thread stops, causing the whole JVM to terminate. Here is a bit hacky workaround - when your background non-daemon thread is about to finish, close the application context explicitly:
public class LifecycleBean implements ApplicationContextAware /* ... */ { private AbstractApplicationContext applicationContext; @Override public void setApplicationContext(ApplicationContext applicationContext) { this.applicationContext = (AbstractApplicationContext)applicationContext; } public void run() { for(int i=0; i<10 && !isInterrupted(); ++i) { log.info("Hearbeat {}", i); try { sleep(1000); } catch (InterruptedException e) { } } applicationContext.close(); }}