Starten von Spring batch job

• Ich habe ein problem wo ich brauche, um zu erhalten eine Reihe von Nachrichten aus einem MQ-Warteschlange und schreiben diese in eine Datei und beginnen Sie eine spring-batch-job mit der Datei als Eingabe

Einer Art und Weise zu tun wäre, sich auf ein bisschen Frühling Integration, wo Sie hätten eine Datei, die poller würden Umfrage für eine neue Datei:

<file:inbound-channel-adapter id="filePoller"
                              channel="filesAreComing" 
                              directory="file:${input.directory}"
                              filename-pattern="test*" />

Anzupassen file message ( java.io.Datei ) zu einem file name ( String ), denn das ist das, was Spring Batch braucht. Diese kann getan werden, mit einem JobLauncher adapter, das ist schon verfügbar von Spring Batch Admin hier:

@ServiceActivator
public JobLaunchRequest adapt(File file) throws NoSuchJobException {

    JobParameters jobParameters = new JobParametersBuilder().addString(
            "input.file", file.getAbsolutePath()).toJobParameters();

    return new JobLaunchRequest(job, jobParameters);
}

wickeln Sie es um ein JobLaunchRequest ( das ist nur ein Halter für eine Job und JobParameters ) und senden diese Anfrage als [eine Nachricht], um JobLaunchingMessageHandler:

<service-activator input-channel="jobLauncher">
    <beans:bean class="org.springframework.batch.integration.launch.JobLaunchingMessageHandler">
        <beans:constructor-arg ref="jobLauncher" />
    </beans:bean>
</service-activator>

dass sich bringen würde, den job.

"- Eingang.Datei" ist ein parameter, der gebunden ist, zur Laufzeit ( also #{...} ):

<bean id="reader" class="org.springframework.batch.item.file.FlatFileItemReader" scope="step">
    <property name="resource" value="#{jobParameters[input.file]}" />
    ... line mapper and other props
</bean>