Wanted to run this by the community for some advice.
We have 20 brokers in total (10 master/slave pairs). Operational tooling is
an issue, we need something simple to address short term needs. So our goal
is to create a web page showing unified operational view for the entire
cluster. Simple metri
I'm testing JMS applications in a NoB cluster to validate client are
receiving updates as brokers join/leave the cluster; our openwire connector
config:
The client connection URL is below; this is just a virtual IP that proxies
to a router and finds the nearest broker (all of this wo
Is there a JMX metric for testing prefetch=1 vs prefetch=100? I want to
confirm reduced network activity between consumer and broker when using
large prefetchSize. DispatchedCounter and DispatchedQueueSize appear to
increment/decrement by 1, never consistent with prefetchSize. I'm missing
something
Tim,
Wow, thank you; my assumption was totally wrong.
On the flip side, to ensure my understand of optimizedAcknowlege="true"
isn't wrong either, does the client "ack" groups of messages using a single
network call instead of individually? (Batch size being 65% of prefetchSize)
--
View this me
We're testing network of brokers using brokerPath to validate which brokers
the message visited. Based on our observations, "brokerPath" is not a
message property or header, and the only way to access it is casting message
to ActiveMQMessage. No need to explain why this is not ideal; is there no
al
Yup, that's always an option too, :-)
thx
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Why-is-brokerPath-not-a-message-property-tp4709942p4709944.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Looking for advice on how to update activemq.xml in a distributed topology
that uses M/S pairs and NoB.
Some ideas we're considering...
Option A: *Custom Startup Bean*
On startup (before activemq.xml is read), a custom class queries GIT/SVN for
latest version of broker config files, comparing ver
Hi Tim,
Should have mentioned earlier, we're on RedHat AMQ, and the custom bean for
loading new config files would be OSGI. The problem is configuring a
dependency on the broker bundle ensuring our custom stuff loads first. I
know how to do it with OSGI features, but only if I control packaging th
Show the client code.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Network-of-Brokers-Connected-but-messages-are-not-received-on-second-broker-tp4720116p4720117.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
We're trying to channel all advisory events generated from a standalone
broker to a queue, but nothing is ever forwarded to the queue. This appears
to only work when the composite topic does NOT use * or >, is this by
design?
Thanks, Tim. We finally gave up and created subscribers to each of the
advisory topic names that we needed to log externally.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Wildcards-in-composite-destinations-not-working-tp4727353p4727872.html
Sent from the ActiveMQ - Us
ActiveMQ 5.12
When messages are dispatched to a consumer, how long will the broker wait
before it considers the consumer "slow" assuming the consumer does not ack
the message and the connection remains active? We're not using any slow
consumer strategy in the broker, so when I found this I wasn't
We have a broker network of 12 brokers in a complete graph, so every broker
has a separate connection to every other broker. We want to consume and
forward some advisories messages from each broker to splunk; the splunk
integration is not important, our concern is the subscriber itself. Our
current
Is it safe to use JMX-based message browsing for queues when troubleshooting
production issues?
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Hi Tim,
Yeah, that's what we're thinking too; based on all available options, it's
certainly the simplest approach with fewest moving parts.
thx
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
That's a good point, competing with resources, ty.
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Just wanted to confirm the statistics plugin is one-to-one, that is, one
request returns metrics for a single broker, regardless if the request was
sent to topic://ActiveMQ.Statistics.Broker, and all brokers belonged to a
network. We can't seem to get the latter to work, the goal is to send a
singl
Trying to understand the cause for the following error getting logged each
time the auth plugin syncs with LDAP. We use LDAP server for storing
queue/topic permissions, but all destinations are dynamic, so a policy entry
may not always have a physical destination counterpart in ActiveMQ; that's
our
Remove "rebalanceClusterClients=true", it distributes connections across
brokers, likely exacerbating your problem. Is "duplex="true" enabled from
both ends of the connector? If so, enable it from one end only, or, remove
it entirely and use static connections between the brokers.
--
Sent from:
We see the same error, sporadically, we feel it's caused by load-balancers
momentarily directing JMS clients to slaves on initial connect during a
master failover situation, at least that's our best guess.
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Tim,
If, by default, the broker has no slow consumer strategy configured, does
that also mean the broker will not publish slow consumer advisory messages?
Are the strategy and advisory linked together? If not, under what conditions
does the broker publish slow consumer advisories?
--
Sent from:
In production with ActiveMQ 5.11 with multi-kahadb per destination on NFSv4
M|S (Linux 7.1), we're seeing the following log messages intermittently
during operations:
*Slow KahaDB access: Journal append took: 2 ms, Index update took 16901 ms*
Also, on startup, we see the following in our kahadb
nvm, I got it.
read the docs, son. :-)
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
I'm writing a simple topic subscriber for consuming advisory messages:
Subscriber receives these messages...
topic:ActiveMQ.Advisory.Connection
..but not these:
topic:ActiveMQ.Advisory.Consumer.>
topic:ActiveMQ.Advisory.Producer.>
...tried adjusting the topic, but none of these worked:
topic:Act
OK, so I discovered ActiveMQPooledConnectionFactor uses pooled, anonymous
producers, for which advisories are not generated, which explains my issue.
Reference:
https://issues.apache.org/jira/browse/AMQ-4176
http://activemq.apache.org/how-do-i-use-jms-efficiently.html
--
Sent from: http://act
It's my understanding each kahadb is assigned a checkpoint thread which,
every 5s (default), wakes up and does something; what is it doing, and is
there any negative impact if the interval is increased to 60s or 120s? We
are using persistent messages, jsyk
--
Sent from: http://activemq.2283324.n
o brokers in NY are available.
failover:( failover:(tcp://ny1,tcp://ny2),
failover:(tcp://chi1,tcp://chi2))?randomize=false&priorityBackup=true
We're exploring DNS and F5 options as well, but we want to leverage the
software as much as possible before configuring infrastructure.
Tha
Tim,
We missed that one! Looks promising, though the only gripe I have with that
approach is duplication of data, creating maintenance overhead and higher
likelihood of misconfigurations.
I assume the nested option I suggested is not supported?
Raffi
-Original Message-
From: Timothy
lover:(tcp://ny1,tcp://ny2,tcp://chi1,tcp://chi2)
randomize=true
priorityBackup=true
priorityURIs=tcp://ny1,tcp://ny2
Thanks, Tim, very helpful!
Best,
Raffi
-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com]
Sent: Thursday, September 24, 2015 5:57 PM
To: users@activemq.
Looking to confirming transports that support client failover in 5.11/A-MQ 6.2
Based on documentation, we found the following; are we missing anything?
Openwire
Openwire.net
AMQP JMS
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential and is inten
Tim,
To be clear, NoB and M/S are mutually exclusive within the same master/slave
group, but the same does not hold true for "cluster" given its ambiguity.
Raffi
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Tuesday, Se
Barry,
No, not from the client perspective, there is no special designation. Provided
config permits message flow between A and B, messages
should flow in the direction of the connector config.
Raffi
-Original Message-
From: barry.barn...@wellsfargo.com [mailto:barry.barn
n?
Regards,
Barry
-Original Message-----
From: Basmajian, Raffi [mailto:rbasmaj...@ofiglobal.com]
Sent: Wednesday, September 30, 2015 3:07 PM
To: users@activemq.apache.org
Subject: RE: Network of Brokers - Putting/Getting from a queue
Barry,
No, not from the client perspective, there is no special d
Is the REST api enabled in ActiveMQ 5.11?
I'm using Fuse 6.2, which has ActiveMQ 5.11, but I can't seem to get anything
working with sending or receiving messages over HTTP, all I get is 404:
http://localhost:8181/api/message
http://localhost:8181/api/jolokia
wget --http-user=fuse --http-passwor
Barry,
If you're using SSL, do something like this:
http://ggl-consulting.blogspot.com/2015/03/broker-to-broker-network-connector-with.html
Best
Raffi
-Original Message-
From: barry.barn...@wellsfargo.com [mailto:barry.barn...@wellsfargo.com]
Sent: Sunday, Octob
I'm not 100% sure if duplex works with SSL.
Glad you're making progress :-)
Raffi
-Original Message-
From: barry.barn...@wellsfargo.com [mailto:barry.barn...@wellsfargo.com]
Sent: Sunday, October 04, 2015 10:06 PM
To: users@activemq.apache.org
Subject: RE: Network of Brokers
f. Brokers
configured in NoB, on the other hand, talk the same language, so there's no
technical gap to bridge and thus no need to transform from one message format
to another.
Is that a correct assessment or am I missing something?
Raffi
-Original Message-
From: Chri
operations for restricting access to destinations, but these are too
limiting for our needs. Can we achieve fine-grained access as depicted above,
or does this require a custom LDAP module?
Raffi
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential
Have you looked at Message Groups?
http://activemq.apache.org/message-groups.html
-Original Message-
From: skrish018c [mailto:sunil_kris...@cable.comcast.com]
Sent: Thursday, October 08, 2015 8:03 AM
To: users@activemq.apache.org
Subject: Can we achive message priority with parallel pro
Are composite destinations supported for all types of clients, not just
JMS/Java?
For example, is it possible for HTTP client to send a message to three queues
at once?
curl -d "body=message" http://mqhost/api/message/TEST1,TEST2,TEST3?type=queue
This e-mail transmission may contain informati
Are you referring to the G1 collector?
I know it's completely subjective, but I'd be curious to know what settings (in
general) work well for moderate volume.
Raffi
-Original Message-
From: burtonator2...@gmail.com [mailto:burtonator2...@gmail.com] On Behalf Of
Kevin B
Max memory is only 1Gb? Not knowing anything about your use cases or volumes,
1Gb is low, try increasing to 2Gb, so how far that gets you.
Btw, on Java 8, "PERM" settings related to PermGen memory space are ignored;
that space was removed, replaced with Meta space, use -XX:MaxMetaspaceSize to
c
min as 1024?
Regards,
Barry
-Original Message-
From: Basmajian, Raffi [mailto:rbasmaj...@ofiglobal.com]
Sent: Tuesday, October 20, 2015 1:18 PM
To: users@activemq.apache.org
Subject: RE: GC Overhead limit exceeded?
Max memory is only 1Gb? Not knowing anything about your use cases or
Tim,
Can you share the G1 settings you used?
Raffi
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Wednesday, October 21, 2015 10:41 AM
To: ActiveMQ Users
Subject: Re: GC Overhead limit exceeded? [ EXTERNAL ]
Before you can tune for
y with the performance you're seeing.
Tim
On Wed, Oct 21, 2015 at 9:14 AM, Basmajian, Raffi
wrote:
> Tim,
>
> Can you share the G1 settings you used?
>
> Raffi
>
> -Original Message-
> From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Is it possible to configure a network connector such that on startup it is
disabled, but may be activated later via JMX or updated config?
Raffi
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential and is intended exclusively for the person(s
sessions a broker
creates? If so, where are these limits defined?
Raffi
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential and is intended exclusively for the person(s) to
whom it is addressed. Any use, copying, retention or disclosure by
ual use, I don't see it being a practical
solution for collection in this case. (unless I'm missing something?)
JB,
Got a link for this? Karaf Decanter for the ActiveMQ view
Raffi
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent:
You can do it via JMX,
Attribute - BrokerVersion
MBean - org.apache.activemq:type=Broker,brokerName=
-Original Message-
From: Jan Gargulák [mailto:jan.gargu...@trixi.cz]
Sent: Monday, November 02, 2015 9:15 AM
To: users@activemq.apache.org
Subject: Get ActiveMQ broker version programma
-
From: Basmajian, Raffi [mailto:rbasmaj...@ofiglobal.com]
Sent: Monday, November 02, 2015 9:34 AM
To: users@activemq.apache.org
Subject: RE: Get ActiveMQ broker version programmatically [ EXTERNAL ]
You can do it via JMX,
Attribute - BrokerVersion
MBean - org.apache.activemq:type=Broker,
Is it possible to force a broker to start as a slave, for testing?
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential and is intended exclusively for the person(s) to
whom it is addressed. Any use, copying, retention or disclosure by any person
Nov 5, 2015 8:53 AM, "Basmajian, Raffi" wrote:
> Is it possible to force a broker to start as a slave, for testing?
>
> This e-mail transmission may contain information that is proprietary,
> privileged and/or confidential and is intended exclusively for the
> person
Is there anything in ActiveMQ that can auto publish JMX metrics to topics,
perhaps named after the Mbean/attribute itself?
We want to build a simple web console that receives only a few JMX metrics, but
we don't want to poll, would rather push metrics over ws/stomp.
Raffi
This e
I'm throwing a hail mary on this one,
We've set up a broker cluster on A-MQ 5.11 (Fuse 6.2).
Six master/slave pairs, full graph topology network of brokers; 12 brokers
total.
The cluster is brand new, no message activity; network connectors are active
and working properly.
Java 8, RHEL 7.1, 1gb/
ualVM?
On Nov 10, 2015 4:09 PM, "Basmajian, Raffi"
wrote:
> I'm throwing a hail mary on this one,
>
> We've set up a broker cluster on A-MQ 5.11 (Fuse 6.2).
> Six master/slave pairs, full graph topology network of brokers; 12 brokers
> total.
> The cluster
lternative.
Raffi
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Wednesday, November 11, 2015 8:41 AM
To: ActiveMQ Users
Cc: asha...@vizuri.com; Kent Eudy
Subject: RE: JMX connections creating high cpu and GC [ EXTERNAL ]
The only way I can t
Hi Francois,
If you're using REST-to-JMX api from Jolokia, this is what you need:
https://jolokia.org/reference/html/protocol.html
Best,
Raffi
-Original Message-
From: fliot [mailto:franc...@liot.org]
Sent: Friday, November 13, 2015 12:43 PM
To: users@activemq.apache.org
Subject
Francois,
The answer is in that documentation, either list or wildcard will work,
-Original Message-
From: fliot [mailto:franc...@liot.org]
Sent: Friday, November 13, 2015 1:53 PM
To: users@activemq.apache.org
Subject: RE: JMX : how to browse queues [ EXTERNAL ]
Thanks for you respon
When using network of brokers, does QueueBrowser show messages from a single
broker, or an aggregate of messages from all brokers assuming messages for a
given queue reside on more than one broker?
This e-mail transmission may contain information that is proprietary,
privileged and/or confident
Thanks, Tim.
Raffi
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Sunday, November 15, 2015 3:16 AM
To: ActiveMQ Users
Subject: Re: QueueBrowers in clustered topologies [ EXTERNAL ]
When you browse a queue, you are only browsing the
What are you trying to achieve? You mentioned "replication" and "forwarding"
interchangeably, which is confusing. Message replication is a function of the
persistence adapter, not network of brokers.
Sent from my Verizon Wireless 4G LTE smartphone
Original message
From: mag
OK, understood.
I haven't used composite queues so I won't be able to assist on this question,
though I'm sure veterans will chime in with their thoughts.
Good luck
-Original Message-
From: magnusT [mailto:magnus.thylan...@greenhatpeople.com]
Sent: Wednesday, November 18, 2015 7:29 AM
Tim, we need an app for that :-)
Raffi
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Wednesday, November 18, 2015 10:27 AM
To: ActiveMQ Users
Subject: Re: ActiveMQ Brokers starts the reindex of the KahaDB on every startup
[ EXTERNAL
Looking for soak test harness, is one available in the code base? Did a quick
search, found one for Artemis, but need ActiveMQ
Raffi
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential and is intended exclusively for the person(s) to
whom it is
I'm looking for test harnesses to produce various types of load for soak,
stress, and performance testing. Quick google search revealed some stuff for
Artemis, but not ActiveMQ; is there nothing in the project that addresses this
need?
Raffi
This e-mail transmission may contain inform
NoB forwards messages based on consumer demand, not for achieving failover.
You can get failover on the client using standalone brokers, just use
failover:() protocol from client.
Master/Slave is true failover.
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Tuesday
t config, but leverage ActiveMQ cluster aware clients library to
manage connection failovers.
Hope that helps,
Raffi
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Tuesday, December 01, 2015 2:57 PM
To: users@activemq.apache.org
Subject: Re: ActiveMQ deployment [ EX
ewer replicated
LevelDB store. There are some stability issues with replicated LevelDB (w/ the
code handling the zookeeper connection). Do you use an older configuration to
handle M/S?
Jim
On Tue, Dec 1, 2015 at 4:24 PM Basmajian, Raffi
wrote:
> That's exactly the configuration we're
only, not stomp, ws, amqp:
Full reference here
http://activemq.apache.org/failover-transport-reference.html
Hope that helps
Raffi
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Tuesday, December 01, 2015 7:33 PM
To: users@activemq.apache.org
Subject
I'm looking for test harnesses to perform soak, stress, performance, and load
testing on ActiveMQ.
Found some stuff for Artemis, not ActiveMQ,
Raffi
This e-mail transmission may contain information that is proprietary,
privileged and/or confidential and is intended exclusively for the per
you not have a problem to use Scala. Gatling provide a JMS extension which
support ActiveMQ. But I never tested it.
http://gatling.io/docs/2.1.1/jms.html
Michael
2015-12-02 15:41 GMT+01:00 Basmajian, Raffi :
> I'm looking for test harnesses to perform soak, stress, performance,
> a
hosts; the advantage of using LB/wide-IP is avoiding all this complexity at the
client level.
Hope that helps
Raffi
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Wednesday, December 02, 2015 1:34 PM
To: users@activemq.apache.org
Subject: Re: ActiveMQ deployment [ EXTERNA
jolokia REST docs here:
https://jolokia.org/reference/html/protocol.html
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Wednesday, December 02, 2015 3:38 PM
To: users@activemq.apache.org
Subject: Re: ActiveMQ deployment [ EXTERNAL ]
Raffi,
BTW, I am unable to get any res
from the screen shots, but this tool does not appear to
provide such feature, does it?
2) Is stomp.js stable? I understand it's no longer supported.
Raffi
-Original Message-
From: A.Marchand [mailto:a.march...@progeri.com]
Sent: Wednesday, December 02, 2015 2:55 AM
To: users@activem
Yes, that is expected behavior. Slaves do not service normal requests, the
transport connectors are not enabled,
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Thursday, December 03, 2015 1:57 PM
To: users@activemq.apache.org
Subject: 5.12.1 Master/Slave behavior
Show the client-side configuration you're using.
-Original Message-
From: Rallavagu [mailto:rallav...@gmail.com]
Sent: Wednesday, December 09, 2015 7:04 PM
To: users@activemq.apache.org
Subject: NoB and Load Balancing [ EXTERNAL ]
ActiveMQ 5.12.1
Setup Network of Brokers between two clu
Dsubject=foo.bar
On 12/9/15 4:19 PM, Basmajian, Raffi wrote:
> Show the client-side configuration you're using.
>
> -Original Message-
> From: Rallavagu [mailto:rallav...@gmail.com]
> Sent: Wednesday, December 09, 2015 7:04 PM
> To: users@activemq.apache.org
> Subjec
be simpler to publish to a failover URL containing all the brokers
rather than starting an embedded broker whose sole purpose is to publish stats?
It seems like your proposed approach adds unnecessary complexity.
Tim
On Dec 16, 2015 3:59 PM, "Raffi" wrote:
> Wanted to run this by the commu
78 matches
Mail list logo
