code: @Override
  	public void started(ServiceBroker broker) throws Exception {
  		super.started(broker);
  
  		// Create shared executor provider
  		defaultExecutorProvider = new ExecutorProvider() {
  
  			@Override
  			public final boolean shouldAutoClose() {
  				return false;
  			}
  
  			@Override
  			public final ScheduledExecutorService getExecutor() {
  				return scheduler;
  			}
  
  		};
  	}
docs: --- START ---