EdeeUI

V commandu:

@Autowired private EdeeUiAsyncConversationManager conversationMgr;

public Resolution perform(..) {
	conversationMgr.addConversation(
		new UiConversation() extends Conversation implements ApplicationListener {

			public void onEvent(Application event) {
				if (event instanceof BatchStoredEvent) {
					super.newMessage(....)					
				}				
			}			

		},
		new TimeToLiveChecker(1000 * 60 * 60)
	);
}

Samozřejmě místo TimeToLiveCheckeru by mohlo být něco jako:

new ThreadStateChecker() { ... tady se budu ptát threadu, jestli už skončil ... }