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 BE022200D5B for ; Wed, 13 Dec 2017 10:22:22 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id BC8B1160C27; Wed, 13 Dec 2017 09:22:22 +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 0E05B160C16 for ; Wed, 13 Dec 2017 10:22:21 +0100 (CET) Received: (qmail 33341 invoked by uid 500); 13 Dec 2017 09:22:21 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 33324 invoked by uid 99); 13 Dec 2017 09:22:20 -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; Wed, 13 Dec 2017 09:22:20 +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 51A3D18078A for ; Wed, 13 Dec 2017 09:22:20 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.901 X-Spam-Level: X-Spam-Status: No, score=-0.901 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-2.8, SPF_PASS=-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-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 6qKx9iWAvbn1 for ; Wed, 13 Dec 2017 09:22:18 +0000 (UTC) Received: from mail-wr0-f171.google.com (mail-wr0-f171.google.com [209.85.128.171]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 04AFA5FB2D for ; Wed, 13 Dec 2017 09:22:18 +0000 (UTC) Received: by mail-wr0-f171.google.com with SMTP id h1so1443055wre.12 for ; Wed, 13 Dec 2017 01:22:18 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:references:in-reply-to:from:date:message-id:subject:to :cc; bh=uhCeFNX7AIhGpfKvSz/pBhOzhKoxo7aQ3v4YCk47SuI=; b=jPDMSN268HwdYyXL3ByRZbkTbjGX4/fci5pkW6fQt5HuvRL/3G0/qjFXC78eFXj7su en3FFsaNEfA2C5ZViaJtmLpYFC4TD2z1OtLxam+nxXbB78zPswjmmgSph01zLI22U7Zr A9koXK3S4eQl2SJJZ+7i35y0tTxQF0KRB5LbImPaEbGz8TMCsg3mlRmDeh5RI3niB9Cr tvDFwzNjruKfEpTv2Vaq9n/w3o8pw3LiebZdR5Smhkd+mnc3u0i05iFQv9bTaB8jTh10 VQ4SmXwxmO2xQ8u/i4vqPkQloAJ4/ytCeR1I9fqrIdom9UsqabJ0VrIpuONnhtvISlXf rQYQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to:cc; bh=uhCeFNX7AIhGpfKvSz/pBhOzhKoxo7aQ3v4YCk47SuI=; b=aO+NAu2Fp8YbYIml1xxDIEbC2LGRKnILIBfb3mjF2qmAVNmEH3ufJNMRyvqHROHWxU y4EHZePr5ELbwigt5qO3TFl8Jul6iNkFHdYS2BSPdCthg5KLERK7ZiEOqwMSKWUQ9YRc 0WTHqz3SwwvZs2bAMhGVD4iHZXMUXnxLCc/vZ7r3WHeoFQWW92+t35KN/csfMNMLyBHt go3S9LlrIUA73pGyy7Rs5wvi507j2AOuvDroDUN/RYZ2DaednlORQPiGPMYDEZyBHy+q nRs3BUyGBUf7OmB1GZNwZervu+snlQYYzxP5CGrQO78nQ0xHkrp3uZjM3+hxeqCgZSJe 7ecQ== X-Gm-Message-State: AKGB3mIsl1iVhUlT8Qw2Fmx96l3a3V9keSH038MwszPDFXpQxSqCgc2d NsYkC1Veffxmpr/qevrsUU/m2vrEk2AcFne8bTU= X-Google-Smtp-Source: ACJfBosIhSTo+q9amzcVGp+XtlZIcjtDGGqQsUqy4CG74dFf8i1Y0xnoRtGuKcC1FaDOm1mVSbs8WrX8MFosWj9XEIE= X-Received: by 10.223.199.70 with SMTP id b6mr1724304wrh.25.1513156937452; Wed, 13 Dec 2017 01:22:17 -0800 (PST) MIME-Version: 1.0 References: <0130621f-08da-6519-7570-7ef7cf346d31@Gmail.com> <005e2971-5170-202e-95f2-b814d21f427f@redhat.com> In-Reply-To: <005e2971-5170-202e-95f2-b814d21f427f@redhat.com> From: Adrian Brown Date: Wed, 13 Dec 2017 09:22:06 +0000 Message-ID: Subject: Re: Using Topics and Queues for both Java-based and Node.js-based services To: users@activemq.apache.org Cc: Jeroen van Ooststroom Content-Type: multipart/alternative; boundary="089e08245348bf0fac0560354d55" archived-at: Wed, 13 Dec 2017 09:22:22 -0000 --089e08245348bf0fac0560354d55 Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable I think RabbitMQ let=E2=80=99s you map MQTT topics to AMQP can remember fo= r sure but have a look at https://www.rabbitmq.com/mqtt.html On Wed, 13 Dec 2017 at 8:04 pm, Ulf Lilleengen wrote: > On 12. des. 2017 22:50, Jeroen van Ooststroom wrote: > > Hello, > > > > Coming back to the discussion on the apache-activemq IRC channel of > > possible Topics and Queues when using ActiveMQ=E2=80=99s MQTT service. > > > > First a bit of history then. We=E2=80=99ve have been using multiple Jav= a-based > > services for quite a bit of years now utilizing ActiveMQ=E2=80=99s JMS = Topic and > > the occasional JMS Queues. Recently, we started expanding by adding a > > multitude of Node.js-based services to the mix. At some point these > > services also needed the capability of sending messages. As we already > > were using ActiveMQ for JMS Messaging with our Java-based services it > > seemed obvious to stick with ActiveMQ even for our Node.js-based > > services. However, they can=E2=80=99t leverage JMS evidently. Therefore= we > > picked MQTT and enabled MQTT on our ActiveMQ server next to the already > > supported JMS. As these Node.js services have been deployed stand-alone > > up until now, there was no harm in using Topics for this approach. > > > > However, we are no looking into deploying these Node.js-based services > > in a clustered fashion now. (We have an Amazon ECS Cluster to which we > > want to deploy multiple Containers of the same Node.js-based services. > > This imposes a problem as for certain messages we only want a single > > subscriber of a particular service to receive and handle that message. > > Hence we were leaning towards using Queues instead of Topics for these > > scenarios. Unfortunately as member dejanb pointed out, MQTT doesn=E2=80= =99t > > support Queues. > > > > So our question still remains similar. How can we utilize both JMS Topi= c > > (1-to-N) and Queue-like (1-to-1) behaviour for both our Java-based and > > Node.js-based services using ActiveMQ? (We=E2=80=99d like to possible s= hare > > these Topics and Queues among the Java- and Node.js-based services.) Is > > there another approach we should be looking into from a Node.js-based > > perspective and move away from MQTT and potentially use something > > different that ActiveMQ provides? > > > > I'm afraid I don't have a good answer on how you can use MQTT, but you > might want to have a look at using AMQP, which has support for queues, > topics, JMS clients (qpid-jms[1]) and node.js clients (rhea[2]). > > [1] https://qpid.apache.org/components/jms/index.html > [2] https://github.com/grs/rhea > > -- > Ulf > --=20 Regards Adrian Brown --089e08245348bf0fac0560354d55--