On Wed, 2012-08-22 at 23:49 -0700, joesan wrote:
> This is how my MessageListener looks like:
>
> *public class Listener implements MessageListener {
>
> public void onMessage(Message message) {
> try {
> MapMessage map = (MapMessage)message;
>
This is how my MessageListener looks like:
*public class Listener implements MessageListener {
public void onMessage(Message message) {
try {
MapMessage map = (MapMessage)message;
Long msgCount = map.getLong("counter");
Below is how my Consumer looks like:
*public class Consumer {
private static String brokerURL =
"failover:(tcp://localhost:61616,tcp://localhost:61617)?maxReconnectAttempts=-1";
private static transient ConnectionFactory factory;
private transient Connection connection;
private tr
Well as per the docs, it is so!
http://activemq.apache.org/failover-transport-reference.html
maxReconnectAttempts=-1 will try indefinitely! I will try that tomorrow on
my cluster configuration and let know the results here!
Thanks for all the help!
--
View this message in context:
http://act
I would try increasing the maxReconnectAttempts to a bigger value. Is there a
rule of thumb as to how big this should be? Is there an indefinite try? what
happens if I specify -1? Will it try indefinitely until it gets a
connection? I would love to have that!
--
View this message in context:
ht
At least from what I'm seeing in *ActiveMQ in Action*, that looks right.
Could it be that your maxRecoveryAttempts=1 is preventing it from
recovering the second time? (I'm fairly new to this myself)
(*Chris*)
On Wed, Aug 22, 2012 at 10:32 AM, joesan wrote:
> I'm happy to see some help at las
I'm happy to see some help at last.
Here is how the fail-over url looks like from my clients (both producer and
consumer)
failover:(tcp://localhost:61616,tcp://localhost:61617)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Clustering-Issue-tp4655306p4655440.
What is the connection URL you are using on your clients?
(*Chris*)
On Wed, Aug 22, 2012 at 12:16 AM, joesan wrote:
> Any help friends?
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-Clustering-Issue-tp4655306p4655410.html
> Sent from the ActiveMQ -
What is more troubling me is that the messages sent by the Producer to a
Topic is lost when the Master goes down. When I restart my consumer, all
those messages that the Producer had sent to the Topic was lost. How do I
handle this? Where is the high availability in picture in this AMQ
Clustering?
