Return-Path: X-Original-To: apmail-incubator-cloudstack-dev-archive@minotaur.apache.org Delivered-To: apmail-incubator-cloudstack-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 82063E531 for ; Wed, 30 Jan 2013 08:21:58 +0000 (UTC) Received: (qmail 44144 invoked by uid 500); 30 Jan 2013 08:21:58 -0000 Delivered-To: apmail-incubator-cloudstack-dev-archive@incubator.apache.org Received: (qmail 44073 invoked by uid 500); 30 Jan 2013 08:21:58 -0000 Mailing-List: contact cloudstack-dev-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: cloudstack-dev@incubator.apache.org Delivered-To: mailing list cloudstack-dev@incubator.apache.org Received: (qmail 44043 invoked by uid 99); 30 Jan 2013 08:21:57 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jan 2013 08:21:57 +0000 X-ASF-Spam-Status: No, hits=-2.3 required=5.0 tests=RCVD_IN_DNSWL_MED,SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of Murali.Reddy@citrix.com designates 203.166.19.134 as permitted sender) Received: from [203.166.19.134] (HELO SMTP.CITRIX.COM.AU) (203.166.19.134) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jan 2013 08:21:49 +0000 X-IronPort-AV: E=Sophos;i="4.84,566,1355097600"; d="scan'208";a="607752" Received: from banpmailmx01.citrite.net ([10.103.128.73]) by SYDPIPO01.CITRIX.COM.AU with ESMTP/TLS/RC4-MD5; 30 Jan 2013 08:21:27 +0000 Received: from BANPMAILBOX01.citrite.net ([10.103.128.71]) by BANPMAILMX01.citrite.net ([10.103.128.73]) with mapi; Wed, 30 Jan 2013 13:51:24 +0530 From: Murali Reddy To: "cloudstack-dev@incubator.apache.org" Date: Wed, 30 Jan 2013 13:51:23 +0530 Subject: Re: [MERGE] merge 'events-framework' branch to master Thread-Topic: [MERGE] merge 'events-framework' branch to master Thread-Index: Ac3+wsq7sEd+6KHKT0KSkQJ7YKdAaQ== Message-ID: In-Reply-To: <93099572B72EB341B81A644E134F240B012F747FE60F@SJCPMAILBOX01.citrite.net> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: user-agent: Microsoft-MacOutlook/14.2.5.121010 acceptlanguage: en-US Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-Virus-Checked: Checked by ClamAV on apache.org > >Ok. this makes more sense as I think there would not be too many >subscribers. >So you would notify publisher that a new queue has been created? Otherwise >how does publisher push the events out? Generally idea of pub-sub model is that publisher/subscriber need not be aware the existence of others. In the AMQP case, publisher just publishes events to exchanges and not bother about the consumers. A subscriber interested in a particular set of messages, will create a queue bound to exchange with a binding key with pattern that describes interested messages. It is message broker responsibility to match the message in exchange with all binding key of the queue and deliver the message into queue if message's routing key matches with binding key. So CloudStack just publishes messages to an exchange, and creates a queue for each subscriber and sets up call back to get notified If message gets into a queue.