Search:

It does sound like you might want to consider only having a single active poller (by setting auto-startup=false but manually starting one of them, maybe via a control bus message). Then you would...

You can add an advice-chain to the poller (via the <poller> element's advice-chain attribute), and that allows you to provide Advice that wraps the poll operation. There you could add the lock...

We do have a SpringSecurity-based Channel Interceptor that can be applied to any channel, but that will expect the SecurityContext to have been established upstream (e.g. via a SpringSecurity...

Sorry, that class is in the spring-batch-infrastructure-tests module. It is not deployed in Maven central, but you can copy that code directly and try it within your app. We know that others have...

Try replacing "Status-Code" with HttpHeaders.STATUS_CODE (from org.springframework.integration.http.HttpHeaders).

@Value is used for injection of values that are available at configuration time whereas "headers" are available per-Message instance at runtime.

Could you provide a little bit more context about...

Spring Batch provides something along these lines:
http://static.springsource.org/spring-batch/apidocs/org/springframework/batch/container/jms/BatchMessageListenerContainer.html

Antony,

We are actually working on a few things for Spring Integration 3.0 that will be directly relevant. For example, we will support parameterizable flow definitions (modules) that can be...

You can create the ApplicationContext and then grab the 'requestChannel' from it within the main. Or you can add a gateway and inject that:...

This section of the reference manual should clear it up (especially the XML config excerpt which should be all you need):...

One other point: the most efficient settings for a thread pool are usually based on the number of cores on a machine (e.g. n+1) IF the tasks being handled are CPU-bound (not blocking I/O). So, in the...

Glad to see that you're on the right track now. I've added a JIRA issue so that we'll be sure to highlight this requirement for explicitly named queues (if redeclaration is expected) within the...

Sure, that should work. The two main options in terms of what you export to the service-registry from the Spring Integration side would be a Message Channel or a Gateway. This blog is a bit old, but...

Yes, you can use both blueprint and SI configuration files.

If the only "endpoints" for your backend app are the adapters connecting to JMS queues, then you don't need to run in a servlet container... the logical spring container (ApplicationContext instance)...

Thank you for reporting this. Could you please create a JIRA issue for it?, and even better issue a PR as well:
https://github.com/SpringSource/spring-integration/blob/master/CONTRIBUTING.md
...

What you pass needs to conform to the JMS spec for selectors (i.e. that syntax is pure JMS, not related to Spring Integration at all). Read the "Message Selectors" section here for more info:...

I don't think those classes ever existed in a Spring release. They were in a sandbox prototype in the Spring 1.x days many years ago IIRC.

The way to work with JMS via Spring is through...

A MessageProducer is created from a Session which is acquired from a Connection which is established via a ConnectionFactory.

That chain is precisely what JmsTemplate handles for you, AND with...

I also replied on your StackOverflow thread, but will add the same here....

I think you may be referring to some very old posts that were written before Spring added support for caching resources...

Can you explain why you can't use JmsTemplate?

If you are willing, upgrading to the latest snapshot version of STS *should* take care of those warnings. But as Artem mentioned, the version on the classpath is always used at runtime.

Anoop,

It does sound like a useful feature. For now, you should be able to use <splitter ref="fileSplitter" .../> and then have a "fileSplitter" bean that takes a path and returns the...

Each listener has 1 thread or N threads if you set the concurrent-consumers value to N. That's the main factor.

You *can* however share a listener for multiple queues (specify a comma-delimited...

Can you show the "messageHandler" bean's "handleMessage" method?