question: protected void init ( ) throws Exception { JetstreamApplicationInformation ai = getApplicationInformation ( ) ; ai . selfLocate ( ) ; m_workQueue = new LinkedBlockingQueue < Runnable > ( ai . getWorkQeueSz ( ) ) ; m_worker = new ThreadPoolExecutor ( ai . getWorkerThreads ( ) , 3 , 30 , TimeUnit . SECONDS , m_workQueue , new ThreadPoolExecutor . CallerRunsPolicy ( ) ) ; m_worker . prestartCoreThread ( ) ; Management . addBean ( ai . getApplicationName ( ) , this ) ; logInfo ( "Starting services for " + ai ) ; String [ ] configs = ai . getConfigRoots ( ) ; RootConfiguration rc = configs == null ? new RootConfiguration ( ai ) : new RootConfiguration ( ai , configs ) ; rc . start ( ) ; String [ ] sa = ai . getBeans ( ) ; if ( sa != null ) for ( String bean : sa ) rc . getBean ( bean ) ; }
target:  Override this method to do initialization in a custom JetstreamApplication.