I have filed an issue to follow up:
https://issues.apache.org/jira/browse/ARTEMIS-806 
<https://issues.apache.org/jira/browse/ARTEMIS-806>

Please let me know if and how I can help further.

Thanks!

Antoine

> On Oct 15, 2016, at 12:32 AM, Antoine Toulme <antoine.tou...@gmail.com> wrote:
> 
> I have managed to reproduce the issue by adjusting the symmetric cluster 
> example.
> 
> Here is the code:
> https://github.com/atoulme/activemq-artemis/tree/mqtt_cluster_test2 
> <https://github.com/atoulme/activemq-artemis/tree/mqtt_cluster_test2>
> 
> With this code, I see that messages are sent, but none are received.
> If you change the subscription to “mqtt/bar” line 71 and 103, messages are 
> passed OK.
> 
>> On Oct 14, 2016, at 5:52 PM, Antoine Toulme <antoine.tou...@gmail.com 
>> <mailto:antoine.tou...@gmail.com>> wrote:
>> 
>> I have a test showing a cluster using MQTT, but it passes.
>> 
>> Either the test is bogus, the issue is intermittent, the issue was fixed 
>> since 1.4.0 and/or my cluster configuration is wrong.
>> 
>> Previously, I have found the issue to be intermittent.
>> 
>> Please feel free to take a look at the test. If it looks of value, I can 
>> create a pull request for it:
>> https://github.com/atoulme/activemq-artemis/commit/f7243c38ed0b835d1d3546845fa1871a636329e2
>>  
>> <https://github.com/atoulme/activemq-artemis/commit/f7243c38ed0b835d1d3546845fa1871a636329e2>
>> 
>> I’ll try to rerun my set up:
>> -with trace logging turned on
>> -with the latest code from master
>> 
>> Any help is very appreciated.
>> 
>> Thanks,
>> 
>> Antoine
>> 
>>> On Oct 14, 2016, at 8:28 AM, Antoine Toulme <antoine.tou...@gmail.com 
>>> <mailto:antoine.tou...@gmail.com>> wrote:
>>> 
>>> 
>>>> On Oct 14, 2016, at 3:01 AM, Martyn Taylor <mtay...@redhat.com 
>>>> <mailto:mtay...@redhat.com>> wrote:
>>>> 
>>>> As a quick check can you tell me what message-load-policy you have
>>>> configured on your cluster connection.  Could you try setting this to
>>>> STRICT?
>>> It was unset, I tried setting to STRICT. That didn’t change the behavior.
>>>> 
>>>> If that doesn't work a reproducer would be the best thing to provide.  I
>>>> can manage to get somewhere with the modified cluster test, send a PR and
>>>> I'll take a look.  If not let me know and I'll see if I can reproduce this
>>>> myself (it would help if you could send your broker config).
>>> I should have a test to share later today.
>>> 
>>> In the mean time, my broker config is here:
>>> https://gist.github.com/atoulme/f5e3702b75c55994c5d2b42eb343fece 
>>> <https://gist.github.com/atoulme/f5e3702b75c55994c5d2b42eb343fece>
>>> 
>>> Both nodes use the same config, swapping <IP1> and <IP2> to point at each 
>>> other.
>>>> 
>>>> Thanks
>>>> 
>>>> On Fri, Oct 14, 2016 at 8:39 AM, Antoine Toulme <antoine.tou...@gmail.com 
>>>> <mailto:antoine.tou...@gmail.com>>
>>>> wrote:
>>>> 
>>>>> Hello,
>>>>> 
>>>>> we are trying out ActiveMQ Artemis with MQTT. We are interested in using
>>>>> pattern subscription such as foo/# to listen to a set of topics.
>>>>> 
>>>>> We created a cluster in which one client publishes to a node, while an
>>>>> other one subscribes to another.
>>>>> 
>>>>> When using pattern subscriptions, we see that the subscriber does not
>>>>> receive the message.
>>>>> When using an exact subscription (foo/bar), the subscriber receives the
>>>>> message.
>>>>> 
>>>>> I tried to recreate the situation by modifying one of the clustering
>>>>> integration tests (MessageRedistributionTest). I’m not quite there yet
>>>>> mostly because of my ignorance of the internals.
>>>>> 
>>>>> Are you aware of this issue? I’d be happy to show you my demo and the
>>>>> results. Also happy to share whatever code, however crappy, I have written
>>>>> to create a test for this so far.
>>>>> 
>>>>> Cheers,
>>>>> 
>>>>> Antoine
>>> 
>> 
> 

Reply via email to