Search:

Hi,

I'm trying to write an Aspect that proxies all method implementation of the following interface:


public interface ContentConverter<T> {

public T...

Hi,

Is it possible to register channel interceptors using annotations?

Thanks,
Shahar

OK. Thanks.

Thanks Osvaldas.
I want to make sure I got it right. So if I had configured two beans which are assignable to HarvestedDocument then spring will inject both (as a collection) to objectQueue?
...

Hi,

I'm trying to inject to one of my beans a Queue<HarvestedDocument>. I've written the following code in a factory class:


@Configuration
public class ObjectsQueueFactory {

private...

Hi,

I have the following configuration in my application:



<task:executor id="RequestExecutionPool" pool-size="5-20"
queue-capacity="0" rejection-policy="CALLER_RUNS" />
...

Hi Oleg,

The thing is that in our system nothing is really low-priority but rather "slightly-lower" :).
I really need a more fine tuned adjustment of the way items are prioritized. Using variable...

Mark,

Thanks for the task-executor idea (actually it reminded me that I forgot to assign my task-executor :)).

Regards,
Shahar

Hi Oleg,

I'm not sure I understand your post. I don't have any trouble making the queue distributed with HazelCast. The ref to "DistributedQueue" in the configuration excerpt above is already...

We preferred grid-based distribution and redundancy over JMS. JMS is not easily scalable in opposed to grid-based technologies.
Are you proposing other options because the solution above is not...

Yes. A priority-queue is not good for 2 reasons:
1. The queue has to be a distributed queue. I'm not using a simple queue but rather a HazelCast queue. HazelCast does not have a priority queue...

And I could probably also use the max-messages-per-poll attribute in order to poll more messages from high-priority channels, right?

I'm thinking of using the following configuration:


...

Hi Mark,

The idea is to be able to prioritize between channels without causing starvation on one\some of the channels. So I want to be able to poll from channels according to some predefined...

Hi,

I need some kind of mechanism for polling multiple channels (according to a certain strategy determined by the user). I was thinking of extending the AbstractPollingEndpoint in a way quite...

I've opened a JIRA issue: https://jira.springframework.org/browse/INT-1511.

Thanks!

Oh shit... I missed the point where Oleg asked me to open a Jira issue and not put all the details in the forum (like I did). I'll do it now.

I'm not reading files with .writing extension. On the contrary, I'm trying to read files without the extension but the outbound-gateway has not finished writing (or maybe failed to rename).

You...

Hi Oleg,

I do not have a specific scenario is which it is reproduced consistently.
Our system, in which the bug reproduces quite often, is something like this:
1. Have some class read the...

Hi,

I'm encountering a race condition when using the following configuration:



<file:outbound-gateway id="FileStreamGateway"
directory="file:${repository}"...

Works perfect! Thanks again.

Thanks! I'll check that out.

Thank you for the idea! I'm not too familiar with restrictions in XML schema, but the concept seems to be promising.

Regarding your last comment - not all of my application code is plagued with...

Thanks Mark!

It's good to know that the header enricher supports dynamic values as well.
Is it possible to map method arguments (let say of a gateway interface) to the payload/header using...

Hi,

I have a general question regarding headers: what are the ways to add custom headers to a message?
The ones I know of:

Header enricher: good only for adding headers with static values?
...

The whole idea is to let the user choose whether to use placeholders or not. In most cases, the user won't externalize attributes to properties files. In these cases type validation can be very...