[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287756#comment-16287756 ] ASF subversion and git services commented on ARTEMIS-1523: -- Commit 46b642447c20200fa29932d1fd5df596a7b97759 in activemq-artemis's branch refs/heads/master from raul.valdoleiros [ https://git-wip-us.apache.org/repos/asf?p=activemq-artemis.git;h=46b6424 ] ARTEMIS-1523 wildcard binding configured wrong Bindings with wildcards are not configured with the proper message-load-balancing type. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287757#comment-16287757 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user asfgit closed the pull request at: https://github.com/apache/activemq-artemis/pull/1690 > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282835#comment-16282835 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user jbertram commented on the issue: https://github.com/apache/activemq-artemis/pull/1690 @michaelandrepearce, I'm working on this PR with @Skiler. I plan on amending it before merging to deal with all the stuff you mentioned (plus a few other things). > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282871#comment-16282871 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user michaelandrepearce commented on the issue: https://github.com/apache/activemq-artemis/pull/1690 @jbertram great cheers for that. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282837#comment-16282837 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user jbertram commented on the issue: https://github.com/apache/activemq-artemis/pull/1690 @Skiler, btw this will go into 2.5.0 since 2.4.0 has already been released. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282782#comment-16282782 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/1690#discussion_r155677138 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/WildcardAddressManager.java --- @@ -30,6 +25,11 @@ import org.apache.activemq.artemis.core.postoffice.BindingsFactory; import org.apache.activemq.artemis.core.transaction.Transaction; +import java.util.Collection; --- End diff -- This move re-change wasn't needed, if could revert, so just the code changes needed are in the PR. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282780#comment-16282780 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/1690#discussion_r155676825 --- Diff: artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java --- @@ -5,9 +5,9 @@ * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * --- End diff -- On that note, there doesn't seem to be any material change to this class, except you've used a re-formatter set to your own settings, id suggest simply reverting this file. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282776#comment-16282776 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/1690#discussion_r155676188 --- Diff: artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java --- @@ -5,9 +5,9 @@ * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * --- End diff -- should not be added > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16280266#comment-16280266 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler commented on the issue: https://github.com/apache/activemq-artemis/pull/1690 Hi @jbertram This is the new pull request. It's possible to include this fix in the 2.4.0 version? Thanks > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16280262#comment-16280262 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 I had some problemas with the squash, so I created a new pull request. https://github.com/apache/activemq-artemis/pull/1690 > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16280261#comment-16280261 ] ASF GitHub Bot commented on ARTEMIS-1523: - GitHub user Skiler opened a pull request: https://github.com/apache/activemq-artemis/pull/1690 ARTEMIS-1523 Allow MQTT with dynamic cluster ARTEMIS-1523 Allow MQTT with dynamic cluster You can merge this pull request into a Git repository by running: $ git pull https://github.com/Skiler/activemq-artemis mqqtcluster Alternatively you can review and apply these changes as the patch at: https://github.com/apache/activemq-artemis/pull/1690.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1690 commit c1e2d1472b6060117f9c64aad066f48324300201 Author: raul.valdoleiros Date: 2017-11-24T17:53:14Z ARTEMIS-1523 Allow MQTT with dynamic cluster ARTEMIS-1523 Allow MQTT with dynamic cluster > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16280263#comment-16280263 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler closed the pull request at: https://github.com/apache/activemq-artemis/pull/1679 > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16279197#comment-16279197 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user jbertram commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 It would be ideal to have a real test in the test-suite to validate this functionality instead of just an example. I think that once a test was created you could get rid of the example completely. If you wanted to keep the example after the test was created I would move it to the protocols/mqtt section rather than the features/clustered section. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16279054#comment-16279054 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user jbertram commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 It looks a lot better, but you need to squash your commits together into a single commit. Once that's done I'll kick off a full test-suite run with your changes and see how it goes. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278838#comment-16278838 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 Hi @jbertram I changed the way it create the Bindings based in wildcard. I hope it's good now :) > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277212#comment-16277212 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user jbertram commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 > For what I have analysed in the artemis code, the message-load-balancing-type is only set for queues configured in the broker.xml. I don't believe that's true. If you change your example to create subscriptions on "test/1/some/la" instead of "test/+/some/#" and also remove theblock from the broker.xml files then the address "test/1/some/la" will be created along with the corresponding subscription queues automatically when the client runs. In this situation I can see that the messages are load-balanced properly among the cluster nodes. This leads me to believe that the issue is with how the subscription queues with wildcards (i.e. "test/+/some/#") are interacting with the messages send to a specific address (i.e. "test/1/some/la"). > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276682#comment-16276682 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 Hi @jbertram For what I have analysed in the artemis code, the message-load-balancing-type is only set for queues configured in the broker.xml. When you publish to an auto created queue it seems the load balancing type isn't set by the postoffice. So can you help me understand how this is supposed to work in order to fix it? I can do this without using the address and using the value defined in the default cluster connection. What do you think? Thanks in advance > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16273623#comment-16273623 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user jbertram commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 The single commit here is much easier to understand so thanks for that. However, I don't believe technical solution is viable as it relies on the address for the subscription matching the address in the cluster-connection which would likely only happen if it was specifically configured that way which would preclude other clustered addresses. I think the real solution would be to address why the message-load-balancing-type isn't being set on the subscription queues in the first place. > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270450#comment-16270450 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler commented on the issue: https://github.com/apache/activemq-artemis/pull/1679 Hi @jbertram I created a new pull request, I hope it has the needed organization. Thanks in advance > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270448#comment-16270448 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler closed the pull request at: https://github.com/apache/activemq-artemis/pull/1677 > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270445#comment-16270445 ] ASF GitHub Bot commented on ARTEMIS-1523: - GitHub user Skiler opened a pull request: https://github.com/apache/activemq-artemis/pull/1679 ARTEMIS-1523 Allow MQTT with dynamic cluster You can merge this pull request into a Git repository by running: $ git pull https://github.com/Skiler/activemq-artemis securebranch Alternatively you can review and apply these changes as the patch at: https://github.com/apache/activemq-artemis/pull/1679.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1679 commit 1ea3fd90178132d1d23827c01b05df5e153cd141 Author: raul.valdoleiros Date: 2017-11-24T17:53:14Z ARTEMIS-1523 Allow MQTT with dynamic cluster > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269031#comment-16269031 ] ASF GitHub Bot commented on ARTEMIS-1523: - Github user Skiler commented on the issue: https://github.com/apache/activemq-artemis/pull/1677 Hi @jbertram, Can you help me understand how the commits should be organized? The commit "Mqtt cluster" has the scenario I want to test. The commit "ARTEMIS-1523 Fixing mqtt dynamic cluster" is the fix for that scenario. The other commits are just pom stuff. In the scenario you have: - two brokers using dynamic cluster (I think is the right term) and receiving mqtt messages - the brokers have a queue configured with anycast - two consumers, each one subscribing the broker 1 and the other subscribing the broker 2 - one producer sending 3 messages to broker 1 The goal is to receive the the first and third message in the consumer 1 and the second message in the broker 2. Thanks > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268957#comment-16268957 ] ASF GitHub Bot commented on ARTEMIS-1523: - GitHub user Skiler opened a pull request: https://github.com/apache/activemq-artemis/pull/1677 Allow mqtt with dynamic cluster https://issues.apache.org/jira/browse/ARTEMIS-1523 You can merge this pull request into a Git repository by running: $ git pull https://github.com/Skiler/activemq-artemis master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/activemq-artemis/pull/1677.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1677 commit f506885272b7d074ba12f14d3831e3c4357aad46 Author: raul.valdoleiros Date: 2017-11-24T17:53:14Z Mqtt cluster commit c502b2c71d91fb8420f214814d9926c98b203fa3 Author: raul.valdoleiros Date: 2017-11-28T15:45:34Z Merge remote-tracking branch 'upstream/master' commit ef36451e5da2ad8db5c33ecc1f6ac5b28d249a5f Author: raul.valdoleiros Date: 2017-11-24T17:53:14Z Mqtt cluster commit 0f9ae82ab12b751bfe70d34ac5977454943dc200 Author: raul.valdoleiros Date: 2017-11-28T15:44:26Z ARTEMIS-1523 Fixing mqtt dynamic cluster Now artemis uses the message-load-balacing property of cluster connection to share the mqtt message between brokers commit a7d115f30437ea2c2465f1af17768f69c973af48 Author: raul.valdoleiros Date: 2017-11-28T15:51:03Z ARTEMIS-1523 Fix pom commit f10ce5e91a1094aaaeac2015b77d900cbb3f0b66 Author: raul.valdoleiros Date: 2017-11-28T15:52:36Z ARTEMIS-1523 Fix versions > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ARTEMIS-1523) Cannot create a MQTT cluster
[ https://issues.apache.org/jira/browse/ARTEMIS-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266588#comment-16266588 ] Raul Valdoleiros commented on ARTEMIS-1523: --- Hi [~jbertram], I already added it to the mailing list: http://activemq.2283324.n4.nabble.com/Apache-Artemis-MQTT-td4733161.html If you can help me I would appreciate that. Thanks in advance > Cannot create a MQTT cluster > > > Key: ARTEMIS-1523 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1523 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.4.0 >Reporter: Raul Valdoleiros >Priority: Blocker > > I created a cluster with two nodes of artemis brokers, configured with mqtt > protocol. > The goal is to send a message, through mqtt, to broker 1 and receive it in > the subscriber of broker 2. > I've wrote a test for that: > https://github.com/Skiler/activemq-artemis/tree/master/examples/features/clustered/clustered-queue-mqtt > Can anyone help me understand what is wrong? > Thanks in advance, > Raul -- This message was sent by Atlassian JIRA (v6.4.14#64029)
