Search:

Hello All,

I'm using the RabbitTemplate (via the Grails RabbitMQ plugin) and am subscribed to a queue with acknowledgeMode = MANUAL.

I'm trying to find the appropriate way to manually...

Thanks for the prompt response Gary. Given that the CachingConnectionFactory is the reason, I'm surprised that the following terminates w/o the System.exit nor the connectionFactory.destroy()


...

Hello All,

I'm looking at a very simple example sending a message using AmqpTemplate#convertAndSend. I don't understand why the program won't terminate w/o an explicit System.exit(0).

Is it...

Thanks Gary, I think I have it now and I really appreciate your help.

One further question - could you please elaborate on the "send-timeout" for an Aggregator described as:

"The timeout...

Thanks Gary, that's just what I was looking for!

--john

Hello All,

I'm trying to configure a simple aggregator which will correlate based on the value in the header key "CORRELATION_ID" and release if no new messages have arrived w/in 3 seconds. Going...

Hello All,

I have a file outbound channel adapter configured as below and am finding that the files generated have the complete message written to them including the header, e.g.


[Payload=Sat...

Perfect! just specifying the method in the splitter works fine. My input-channel is not explicitly typed, but is passing java.io.File.

Thanks for being so helpful with my questions.

--john

Thanks again Cleric, I really appreciate your help in understanding this.

I'm still confused on why I'm having trouble using a Groovy class instead of a Java class. Here's the situation:

1) a...

Thanks for your reply Cleric.

Based on your suggestion, I changed from lang:groovy to int-groovy:script, e.g.

<int:splitter input-channel="channel1" output-channel="channel2">
...

Hello,

My question seems similar to the one asked about the Router, but I cannot seem to get that proposed solution to work.

In my case, I'd like to use a Groovy bean as a Splitter. I've...

Thanks again Gary, that helps. I think I'll go a different direction though and just use maven or gradle to execute the program (and manage the classpath).

--john

Thanks Gary.

The answer is essentially yes - it's my understanding that's what the maven assembly plugin is doing is to create a single jar with all dependencies.

However, I may be...

Thanks for your reply Amol!

This is a single jar containing all dependencies and produced by maven assembly. The *.xsd files are in packages rooted at the top level of the jar. Do I understand...

Hello All,

I created a small Spring MVC/Spring Integration standalone application which I packaged into a a JAR with dependencies. When I try to run the main program, specifying the JAR in the...

I seem to have gotten around this problem by specifying the isolation-for-create attribute on the jobRepository, e.g.

<batch:job-repository id="jobRepository"...

Hello All,

I'm using Spring Batch 2.1.8 and getting the exception below when trying to run a single job. I saw references in the forum to the same error, but they appeared to be when running...

perfect - thanks for the explanation!

--john

Hello All,

I'm new to Spring-Integration and a little confused about the need to explicitly define channel elements to connect two other elements. For example, the following seems to work...

Perfect! thanks for your quick response and sorry I'd overlooked something so obvious.

--john

Hello All,

I'm trying to follow Mark Fischer's very nice blog post (http://blog.springsource.com/2009/02/13/982/) but using 2.0.3 rather than the 1.0.1 that it was written for.

Could someone...

Hello All,

I'm trying to inject into non-Spring beans and have marked the target class w/ @Configurable. I put "<aop:spring-configured />" into my ApplicationContext file, but it doesn't seem to...

Hello All,

I'm trying to use Spring 2.5.6, Ibatis 2.3.4, and Oracle w/ Spring's DAO support. It seems that I'm not getting the transactional behavior I'd expect in my DAO.

In one of the DAO's...