Hi,
Could you share your activemq.xml for each broker ?
Thanks
Eegards
JB
carlzuo a écrit :
>I had two ActiveMQ brokers (A and B) that were configured as store-forward
>network. They work perfectly to forward messages from A to B when there is a
>consumer connected on broker B and producer sen
No, you can not rebalance the pending messages but can control the distribution
rate.
Each broker/nodes use a oneway network connector and give the slow node a lower
prefetchSize may help.
The consumers on the slow broker/node need a lower prefetchSize as well.
At 2013-03-21 06:17:26,ms wrote:
As default, a message can pass through a broker only once.
Since your message has passed through broker A so it won't be replayed
except for your additional requirement.
You can enable replay feature via adding policy for you queue like this:
Or you may take a look at the stuck m
Hi,
could you share your activemq.xml on each broker ?
Thanks,
Regards
JB
On 03/20/2013 07:43 PM, carlzuo wrote:
I had two ActiveMQ brokers (A and B) that were configured as store-forward
network. They work perfectly to forward messages from A to B when there is a
consumer connected on broker
I had two ActiveMQ brokers (A and B) that were configured as store-forward
network. They work perfectly to forward messages from A to B when there is a
consumer connected on broker B and producer sends messages to A. The problem
is that when the consumer is killed and reconnected to A, the queued
m
Hi there,
I have two embedded brokers configured as a static network of brokers.
There is one producer (overall) and each node features 4 consumers. Messages
are getting distributed evenly over both brokers.
Node A processes the messages a little faster than node B. So, after some
time all 4 consu
Simple newbie question - I donwloaded and installed version 5.8.0 and
attempts to hit the webconsole @ http://locahost:8161 is resulting in me
being prompted for crecdentials. I'd like to turn this off - I tried setting
property name="authenticate" value="false" in jetty.xml and resatarted the
serv
Hi Christian,
Thank you for your reply. I appreciate it.
Kind regards,
T. Akhayo
2013/3/20 Christian Posta
> The plugins array is looped through and installed one at a time. But what
> it does is "wrap" the previous broker. So the plugins will see the message
> in the reverse order they are s
Thx Gary!
Will have my Team look into the Unit test, etc
On Tue, Mar 12, 2013 at 5:52 PM, Gary Tully wrote:
> that is a bug for sure. There was a related issue resolved in 5.8 -
> https://issues.apache.org/jira/browse/AMQ-4220 and the fix has a nice
> test.
> Maybe u can come up with a variant
The plugins array is looped through and installed one at a time. But what
it does is "wrap" the previous broker. So the plugins will see the message
in the reverse order they are specified.
On Wed, Mar 20, 2013 at 8:47 AM, T Akhayo wrote:
> Good afternoon,
>
> I have a activemq server for my jm
Problem solved.
Error was not in defining redelivery policy
but in dealing with messages ack/not ack.
When message was to be acknowledged it was done this way:
_message->acknowledge();
However, when message was to be returned to the queue the following snippet
was called:
_session->reco
Hi all,
I'm currently trying to come up with a plan to upgrade several applications
to use Java 7 but I am not fully understanding several dependencies,
hopefully you can help.
The dependency setup currently:
* ActiveMQ 5.5.1
* Apache Camel 2.7.1
I understand that camel added support for Java 7
Hi,
I am new to ActiveMQ and JMS.
I want a simple Publisher/Subscriber Module to be implemented using topic
and "ActiveMQ" as the jms provider instead of sdk.
If any example of how to do so specially how to use activeMQ as the JMS
provider and relavant publishing/subscribibg of topics will do me a
Hello,
I am using ActiveMQ-CPP 3.4.5 to connect from C++ program to message broker.
The problem I encountered is connected with redelivery policy.
Messages which are returned to queue are redelivered immediately. This is
not the
behaviour I expect. I would expect the messages to be returned after
Hi Guys,
I encountered this error on ActiveMQ start.log
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1.apply(LevelDBClient.scala:941)
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1.apply(LevelDBClient.scala:937)
at
org.apache.act
Simply, your message is larger than 64KB.
Take a look at:
http://www.drillio.com/en/software-development/java/encoded-string-too-long-64kb-limit/
At 2013-03-20 20:33:58,yogu13 wrote:
>What can be done to get some answers here :)
>
>LEt me know if i am missing out on details.. i searched throug
What can be done to get some answers here :)
LEt me know if i am missing out on details.. i searched through various
forums to only find that people who ended up with this issue never got any
resolution.
Regards,
-Yogesh
--
View this message in context:
http://activemq.2283324.n4.nabble.com/A
I found average size of messaged around 100 bytes using web site
http://mothereff.in/byte-counter
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-topic-vs-queue-tp4664859p4664933.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
18 matches
Mail list logo
