The broker will prefer dispatching messages to local consumers. However, if
there are no local consumers and there are consumers on other cluster nodes
then messages will be redistributed to those nodes for those consumers.
If you're using the core JMS client then this documentation [1] about
clie
Hi Justin,
Yes, I can clarify the idea.
The product is configured and sold based on the load it can handle. For
example, one client can come and ask for this product to handle 20K
requests but another client can ask for 200K requests. Here the load is
pre-determined by clients. Although the pro
No one is suggesting that you make your application code dependent on
cluster size. I'm not sure where you're getting that idea.
As noted, using ON_DEMAND with a redistribution-delay > 0 will allow
clients to connect to any node of the cluster and consume messages sent to
any other node in the clu
Hi Justin,
Our product is sold to clients based on load. They usually dont scale
up/down clusters (for scalability). And we dont want to make application
code dependent on cluster size. Because for some clients, there could be 2
node cluster but for some it could be 6 node cluster.
Regards,
Prate
I think perhaps you misunderstood what I was recommending. You shouldn't
need to adjust any client code. You certainly don't *need* to create a
consumer on every node of the cluster as you imply. Using ON_DEMAND with a
redistribution-delay > 0 will allow clients to connect to any node of the
cluste
Hi Justin,
Thanks for replying. There is a reason why I don't want to create a
consumer per broker/instance of artemis. I am trying to come up with an
architecture for a product where an artemis cluster can expand or shrink
but it shouldn't have any impact on client code.
Considering the suggest
While it's true that with ON_DEMAND you don't get the same behavior as
STRICT (as one would expect), you still get the benefit of load-balancing
because messages will be initially distributed to nodes that have
consumers. This is why it's called "on demand" - messages are distributed
to where the c
Hi Roskvist,
I tried the ON_DEMAND value but still it doesnt work. Infact, with
on_demand value the loadbalancing stops and the whole scalability feature
in the cluster becomes irrelevant.
IMO, if the client for a queue/topic is connected to any of the broker
instances then; messages should get
Right, so as far as I am aware the STRICT load balancing policy does not allow
for message redistribution, it's purpose is to divide incoming messages evenly
across the cluster regardless of client/consumer state. Perhaps ON_DEMAND might
be better suited for your needs, or possibly OFF_WITH_REDI
STRICT
Is the value in broker.xml
On Fri 7 Apr 2023, 09:54 Roskvist Anton, wrote:
> Hello,
>
> In your cluster configuration, what "message-load-balancing"-type have you
> configured?
>
> Br,
> Anton
>
> This email message (including its attachments) is confidential and may
> contain privileged
Hello,
In your cluster configuration, what "message-load-balancing"-type have you
configured?
Br,
Anton
This email message (including its attachments) is confidential and may contain
privileged information and is intended solely for the use of the individual
and/or entity to whom it is addres
Hi All,
I am running 6 brokers/instances of artemis ( 3 master/live, 3 slave).
While sending messages to them, everything works fine as messages are
loadbalanced. For example, if I send 1000 messages each node will get 333.
All 3 master/live nodes form a cluster and I can see that via the web
co
mpts=1)
>
> Bruce
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4519600.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
&maxReconnectAttempts=1,failover:(tcp://hub2:61001,tcp://hub1:62001)?updateURIsSupported=false&maxReconnectAttempts=1)
Bruce
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4519600.html
Sent
>prefetchSize="1000"
>>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4517522.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Torsten Mielke
tors...@fusesource.com
tmie...@blogspot.com
>
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4517522.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
a:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:619)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4517307.html
Sent from the ActiveMQ - User mailing list archi
Thanks for the reply. I tried taking the // out so I'm now using:
but it failed on the second run of my test.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4517077.html
Sent fro
7;//' will help?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4516935.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
e network connector's configuration:
Thanks,
Bruce
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p45
I am trying to set up a simple Camel routing rule in ActiveMQ using
the example found online:
I have a message producer sending TextMessage objects to the example.A
queue and a listener that is listening on the example.B queue. I am
getting a bunch of exceptions in the ActiveMQ:
C
uter (
> http://activemq.apache.org/camel/message-router.html), but I am not sure
> if
> it can look inside an object to determine where to route data to.
>
>
>
> Thanks
> Mark
>
>
--
View this message in context:
http://www.nabble.com/message-routing-tp18496
I am passing instances of a class from a single producer to a group of
consumers. The class contains an integer id field that defines the
consumer. I am searching for advice on how to properly route data through
ActiveMQ.
So if I have Class X that has a field Y, how can I route messages in a To
On 26/02/2008, jimmy Zhang <[EMAIL PROTECTED]> wrote:
> Hi, all, I have just recently joined the list and wonder if
> someone can explain to me how FUSE routes XML messages
> in its current implementation... Is it DOM/XPath based or
> is it SAX/PULL based?
For FUSE related questions you should
Hi, all, I have just recently joined the list and wonder if
someone can explain to me how FUSE routes XML messages
in its current implementation... Is it DOM/XPath based or
is it SAX/PULL based? What is the performance number etc?
I appreciate any suggestions on this...
thanks,
Jimmy Zhang
25 matches
Mail list logo
