Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of andrew@oc384.net designates
 204.80.187.5 as permitted sender)
From: "Andrew M" <andrew@oc384.net>
To: <users@activemq.apache.org>
References: <03be01c87e33$1b098620$511c9260$@net>
 <ec6e67fd0803042217o7958b36er891b9b93736fe1be@mail.gmail.com>
 <046f01c87ed8$7313c3d0$593b4b70$@net> <04cd01c87f01$211fb4c0$635f1e40$@net>
In-Reply-To: <04cd01c87f01$211fb4c0$635f1e40$@net>
Subject: RE: Retroactive consumer not working...
Date: Fri, 7 Mar 2008 17:04:56 -0600
Message-ID: <016701c880a7$aa061c00$fe125400$@net>
MIME-Version: 1.0
Content-Type: text/plain;
	charset="us-ascii"
Content-Transfer-Encoding: 7bit
Thread-Index: Ach+iKueya305kDmQiWj30cSvZEDQwAThxwAAAB3pOAAc7RvgA==
Content-Language: en-us

Does anyone have an example of working retroactive consumer code?

Thanks,
Andrew


-----Original Message-----
From: Andrew [mailto:andrew@oc384.net] 
Sent: Wednesday, March 05, 2008 2:40 PM
To: users@activemq.apache.org
Subject: Retroactive consumer not working...

My broker is not feeding my consumer the messages from the retroactive queue
when the consumer connects.  The producer puts in a 10 min (600000ms) TTL so
I would think when my consumer reconnects it should receive the last 10 mins
of msgs.  Otherwise things appear fine, new msgs are received, etc... any
ideas?


On the producer.......

    private Session getActiveMqSession() throws JMSException {
        String url = "failover:(tcp://" + ACTIVE_MQ_SERVER + ":" +
ACTIVE_MQ_PORT +
"?wireFormat.maxInactivityDuration=0)?maxReconnectAttempts=0";
        ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(url);
        connection = connectionFactory.createConnection();
        ((ActiveMQConnection)connection).setUseAsyncSend(false);
        connection.start();
        return connection.createSession(false, Session.SESSION_TRANSACTED); 
    }
    
    Session session = getActiveMqSession();
    
    void send(Object a) throws blah blah blah {
        Destination destination = session.createQueue(consumerName);
        producer = session.createProducer(destination);
        ObjectMessage m = session.createObjectMessage();
        m.setObject(a);
        //10 min TTL
        ((ActiveMQMessageProducer)producer).send(m, DeliveryMode.PERSISTENT,
Message.DEFAULT_PRIORITY, 600000L); 
    }
    

...and on the Consumer...  
  
    Session session;
    
    public void run() {
    	String url =
"failover:(tcp://tupolev:61616?wireFormat.maxInactivityDuration=0)?maxReconn
ectAttempts=0";
	ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(url);
      Connection connection = connectionFactory.createConnection();
      connection.start();
      connection.setExceptionListener(this);
      session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
   }
		
   public void subscribe(String destName, MessageListener l) throws
JMSException {
      destName = destName + "?consumer.retroactive=true";
      MessageConsumer mc =
session.createConsumer(session.createQueue(destName));
      mc.setMessageListener(l);
    }
                

-----Original Message-----
From: Andrew [mailto:andrew@oc384.net] 
Sent: Wednesday, March 05, 2008 9:49 AM
To: users@activemq.apache.org
Subject: RE: purging an ActiveMQ queue

Thanks I'll create it as retroactive.  Problem is, how can I tell the broker
to purge the msgs at midnight so I get only msgs from the current day?
Would I just schedule a messageConsumer.close() ?

Thanks,
Andrew


-----Original Message-----
From: James Strachan [mailto:james.strachan@gmail.com] 
Sent: Wednesday, March 05, 2008 12:17 AM
To: users@activemq.apache.org
Subject: Re: purging an ActiveMQ queue

On 04/03/2008, Andrew <andrew@oc384.net> wrote:
> I would like to set up a topic or queue so that when a client connects to
>  the broker and subscribes to that topic he receives a refresh of all the
>  messages sent so far on that topic that day.  At midnight the broker
should
>  purge the day's messages.  What's the best way to do that?

For queues, messages stay on a queue until they expire. For topics,
normally you only get messages sent after you start subscribing
(unless you use persistent topic subscriptions) though ActiveMQ
supports Subscription Recovery for this kinda stuff...

http://activemq.apache.org/subscription-recovery-policy.html

-- 
James
-------
http://macstrac.blogspot.com/

Open Source Integration
http://open.iona.com