Search:

This works perfectly. Thanks for the assistance.

I have a method that looks similar to:



@RequestMapping(value = "/lists/{listid}/items/{itemid}", method = PUT)
public
@ResponseBody
Item updateItem(
@PathVariable...

Just fyi, I fixed this by putting a ValidationMessages.properties file in the root of the classpath.

I don't think the hibernate validator I'm working with will work with the messageSource. I did...

Is it because I haven't put the context loader listener into my web.xml?

I suspect so but I would like to get some clarity on this if someone will indulge me.

Many thanks,
Matt

Hi,

I have a validator that builds a constraint template with the usual code surrounded by {}. It seems quite typical.



if (!value.matches(regex)) {
...

Really interesting. We may need to scale in this manner as well. Thank you very much.

That is good to know but in this case I have a few different object streams that run sequentially and I want each one to start after the previous one has completed. So expireOnDestroy would only...

I need the application's main thread to sleep for some time while the reapers clear the remaining groups in the SimpleMessageStore.

I've come to the conclusion that when the message stores are...

Indeed. I am learning and it finally occurred to me to do this with delayer. I delay and then reduce the sequenceSize by 1 until the objects can be aggregated. It works great now.

Thanks for...

Sorry to be a bother but I'm not sure I'm getting this.

I have an aggregator that should aggregate objects A, B, C. Object A is required. B and C are optional. Sometimes B and C arrive before A....

So just to clarify for myself, if the code above is executed according to the if stmt the message group will be expired, whereas if not, the message group will NOT be expired?

In other words,...

I would like to be able to provide an alternate expiry procedure that is similar to the existing one in AbstractMessageGroupStore.

My goal is to have the message groups expire after a timeout,...

Looks like that would work for me. Great!

Thanks for this. However, I don't really know what the initial delay will be. It can vary depending on the size of the data set. It isn't predictable.

That's why I opted to be able to pause the...

Here's an idea. I will attempt to use the control bus to pause and unpause the reaper. This way I don't have to try to futz with the scheduler. Please let me know if this looks reasonable. Thanks.
...

Hi,

In the application I'm working on the objects are fetched from a database. The queries use cursors. Once the query plan is ready the data arrives in a constant stream. However, at the...

Hi Gary,

You've given me a few good options to think about so thank you. I'll take another kick at the can however and see what you think.

To clarify, the data arrives from the message...

I have a series of objects that I want to send into SI. They are ordered by the ID of each object, so I can create a correlation id for each related set of them. They arrive in order one after the...

Yes, it works now. This is very good. Thanks so much for the help.

I want to process the objects 10 at a time, and then process whatever is left over at the end. In this case there would be 2 groups of 10 and one group of 5. (25 messages overall)

The example I...

I've been trying to reproduce the behaviour shown at this github page:
https://github.com/olegz/s12gx.2011/tree/master/src/test/java/org/springone2gx_2011/integration/aggregator

However, I see...

Is it possible to call a method that will release messages from a message store on demand, rather than waiting on a timeout for message groups that have not yet reached the sequence size?

JdbcUserDetailsManager has a method: JdbcUserDetailsManager.alterUser(UserDetails); this method contains code to update the existing authorities with the authorities contained in the UserDetails...

Thanks very much for this clear answer. After reading the manual a few times I still wasn't clear on this. Notes like this in the manual would really help a newbie like me.

Many thanks,
Matt

We have a long running application that uses Aggregator. The system continuously adds items through a gateway. All incoming items have a sequence size of 5, a matching correlation id for the group,...