Master/Slave out of sync

Hello, I have a simple Master/Slave configuration between two brokers. I use default configuration of ActiveMQ 5.1. I start the master and then the slave, both with empty queues. I repeat the following steps : - A producer sends 10 messages on a queue (Then the producer/session/connection is

Re: Topic counts explanation

I'll take a stab at it ;) EnqueueCount: The number of messages that have been written to the queue over the lifetime of the queue. DequeueCount: The number of messages that have been successfully (i.e., they’ve been acknowledged from the consumer) read off the queue over the lifetime of the

Re: Activemq5 - Messages redelivered..

Sounds like an 'ack' related issue. What acknowledge mode are you using for your consumer? Joe Get a free ActiveMQ user guide @ http://www.ttmsolutions.com titten wrote: Hi. I am having a problem with getting the same messages redelivered to my client. The configuration is Apache

Re: Activemq5 - Messages redelivered..

Hi. I have tried both session =con.createSession(true,Session.CLIENT_ACKNOWLEDGE); and session =con.createSession(true,Session.AUTO_ACKNOWLEDGE); When using client ack i have specifically added in my onMessageMethod: message.acknowledge(); Thanks. On Thu, Sep 25, 2008 at 1:47 PM, Joe Fernandez

Re: Activemq5 - Messages redelivered..

Can you post the consuming portion of your code? Joe titten wrote: Hi. I have tried both session =con.createSession(true,Session.CLIENT_ACKNOWLEDGE); and session =con.createSession(true,Session.AUTO_ACKNOWLEDGE); When using client ack i have specifically added in my onMessageMethod:

Re: Activemq5 - Messages redelivered..

public void start()throws JMSException{ try{ ConnectionFactory factory = template.getConnectionFactory(); Connection con = factory.createConnection(); con.start(); session =con.createSession(true,Session.CLIENT_ACKNOWLEDGE);

Re: Activemq5 - Messages redelivered..

If you're not using transactions, then change this session =con.createSession(true,Session.CLIENT_ACKNOWLEDGE); to this session =con.createSession(false,Session.CLIENT_ACKNOWLEDGE); ^^^ Joe titten wrote: public void start()throws JMSException{

Re: Activemq5 - Messages redelivered..

Thanks so much! You truelly rock! On Thu, Sep 25, 2008 at 3:42 PM, Joe Fernandez [EMAIL PROTECTED] wrote: If you're not using transactions, then change this session =con.createSession(true,Session.CLIENT_ACKNOWLEDGE); to this session =con.createSession(false,Session.CLIENT_ACKNOWLEDGE);

Failover lock problem

-BEGIN PGP SIGNED MESSAGE- Hash: SHA1 Hi, is it possible to configure a lock query which does not keep a transaction open all the time? We are using activemq 4.1.1 and a postgres database backend. When we create a database backup the transaction is aborted and a backup is created, but

Active MQ 5.1 REST interface.

I'm trying to use the rest interface that comes as part of the web demo and running into an issue reading from queues. Before I go too far, here are some clues as to my environment: $ java -version java version 1.5.0_15 Java(TM) 2 Runtime Environment, Standard Edition (build 1.5.0_15-b04) Java

setting dead Letter header in catch block?

I have the following block that fails: } catch (Exception e) { log.error(X); *// i want to set deadLetter headers here ** throw new RuntimeException(e); } How can I set my dead letter headers as to the

SSL examples for ActiveMQ-CPP

I noticed that CMS (current svn trunk) contains some code to hook in with OpenSSL. Has anyone got an example of using it that they can share ? Best regards, Chris

cms dont's support udp protocol

Hi, all Does anyone know when will cms support udp, and is there a report about tcp and upd's performance difference. Thanks. -- It's winter now, let's hibernate.