/**
    * Copyright By Grandsoft Company Limited.  
    * 2012-2-6 下午04:42:39
    */
   package gboat2.cxf;
   
   import gboat2.base.core.ActivatorInnerThread;
   import gboat2.cxf.business.IWebServiceConfigBusiness;
   
  import org.apache.commons.lang3.time.DateUtils;
  import org.osgi.framework.BundleActivator;
  import org.osgi.framework.BundleContext;
  import org.osgi.framework.ServiceReference;
  import org.osgi.util.tracker.ServiceTracker;
  
  /**
   * Bundle 启动类
   * @author zhaic
   * @since jdk1.6
   * @date 2012-2-6
   */
  public class Activator implements BundleActivator {
  	
  	private ServiceTracker<IWebServiceConfigBusiness, Object> tracker;
  	
  	@Override
  	public void start(final BundleContext bundleContext) throws Exception {
  		tracker = new ServiceTracker<IWebServiceConfigBusiness, Object>(bundleContext, IWebServiceConfigBusiness.class.getName(), null) {
  			@Override
  			public Object addingService(final ServiceReference<IWebServiceConfigBusiness> ref) {
  				new ActivatorInnerThread(DateUtils.MILLIS_PER_MINUTE * 2) { //延迟两分钟，不然查库返回空，有可能是 PO 还没有注册成功
  					@Override
                      public boolean task() {
                          IWebServiceConfigBusiness busi = bundleContext.getService(ref);
                          busi.startPublishAndTrackWebService();// 开始发布web服务
                          tracker.close(); // 无需再跟踪，关闭跟踪器释放资源
                          tracker = null;
                          return true;
                      }
  				}.start();
  				
  				/*
  				IWebServiceConfigBusiness busi = (IWebServiceConfigBusiness) bundleContext.getService(ref);
  				busi.startPublishAndTrackWebService();//开始发布web服务
  				tracker.close();//无需再跟踪，关闭跟踪器释放资源
  				tracker = null;
  				*/
  				return super.addingService(ref);
  			}
  			
  		};
  		tracker.open();
  	}
  	
  	@Override
  	public void stop(BundleContext bundleContext) throws Exception {
  	    /*
  		IWebServiceConfigBusiness cxfSer = (IWebServiceConfigBusiness) SpringContextUtil.getInstance().getBeanOfId(
  		        "cxfBusinessSer", bundleContext.getBundle());
  		if (null != cxfSer) {
  			cxfSer.unpublishAllServices();
  		}
  		
  		if (null != bundleTracker) {
  			bundleTracker.close();
  		}
           */
  	}
  }