Search:

Anyone help me? will be appreciated.

Thank you very much for clear my confusion, mminella.

Cheers.
--Jason

I wonder what's the deference between Spring Batch & Hadoop? looks like they all focus on Big Data & parellel processing.

Thanks for you guys provided above good stuffs for beginners like me.
...

In my email send app, I use Spring AMQP storing email message that come from upper apps(exposing a REST to them). then fetch email message from queue and sending it to SMTP Server through Spring...

Some code like this:


public class A {

@Autoware
private B b;

public void a() {
//AAA: some logic process that maybe throw exception

thanks Gary.

I searching the web found that in rabbit-java-client API there is a method maybe can use to find a queue's depth:...

Thank you, Gary.

The priority of message is very annoying indeed.

x-dead-lettter-exchange argument should add to the original queue. And, you also need Binding a DLQ(dead-letter queue) to DLX. like this:

Both Producer & Consumer side:


<rabbit:queue...

Beautiful, Marten - thank you very much!

Cheers.
-Jason

Today i posted two threads about spring-amqp, one is success posted:

http://forum.springsource.org/showthread.php?133798-Dynamic-adjust-instances-of-concurrentConsumers

But another issue that...

I noticed that SimpleMessageListenerContainer has a property - concurrentConsumers; I use it to setting the count of concurrent consumers:


<rabbit:listener-container...

Since currently rabbitmq not support the priority of message, i use separate queue for per priority-message. for example, queue.priority.low & queue.priority.high. And every queue has its respective...

Thank you very much, Gary. How warm-hearted you are!

So i can't modify the original message, even the MessageProperties or headers of it?

Thanks for reply, Gary.

Yes, i increased the channel-cache-size to 4 since i need some consumers that also need channel instance separately.

I dig out a post that you posted on another...

As a amqp-client, spring-amqp really done a pretty nice job in my mq-based email app. Thanks all of spring-amqp-team.

I use Dead Letter Exchange(DLX) and spring-retry for the bussness exceptions...

I encounter this problem too. that's what i solved it:

Because spring-amqp wrap business exceptions into ListenerExecutionFailedException, So we register wrapped business exceptions instead of...

I am integrating Spring-amqp into my email-app.

In my amqp config xml-file, I just declare a rabbitTemplate like this:

<rabbit:template id="rabbitTemplate"...

i use CachingConnectionFactory & also encounter this problem.
and interface ConnectionFactory not provide a destroy() or close() method invoke,but its subclass AbstractConnectionFactory have ,so i ...