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);
}

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 ) ; }
override this method to do initialization in a custom jetstreamapplication .
