[rabbitmq-discuss] problem with new persiter with 1000 topics/queues

[alex chen]

Matthias,


> > this could be the amqp_producer.c in  rabbitmq-c/examples.  simply modify the 
>code to accept the topic name and  message size from command line.
> 
> Please send us the modified  code.

David mentioned that tools/amqp-publish does the same thing.

> There must be a step 0) missing here.  amqp_bind does not create any queues and 
>will fail if the referenced queues do  not exist. So how are the queues created? 
>Please send us the code/scripts for  that.

i modified rabbitmq-c/examples/amqp_consumer.c to create the queue without 
consuming the messages.
# to bind and declare the queue then exit.  use this in bind.sh
amqp_consumer -r routingkey -q queue -n 0
# to consume the queue, use this in consume.sh
amqp_consumer -r routingkey -q queue 

attached please find the modified amqp_consumer.c.  

> Also, are all the above running on the same machine as the  broker?

yes.  i also tested running publisher from different host.  the throughput is 
the same if the publisher host and borker host are in the same data center, 
because the bottleneck is disk and memory.
 
-alex



      
-------------- next part --------------
A non-text attachment was scrubbed...
Name: amqp_consumer.c
Type: text/x-csrc
Size: 8163 bytes
Desc: not available
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20100825/eee4fc27/attachment-0001.c>