Search:

Hi,
I kind of have a weired requirement where System engineer will want to suspending queue consumers(not stop).

The cases for suspending consumers can be as follows :
System Engg temporily...

Hi cogitate,

Just in case you are using spring-amqp:inbound-gateway, the SPRING_REPLY_CORRELATION is alrady handled for you by DefaultAmqpHeaderMapper.
check...

thanks Gary,
I figured it out. basically rabbit lets one identify the the cause for dead lettering,infact it give a detailed list of things happened with the 'declared dead' message. all these...

Hi ,

When a consumer throws AmqpRejectAndDontRequeueException, message is reject and delivered to dead letter exchange,
Similarly when the life of the message in queue becomes > x-message-ttl...

Hi In one of my projects i am using amqp gateway for doing a request/response kind of activity.

My amqp gateway has a message conveter and is connected to a router, and service activtor down...

Thanks Gary,
I am now throwing AmqpRejectAndDontRequeueException as the cause of my message conversion exception and it worked well.
If no DLE is configured, the rouge message are removed from...

Hi I have configured an amqp gate way with my own custom message converter.
When ever a messageconversion exception is thrown, I am seeing that the gateway is not sending a NACK or ACK to the broker...

Hi I want to set x-expire time for the queues which are created in rabbit
and i am using <rabbit:queue> tag for the same. But looks like rabbit/spring takes the value as string and is not able...

I have a similar requirement , where my clients sends soap messages over AMQP and uses Rabbit broker.
My services could either be a legacy service written on CXF (jax ws endpoint), or a POJO...

i get this exception whien i try to configure a header mapper for my int-amqp:outbound-gateway.

I am using 2.1.0.RELEASE version of spring integration.




java.lang.NoClassDefFoundError:...

Basically posted from Spring integration main forum as this is related to AMQP

Hi

In one of my project, I need to use SOAP over AMQP and XML(text) over AMQP , i.e send soap messages over a AMQP...

Hi

In one of my project, I need to use SOAP over AMQP and XML(text) over AMQP , i.e send soap messages over a AMQP transport (instead of http).

My approch is to use AMQP inbound/outbound...

May be is there a good payload-expression which i can use in the method tag?

Hi

I have an interface like this


package com.me.mystuff;
interface Appender
{

public String append(String s1,String s2,String s3)

Is there a way to do hot deploy in non osgi environment?

if you are talking about the reply queue. you can set the replyTo property in the message header using an header enricher. This way all reply messages will be sent back to the queue you have...

Do you mean temporary channel?
Amqp gateway always works with the queue name you have specified.

Hi ,

I realized that in about 70% our use cases we need a certain combination of spring integration components/handlers (e.g amp gateway, xml or jason transformer, a payload type router and few...

Hi All,

I am trying to build my services stack backed by spring integration and AMQP. One of our goal is to have a fine grained control of each service (i.e we should be able to...

Hi All,

I am trying to build my services stack backed by spring integration and AMQP. One of our goal is to have a fine grained control of each service (i.e we should be able to...

Thanks Mark,

It worked with RC1.0. I had to create my own header mapper and seth the replyHeaderNames and requestHeaderNames.


With JDBCMessageStore (derby) my program do not throw out of...

Here is the stack trace

ERROR [org.springframework.integration.handler.LoggingHandler] - <org.springframework.integration.MessageHandlingException: error occurred in message handler...

Thanks Amol, The im memory (simple message store) looks like the culprit, I used jprofiler to profile the heap dump and AggregatingMessageHandler to be the biggest object using around 96% of ...

With reference to my previous thread of having performance issues while handling group of large messages
refer...

Thanks Amol, i will try this out. But what i also noticed is, my heap groups very large. I have lot of full gc happening ( full gc's run up 2 to 5 secs). And after a point in time, all my threads are...