Hi
We have a network of brokers something like this:
A <--->B<--->C<>Mesh
We are producing some Messages with Request / Reply Pattern in A and those
Messages are supposed to
be consumed also in A.
Now sometimes only half the Messages are being consumed in A and the rest is
"lost" som
Is this with the default Network TTL setting of 1? Sounds like that's the
case and that decreaseNetworkConsumerPriority is false (also the default).
So, even though the consumer is only on A, and a person can easily see it
makes no sense to move the messages to broker B, in an ActiveMQ
demand-fo
That method, onCommand(), is called for every transport "command"; commands
are the unit of the ActiveMQ openwire protocol (not sure what happens with
non-openwire). So, it is called with tremendous detail that is very highly
activemq-internal-specific. And it is called with high frequency on bus
If one consumer can keep up with the production rate, then that's adequate.
When rate of a single consumer cannot match the total production rate
(across all producers), adding more consumers is likely the answer.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-
Hi,
Using ActiveMQ 5.8.
I observed a behavior while restarting ActiveMQ broker.
Details: Two days ago my disk space filled completely and in some time I
have cleaned it up. KahaDB was also on the same storage. Today when I
restarted my broker it was not able to come up and throw the exception:
Thanks Felix, that did the trick.
@artnaseef
I just want to extract the queue statistics and forwarded through the static
bridged network.
As the created message gets JMSType of 'Advisory' (do not know why) broker
did not let the message to pass through.
Advisories are disabled in my system and I
Can you give some detail to the problem?
Advisory topics have a very specific usage in the brokers, especially with a
network-of-brokers. Would it be possible to acheive the goal with a regular
Topic instead of an advisory one?
--
View this message in context:
http://activemq.2283324.n4.nabbl
The most straight-forward approach would be to remove all sources of message
production and allow consumption to drain all messages from the old
solution, if that's feasible.
Another idea: how about standing up new brokers with the Oracle backend and
setting up bridges that only move messages from
No hints?
This is killing me - I'm restarting AMQ several times a week now. :-/
On Wed, May 7, 2014 at 11:18 AM, Larry Meadors wrote:
> I'm running AMQ 5.7.0 with a camel application (using camel 2.10.7, in
> case that's relevant) and recently, the app has started logging these
> messages:
>
> W
Hello,
I need to build a system with a number of hosts connected through an
unreliable mesh network where the hosts are physically moving, i.e.
all connections are expected to drop regularly, and hosts that used
to be one hop apart might suddenly be three hops apart or not connected
at all.
The ne
Yes or to be correct at the message, e.g. CorrelationID:
org.apache.jmeter.protocol.jms.Utils.addJMSProperties(Message, Map):
The same should apply to properties "JMSPriority" (msg.setJMSPriority(int))
and "JMSExpiration" (msg.setJMSExpiration(long)).
I will file a feature issue and try to prov
Dear all,
I used to BrokerService embedded in my java application and Advisory Message
to listener consumer join, consumer left(know everything about
consumer:consumer-id, client-id, ...). But I don't know how to
close/disable/stop consumer from broker service embedded or from Advisory
Message. P
12 matches
Mail list logo
