Search:

Hi,
I'm using spring-rabbit in my message consumer. I've implemented a dead-letter exchange and queue system to collect any messages that could not be processed. Please suggest me a good mechanism...

Hi,
I'm using spring integration amqp. I have a doubt about the advice chain attribute of channel adapter. I had configured it as follows.



<int-amqp:inbound-channel-adapter...

Sorry for not being clear before.Monitor in the sense that alert my system if consumer goes down or if there is a high traffic in the system and maybe to provide logging system.

Hi,
I'm using spring amqp to process messages from a rabbtimq message broker. Can any suggest me a good tool to monitor the messaging system. I've come across Zabbix and Nagios. which one is better??

Thanks a ton cleric.
That did the job for me . :)

Hi,
@cleric @gary,
I've implemented

I have multiple inbound adapters.But I need some mechanism to route message from my Dead Letter Exchange to different queues. How can I achieve this. Is...

Hi all,
I am using spring integration with amqp. I need to route my error messages into rabbit queues after my retry interceptor advice chain has done retry.
How can I specify an error channel in...

Thanks for the advice mate. :)

Hi all,
I'm using spring amqp as my message listener.


WARN | SimpleAsyncTaskExecutor-1 | o.s.amqp.rabbit.listener.SimpleMessageListenerContainer | Consumer raised exception, processing can...

Hi all,
Is there any way that we can preserve the order of messages in the queue while using a exponential backoff policy.We are running multiple instance of queue consumers.

Thanks,
Tec

Thanks cleric. That did the job for me. Although I had to dig out "myexception" from context.getLastThrowable() .

cheers :)

Hi all,
I need to implement a custom retry template in my spring integration project.What I am trying to achieve is to retry my messages using a backoff policy and I need to avoid the retry if it is...

I'm confused.
can u explain the use ApplicationContextAware interface? :)

Hi,
How can I use the same application context in multiple function in a program?


What i actually need to do is this : I have an application context defined in my main function.I need to use...

Hi..i'm using spring java based configuration for bean defnition.wen i try to loead a bean it is not found...

my configuration file


@Configuration
public class AddConfiguration {

...

Hi,
I'm using spring amqp with rabbitmq as my message broker.How can u acknowledge the message from the queue manually after processing it (using simplemessagelistneradapter)?