From users-return-5739-apmail-qpid-users-archive=qpid.apache.org@qpid.apache.org Fri Jan 13 05:20:44 2012 Return-Path: X-Original-To: apmail-qpid-users-archive@www.apache.org Delivered-To: apmail-qpid-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id BFE659151 for ; Fri, 13 Jan 2012 05:20:44 +0000 (UTC) Received: (qmail 57403 invoked by uid 500); 13 Jan 2012 05:20:42 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 57017 invoked by uid 500); 13 Jan 2012 05:20:24 -0000 Mailing-List: contact users-help@qpid.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@qpid.apache.org Delivered-To: mailing list users@qpid.apache.org Received: (qmail 56970 invoked by uid 99); 13 Jan 2012 05:20:09 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Jan 2012 05:20:09 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=HTML_MESSAGE,MSGID_FROM_MTA_HEADER,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy) Received: from [79.134.122.4] (HELO airdice.com) (79.134.122.4) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Jan 2012 05:20:01 +0000 To: users Date: Fri, 13 Jan 2012 07:19:02 +0200 Subject: Uncanny differences Envelope-To: users@qpid.apache.org Message-ID: <74191BABCAD840C28D6B5D86AC719249@airdice.com> From: "Kalle" Received: from Macintosh-4 (localhost [127.0.0.1]) by airdice.com; Fri, 13 Jan 2012 07:36:26 +0200 X-Mailer: sparrow 1.5 (build 1043.1) MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="4f0fbec6_7c83e458_302" X-Virus-Checked: Checked by ClamAV on apache.org --4f0fbec6_7c83e458_302 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit Content-Disposition: inline Hi, Java client, cpp broker. When I do (a bit of a pseudocode here, I'll post with actual examples if necessary) Topic t = session.createtopic("yyy"); MessagePublisher p = session.createPublisher(t); MessageSubscriber s = session.createSubscriber(t); things work. But when I do: Topic t = session.createtopic("xxx/yyy"); MessagePublisher p = session.createPublisher(t); MessageSubscriber s = session.createSubscriber(t); they don't. What I see is that when I define my topic with a /, in order to use my own exchange, not all consumers get my messages. Messages seem to go to just one consumer (which ever got the message first). This would mean that they are in fact listening in a totally different pattern, than in the first case (topic with default exchange). Why does it work like this? Is this a bug, or a feature I've yet to learn to like? :) -- Kalle --4f0fbec6_7c83e458_302--