[rabbitmq-discuss] Alternate Exchange Configuration Issue

Tue Jan 25 14:24:02 GMT 2011

Hi ,

My bad . I had declared the exchange in the producer and did not
declare my alternate exchange there. Once I declared the exchange
properly unroutable messages were pushed to Alternate exchange.
I have a generic question though. In this scenario where I know all un
routable messages are in exchange ,can I somehow publish it back to my
original exchange( guess I need to simply use basicPublish with the
exchange name ) after a latency of somet time ?

My requirement as my earlier question in the forum is to tackle slow
consumers ( consumer that needs to perform some logic with remote
servers and there may be several reasons why the consumer can be
slow). I could either perform some checks to see if my remote server
is alive and then process the messages or use Lease Queue
approach.What I understood from the documentation is
1) Lease Queues
2) Per Queue TTL

Both of these approach  times out queue and message ( does that mean
all my  messages are lost or are they requed back in exchange ).
Please suggest.

Regds
Prashant

On Jan 25, 1:30 pm, Prashant <praya... at gmail.com> wrote:
> Hi ,
>
> the snippet you see is what I was referring to( from rabbitMQ site). I
> have defined an exchange called 'exchange' and declared it with
> arguments as in the code snippet.(groovy)
>
>         exchangeName = 'exchange'; queueName = 'myQueue'
>         args = new HashMap<String,Object>()
>         args.put("alternate-exchange", "my-ae")
>         channel.exchangeDeclare exchangeName, 'direct',false,false,args
>         channel.exchangeDeclare "my-ae", "fanout"
>         channel.queueDeclare "unrouted",false,false,false,null
>         channel.queueDeclare queueName,false,false,false,null
>         channel.queueBind "unrouted" , "my-ae" , ""
>         channel.queueBind queueName, exchangeName, 'rKey'
> Regds
> Prashant
>
> On Jan 24, 7:55 pm, Simon MacMullen <si... at rabbitmq.com> wrote:
>
> > On 24/01/2011 7:33PM, Prashant Yadav wrote:
> >  > Am experiencing trouble when configuring alternate exchange for my
> >  > broker. I am following the docs present in rabbitmq site. The error am
> >  > getting is
> >  >
> >  > Caused by: com.rabbitmq.client.ShutdownSignalException: channel error;
> >  > reason:
> >  > {#method<channel.close>(reply-code=406,reply-text=PRECONDITION_FAILED -
> >  > inequivalent arg 'alternate-exchange' for exchange 'exchange' in vhost
> >  > '/': required {longstr,<<97,101>>}, received
> >  > undefined,class-id=40,method-id=10),null,""}
>
> > Did you previously declare the exchange with a different alternate
> > exchange? (Or none?) Every declaration of an exchange needs to have the
> > same arguments.
>
> > BTW I note that your error message references an exchange called
> > "exchange" but your code references "my-direct".
>
> > Cheers, Simon
> > _______________________________________________
> > rabbitmq-discuss mailing list
> > rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss