org.springframework.xd.dirt.plugins.job

Class BatchJobRegistryBeanPostProcessor

java.lang.Object

org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, XDJobListenerConstants

public class BatchJobRegistryBeanPostProcessor
extends org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor
implements org.springframework.beans.factory.BeanFactoryAware, XDJobListenerConstants

JobRegistryBeanPostProcessor that processes batch job from the job module.

Author:

Ilayaperumal Gopinathan

Field Summary

Fields inherited from interface org.springframework.xd.dirt.plugins.job.support.listener.XDJobListenerConstants

CHUNK_EVENTS_SUFFIX, ITEM_EVENTS_SUFFIX, JOB_EXECUTION_EVENTS_SUFFIX, SKIP_EVENTS_SUFFIX, STEP_EXECUTION_EVENTS_SUFFIX, XD_AGGREGATED_EVENTS_CHANNEL, XD_CHUNK_EVENTS_CHANNEL, XD_CHUNK_LISTENER_BEAN, XD_ITEM_EVENTS_CHANNEL, XD_ITEM_LISTENER_BEAN, XD_JOB_EXECUTION_EVENTS_CHANNEL, XD_JOB_EXECUTION_LISTENER_BEAN, XD_JOB_LISTENERS_SUFFIXES, XD_SKIP_EVENTS_CHANNEL, XD_SKIP_LISTENER_BEAN, XD_STEP_EXECUTION_EVENTS_CHANNEL, XD_STEP_EXECUTION_LISTENER_BEAN

Constructor Summary

Constructors

Constructor and Description
BatchJobRegistryBeanPostProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
java.lang.Object	postProcessAfterInitialization(java.lang.Object bean, java.lang.String beanName)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setGroupName(java.lang.String groupName)
void	setJobLocator(DistributedJobLocator jobLocator)
void	setJobRegistry(org.springframework.batch.core.configuration.JobRegistry jobRegistry)

Methods inherited from class org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

afterPropertiesSet, getGroupName, postProcessBeforeInitialization

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchJobRegistryBeanPostProcessor

public BatchJobRegistryBeanPostProcessor()

Method Detail

setJobRegistry

public void setJobRegistry(org.springframework.batch.core.configuration.JobRegistry jobRegistry)

Overrides:

setJobRegistry in class org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Overrides:

setBeanFactory in class org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

Throws:

org.springframework.beans.BeansException

setJobLocator

public void setJobLocator(DistributedJobLocator jobLocator)

setGroupName

public void setGroupName(java.lang.String groupName)

Overrides:

setGroupName in class org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

postProcessAfterInitialization

public java.lang.Object postProcessAfterInitialization(java.lang.Object bean,
                                              java.lang.String beanName)

Specified by:

postProcessAfterInitialization in interface org.springframework.beans.factory.config.BeanPostProcessor

Overrides:

postProcessAfterInitialization in class org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Overrides:

destroy in class org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor

Throws:

java.lang.Exception