Search:

I don't know if this could be of somebody interest but that's the only solution I have found to do this.

I have extended the HibernatePagingItemReader and I have overrided the doReadPage() method....

Reading the sorce code of AbstractPagingItemReader which is the parent of HibernatePagingItemReader I have seen that there is a "current" instance variable that is incremented previous to the actual...

I have a chunk tasklet that use as reader a custom reader. The custom reader has as a property an HibernatePagingItemReader that is used to read pages of data from database, do some grouping process...

Hi,

I have queue channel defined as:



channel id="myChannel">
<queue capacity="100"/>
</channel>

Thanks for your replies. Yes, I think ThreadLocal with prototype scoped beans its the solucion to my problem as I have multiple threads executing multiple jobs, but each job is single-threaded. I...

I have the next requirement. At some hour I have to do some process and after it, I have to SFTP some files, process them and if all OK, delete from the SFTP Remote Server (I can't delete them at...

Hi bleacherseat,

I think skip listeners are only called when the transaction of the chunk is commited. This is because if there is a rollback you don't really have written the chunk yet , so you...

Thanks for the idea, chori. I don't really like to left FAILED my jobs because it could be confusing. Finally as my job hasn't to be restartable but runnable, I create a new jobInstance every time...

Hi,

I'm using 2.0.4, I really didn't know there was a new release.

Thank you all for your help. I think the gateway will be the best solution. As oleg said, in synchronous mode the exception...

Thats a summarize of the code

The spring integration config regarding this case



[...]
<channel id="channel1">
<queue capacity="1000"/>
</channel>

I hava a doubt about synchronous - asynchronous messaging and error handling.

I have a service that send a message to a channel that is connected to an SFTP Outbound Adapter. I have a try-catch...

I don't know if the JobParametersIncrementer solution is valid for me. Like matthewadams, I need rerunnability in my jobs. I have a daily job with, to simplify, two parameters: A partner id and a...

As I can't use the headerCallback to write more than one header in the same file, I have tried to implement a ItemWriter that in the write method creates a List with one String (the Header) and...

I have a job that reads from a database and writes to a flat file. In one step I read the database data, process the data and write registers to the file. While processing I need to collect some...

I have the same problem. I'm filling a text file in two steps, because it has two kind of registers groups (several registers per group). Each one of this groups has to be between a header and a...