qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From felixehm <felix....@cern.ch>
Subject RE: Qpid messaging design
Date Tue, 05 Oct 2010 16:08:06 GMT

Hi Steve,

thanks for the quick reply.

Steve Huston wrote:
> Do you mean you want each client to declare one queue and then bind the
> amq.topic exchange to that queue using different routing keys? That
> should be possible.
Yes. This is a result from out tests we're run so far. The performance
numbers we got were not convincing at all (a 16 Core machine runs flat out
using the described way). It seems that the Brokers spend a lot of time
dispatching at this (quite high) rate to all the queues. 
So I assumed that there are more clever ways (e.g. 1 queue/client) to do
this and get better results. 

> If you post the problems you experienced trying to bind 400 keys and one
> queue that would be helpful. 
Basically its when I try this code :

8-< -------------------------------

/* Declare an exclusive queue on the broker
string queue = exchange + session.getId().getName();
session.queueDeclare(arg::queue=queue, arg::exclusive=true,

/* map the bindingkeys to my queue
for (int i=0; i< subscriptions; i++){
      string s = destName + convertInt(i);
      listener.prepareQueue(queue, exchange, s);
>-8 ------------------------------

When I try this I get the message : 
# Subscribing to queue amq.topic6916d790-3d2e-42c0-a826-2fce0811a61c
# Subscribing to queue amq.topic6916d790-3d2e-42c0-a826-2fce0811a61c
2010-10-05 17:56:07 warning Exception received from broker: not-allowed:
not-allowed: Consumer tags must be unique
(qpid/broker/SessionAdapter.cpp:489) [caused by 8 \x04:\x07]
not-allowed: not-allowed: Consumer tags must be unique

View this message in context: http://apache-qpid-users.2158936.n2.nabble.com/Qpid-messaging-design-tp5600245p5603791.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.

Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org

View raw message