class DefaultListenerService implements ListenerService, InitializingBean {

    @Override
    public void activateListener(final String beanName, final Boolean forceActivation) {
        if (this.applicationContext.containsBean(beanName)) {
            final Listener listener = this.applicationContext.getBean(beanName, Listener.class);
            if (ListenerStatus.ACTIVE.equals(listener.getListenerStatus()) && Boolean.FALSE.equals(forceActivation)) {
                log.info("Listener: {} already running", beanName);
            } else {
                listener.start();
            }
        }
    }

    public  DefaultListenerService(final BeanRegistrar beanRegistrar, final JobRegistry jobRegistry, final JobRepository jobRepository);

}