[rabbitmq-discuss] Extremely slow responses

[Marcin Krol]

-----BEGIN PGP SIGNED MESSAGE-----
Hash: SHA1

Hello everyone,

I'm getting weird problem with very slow transfers of messages to reply
queue.

The setup: cluster of 3 nodes, with fanout-type exchange, with 3 queues
bound, one per each node.

This part works without problems (tested separately) - messages sent
from client get delivered quickly to each queue and are then read by
servers on each node.

However, when I add callback queue (with exclusive=True) for responses
from each server, I'm getting responses back very slowly - like after a
minute!

(the callback queue gets created by client with
channel.queue_declare(exclusive=True) )

Basically, I combined solutions from tutorial on fanout
(http://www.rabbitmq.com/tutorial-three-python.html) with code from
tutorial on RPC (http://www.rabbitmq.com/tutorial-six-python.html) and
used it in a cluster.

1. Might it be that temporary queues get propagated across cluster very
slowly?

2. Or is it a problem that I do not bind the reply temp queue to any
exchange? (ch.basic_publish(exchange='', routing_key=props.reply_to,
    body = result))

I'm using pika for both server and client.

Rationale for the whole thing: I need to replicate the same JSON-RPC
call across several nodes. At best, I would like to be able to read all
the produced responses back.


Complete code:

Server:

http://pastie.org/pastes/1493724/text

Client:

http://pastie.org/pastes/1493732/text




- --

Regards,
mk

- --
Premature optimization is the root of all fun.
-----BEGIN PGP SIGNATURE-----
Version: GnuPG v1.4.9 (MingW32)
Comment: Using GnuPG with Mozilla - http://enigmail.mozdev.org/

iQEcBAEBAgAGBQJNPd5QAAoJEFMgHzhQQ7hO+9UH/jhK9wz4dkkKnH1z2soHQ8q8
VXeMZ7l7oI+fmm8Njl+ZCIh3VooF/DsU9AI0I370hW0ycSMDEgfmehytxMFwrZer
WpABoOde7sj/WDBE46zfi/6/Iso6URzkdy+IxjfJa+dCDV4O28rApQUO2BFCHgrb
EkEMH0gQ5g88AOotE2NIyXsg8EL0UDceVIfGk9ObkXY3OYyI/v/gSyo8FmWkZqjA
lLtBQCK/RrxAzsH9MGu9Jymihmv7mp740VLXc2CPtQvFt6v6bpTKlpzu053iaQav
TWdGdth+N7aohhyiIuwZJNZInXdsQwqhwystMTfIgwsSEH6gkzbKKlFkL156kXU=
=latj
-----END PGP SIGNATURE-----