You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Helge Waastad <he...@waastad.org> on 2017/09/25 10:25:55 UTC
artemis hierachic topic and clustering
Hi,
I have a java artemis (2.3.0) consumer listening to a "my-topic.#"
if I listen and produce on the same artemis instance, It's working
fine.
However, moving the consumer to another instance in a static configured
cluster, the artmis receiving the messages:
12:01:18,873
WARN [org.apache.activemq.artemis.core.protocol.mqtt.MQTTPublishManage
r] null: java.lang.StackOverflowError
at
java.util.concurrent.ConcurrentHashMap.get(ConcurrentHashMap.java:936)
[rt.jar:1.8.0_131]
at
org.apache.activemq.artemis.core.postoffice.impl.BindingsImpl.getNextBi
nding(BindingsImpl.java:321) [artemis-server-2.3.0.jar:2.3.0]
Can this be a configuration issue?
relevant config:
b1:
<cluster-connections>
<cluster-connection name="my-cluster">
<connector-ref>netty-connector</connector-ref>
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<message-load-balancing>ON_DEMAND</message-load-balancing>
<max-hops>1</max-hops>
</cluster-connection>
</cluster-connections>
<address name="my-topic">
<anycast>
<queue name="my-topic"/>
</anycast>
</address>
b2:
<connectors>
<connector name="netty-
connector">tcp://localhost:61617</connector>
<connector name="b1-
connector">tcp://localhost:61616</connector>
</connectors>
<cluster-connections>
<cluster-connection name="my-cluster">
<connector-ref>netty-connector</connector-ref>
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<message-load-balancing>ON_DEMAND</message-load-balancing>
<max-hops>1</max-hops>
<static-connectors>
<connector-ref>b1-connector</connector-ref>
</static-connectors>
</cluster-connection>
</cluster-connections>
consumer on queue "my-topic.#"
client: mosquitto_pub -m hei -t my-topic.xxx -p 1883
Re: artemis hierachic topic and clustering
Posted by Justin Bertram <jb...@apache.org>.
This looks like a bug to me. Do you have a test-case that I could use to
reproduce the issue? If not, could you create one (potentially based on
the "clustered-static-discovery" example shipped with the broker)?
Justin
On Mon, Sep 25, 2017 at 5:25 AM, Helge Waastad <he...@waastad.org> wrote:
> Hi,
> I have a java artemis (2.3.0) consumer listening to a "my-topic.#"
>
> if I listen and produce on the same artemis instance, It's working
> fine.
>
> However, moving the consumer to another instance in a static configured
> cluster, the artmis receiving the messages:
>
> 12:01:18,873
> WARN [org.apache.activemq.artemis.core.protocol.mqtt.MQTTPublishManage
> r] null: java.lang.StackOverflowError
> at
> java.util.concurrent.ConcurrentHashMap.get(ConcurrentHashMap.java:936)
> [rt.jar:1.8.0_131]
> at
> org.apache.activemq.artemis.core.postoffice.impl.BindingsImpl.getNextBi
> nding(BindingsImpl.java:321) [artemis-server-2.3.0.jar:2.3.0]
>
>
> Can this be a configuration issue?
>
> relevant config:
> b1:
> <cluster-connections>
> <cluster-connection name="my-cluster">
> <connector-ref>netty-connector</connector-ref>
> <retry-interval>500</retry-interval>
> <use-duplicate-detection>true</use-duplicate-detection>
> <message-load-balancing>ON_DEMAND</message-load-balancing>
> <max-hops>1</max-hops>
> </cluster-connection>
> </cluster-connections>
>
> <address name="my-topic">
> <anycast>
> <queue name="my-topic"/>
> </anycast>
> </address>
>
> b2:
> <connectors>
> <connector name="netty-
> connector">tcp://localhost:61617</connector>
> <connector name="b1-
> connector">tcp://localhost:61616</connector>
> </connectors>
> <cluster-connections>
> <cluster-connection name="my-cluster">
> <connector-ref>netty-connector</connector-ref>
> <retry-interval>500</retry-interval>
> <use-duplicate-detection>true</use-duplicate-detection>
> <message-load-balancing>ON_DEMAND</message-load-balancing>
> <max-hops>1</max-hops>
> <static-connectors>
> <connector-ref>b1-connector</connector-ref>
> </static-connectors>
> </cluster-connection>
> </cluster-connections>
>
> consumer on queue "my-topic.#"
> client: mosquitto_pub -m hei -t my-topic.xxx -p 1883
>