Como integrar spring batch+spring boot+quartz

	
       @Bean
	@Scheduled(fixedDelay=5000)
	public Job importJob() {
		
		log.debug("Iniciando scheduler "+new SimpleDateFormat("dd/MM/yyyy HH:mm:ss.S").format(new Date()));
		
	    Job job = jobBuilderFactory.get("Job")
	            .start(step1())
	            .build();
	    return job;
	}
	
	@Bean
	public Step step1() {
		return stepBuilderFactory.get("step1").<Pojo, Pojo>chunk(10).reader(reader())
				.processor(processor()).writer(writer()).build();
	}
	

	@Bean
	public FlatFileItemReader<Pojo> reader() {
		FlatFileItemReader<Pojo> reader = new FlatFileItemReader<Pojo>();
		reader.setResource(new ClassPathResource("sample-data.json"));
		reader.setLineMapper(new LineMapper<Pojo>() {
			private final Logger log = LoggerFactory.getLogger(this.getClass());

			public PojomapLine(String line, int lineNumber) throws Exception {

				log.info("Iniciando o mapeamento json -> Pojo");

				Map<String, Object> sgvasPojoEntityAsMap = new JsonLineMapper().mapLine(line, lineNumber);

				Pojo pojo = new pojo();

				
				return pojo;
			}
		});

		return reader;
	}
	
	@Bean
	public ItemProcessor<Pojo, Pojo> processor() {
		return new ItemProcessor<Pojo, Pojo>() {

			private final Logger log = LoggerFactory.getLogger(this.getClass());

			@Override
			public Pojo process(Pojo pojo) throws Exception {
				log.info("Processamento do item");
				return pojo;
			}
		};
	}
	// end::readerwriterprocessor[]
	
	@Bean
	public JobExecutionListenerSupport jobCompletionNotificationListener() {
		return new JobExecutionListenerSupport() {

			private final Logger log = LoggerFactory.getLogger(this.getClass());

			@Override
			public void afterJob(JobExecution jobExecution) {
				log.info("execução após o termino do job");
				if (jobExecution.getStatus() == BatchStatus.COMPLETED) {
					log.info("!!! JOB FINISHED! Time to verify the results");
				} else if(jobExecution.getStatus() == BatchStatus.FAILED){
					log.warn("Job executado com erros, por favor analise os logs!");
			    }
			}
		};
	}

	// tag::jobstep[]
/*	@Bean
	public Job importPojoJob(JobExecutionListenerSupport listener) {
		FlowJob build = (FlowJob) jobBuilderFactory.get("PojoJob").incrementer(new RunIdIncrementer()).listener(listener)
				.flow(step1()).end().build();
		build.setRestartable(true);
		return build;
	}*/

	@Bean
	public ItemWriter<Pojo> writer() {
		return new ItemWriter<Pojo>() {

			private final Logger log = LoggerFactory.getLogger(this.getClass());

			@Autowired
			private RestTemplate restTemplate;

			@Override
			public void write(List<? extends Pojo> arg0) throws Exception {
				log.debug("Entrando no método write(List<? extends Pojo> arg0) throws Exception");

				for (Pojo pojo: arg0) {
					
					String retorno = restTemplate.postForObject(restUrlBonusConceder, pojo, String.class);

					log.debug(retorno);
				}
			}
		};
	}

	@Scheduled(initialDelay = 5000, fixedRate = 5000)
	public void reportCurrentTime() {
		log.info("The time is now {}", dateFormat.format(new Date()));

		try {

			JobParameters jobParameters = new JobParametersBuilder().addLong("time", System.currentTimeMillis()).toJobParameters();

			JobExecution jobExecution = jobLauncher.run(importPojoJob, jobParameters);
			
			log.info(jobExecution.getStatus().toString());

		} catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
				| JobParametersInvalidException e) {

			log.error(e.getMessage(), e);

		}

	}