Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id D6FA8200BC2 for ; Thu, 17 Nov 2016 15:43:13 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id D5EEA160B0B; Thu, 17 Nov 2016 14:43:13 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 2DB7D160AFF for ; Thu, 17 Nov 2016 15:43:13 +0100 (CET) Received: (qmail 93614 invoked by uid 500); 17 Nov 2016 14:43:12 -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 93598 invoked by uid 99); 17 Nov 2016 14:43:12 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 17 Nov 2016 14:43:12 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 85EC8180538 for ; Thu, 17 Nov 2016 14:43:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.399 X-Spam-Level: X-Spam-Status: No, score=0.399 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id ltGxj8NwvgV7 for ; Thu, 17 Nov 2016 14:43:09 +0000 (UTC) Received: from mail-qk0-f176.google.com (mail-qk0-f176.google.com [209.85.220.176]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 353B45F474 for ; Thu, 17 Nov 2016 14:43:09 +0000 (UTC) Received: by mail-qk0-f176.google.com with SMTP id x190so222079635qkb.0 for ; Thu, 17 Nov 2016 06:43:09 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:from:date:message-id:subject:to; bh=tkwxt5XCQMMISBAKFyO9CPuB0gK0GOIJIZap8IVj6l8=; b=fW2StkYF7QIPMl3wUC6bNcSy13cgyTqId4kTgrQ9Q7CfmzOA06OuOSA3khKSv0bQlP 1uV6gU8k3w9S2Qi3baTit4XMO6F65Buwd97qBN/tKtpkDxju4HUUTTZ1uhIaZySQ/4Mc fNgC4U0Aa3ghL0VSF3lU8szgzs7Mwieh7lP33KOmjPDXRwYY9/vM4qnLjZFhuKQwKxyg J7aHQqFnJA5/kF96JSJCDMCfpGnRps9F4tCTCyyCYUcZzHJjxGE4P3/QcvJrrxdDEqlS IAu9vsrEYKgAI1jrP75X0zx4OXQW+oqgsvvAVN6wbcDvwVdedLIMmkbn/ebR+Gd2IU7E rmNQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=tkwxt5XCQMMISBAKFyO9CPuB0gK0GOIJIZap8IVj6l8=; b=hQAXDDthcpwOUpRuWPTIE6hXnOboR3wNd5jvQCB+MU/aF9JsDRH3bgbacG7zC+u+8E L3C+cETs2yZAsQtYrBItHUWsh4Zg8B3bwpEdYEJTRlcFqzI3lgJGkdTmgQJvhXnpMUMx W4JMIwIQNxNBPrTKLuDr6YiF0j/9qkyeh73lONdg9OZnN8n0KlMMR7EicJVX1Z0mF5vm SJXnDTlk9s1K3lCPOhdGEyEVbkQb80CbOWZp3j6xFkU7oVw//g/WFuUT0MX7Kh+TVp6o XvcPe00pRHBM+T5YOGj/WZ/vXBFpnovy9Vle4lcy6IX75UIf2kJAsTqPGlGT+gtbqYgs 1jrw== X-Gm-Message-State: AKaTC03o4tVPWRp7FsG+bEIjzDW+nRPeetU8OUcVPV2mO9mfxhBXaHQLMbLTyPWS+q0XiU0iK73p0kCntUngng== X-Received: by 10.55.27.226 with SMTP id m95mr4081976qkh.143.1479393788410; Thu, 17 Nov 2016 06:43:08 -0800 (PST) MIME-Version: 1.0 Received: by 10.237.35.172 with HTTP; Thu, 17 Nov 2016 06:43:08 -0800 (PST) From: Robbie Gemmell Date: Thu, 17 Nov 2016 14:43:08 +0000 Message-ID: Subject: [DISCUSS] Shared topic subscriptions using AMQP 1.0 To: "users@qpid.apache.org" Content-Type: text/plain; charset=UTF-8 archived-at: Thu, 17 Nov 2016 14:43:14 -0000 Hi folks, I'd like to shine light on an idea around doing shared topic subscriptions using AMQP 1.0, something useful in general but required in particular for client work on supporting JMS 2.0 (QPIDJMS-207). A quick summary of the idea is that: - Support would be identified via a 'SHARED-SUBS' connection or link capability to allow clients to detect support/lack-of. - A 'shared' source capability would be used to identify sharing is desired. - Sharing would by default be container-id scoped as with links, but a 'global' source capability would be used to identify wish to share a subscription identity across any connection regardless of container-id. - The link name is used to convey the subscription name, with a naming "[|suffix]" scheme to facilitate disambiguating different links referencing the same subscription name from the same container-id where needed (as only one link of a given name is allowed between containers, per direction). I split out a specific JIRA for this https://issues.apache.org/jira/browse/QPIDJMS-220 which covers things in [much] more detail, as there are a great many to try and include here and I'd like to reference it there for other [broker] JIRAs later. Feel free to comment here (or there) after giving it a read. I've implemented much of this now for the JMS client to validate the idea, as there have been others in the past that wouldn't work for one reason or other. The connection capability handling mentioned is in there, but the link capability handling is still outstanding as support needs added to Proton first for that. I've put a 0.20.0-beta cut up in a temporary staging repo in case anyone would like to check it out, its at: https://repository.apache.org/content/repositories/orgapacheqpid-1093. Note though that you wont get very far with using the shared subs bits yet, due to needing server support. Gordon also put together some examples using Proton python at https://github.com/grs/amqp_subscriptions to show how this could be supported in the other APIs. There are simple client examples of the various subscription combinations there can be and how that influences the protocol interactions. There is also a little broker example, though note it only implements some of the behaviours, and won't work with the JMS client currently due to its capabilities checking. Robbie --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org For additional commands, e-mail: users-help@qpid.apache.org