Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 160E6105EB for ; Thu, 20 Feb 2014 07:10:49 +0000 (UTC) Received: (qmail 42974 invoked by uid 500); 20 Feb 2014 07:10:48 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 42796 invoked by uid 500); 20 Feb 2014 07:10:46 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 42749 invoked by uid 99); 20 Feb 2014 07:10:45 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Feb 2014 07:10:45 +0000 X-ASF-Spam-Status: No, hits=2.8 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of suonayi@gmail.com designates 209.85.215.182 as permitted sender) Received: from [209.85.215.182] (HELO mail-ea0-f182.google.com) (209.85.215.182) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Feb 2014 07:10:39 +0000 Received: by mail-ea0-f182.google.com with SMTP id r15so687409ead.13 for ; Wed, 19 Feb 2014 23:10:19 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=gLTPBxuqPZzXwkewUZScICRMxmA3Y1xNpPz4D6s5L9s=; b=H6qEOVxhOJZdi/5I+2//Q1VWBYI5sNsi6lDZVrbIHADtjPc7fUjDzzU3b55IFguOwb anG5/XZyUGO7HJlHls0ZB1gahNIzXbq+PcVHb9VDxddGZR/gGBiZjeFFhB5/KXM3OeMC PmOIZrXWN5VycSS8b5/3zMRvwHlFaTCi+PzXs5tnIaR6EAwmVItZtFwiZK3s5XSGrmh4 GnY0rIF5V4xMA058RtSaDjuvcY/hj22qyZrqHS14qVSFMU4ouQaZ/adIC5kiVD4kzqDX MZToHNfFQr9ryIcY4MobJ8wDnkmC1U7IIkDaxX942O54anmn74W6MICPj49O30oR7eg1 YhXg== MIME-Version: 1.0 X-Received: by 10.15.23.194 with SMTP id h42mr324821eeu.32.1392880219582; Wed, 19 Feb 2014 23:10:19 -0800 (PST) Received: by 10.14.143.76 with HTTP; Wed, 19 Feb 2014 23:10:19 -0800 (PST) In-Reply-To: References: <1392791372947-4678113.post@n4.nabble.com> <8741158E-7727-41BB-B6D6-2C71658CE56E@redhat.com> Date: Thu, 20 Feb 2014 15:10:19 +0800 Message-ID: Subject: Re: Activemq issue when Slave started From: Yin Wang To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=089e0160c1aab3f3f704f2d132a4 X-Virus-Checked: Checked by ClamAV on apache.org --089e0160c1aab3f3f704f2d132a4 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable What's message ack mode you're using? If your consumer does not acknowledge messages that have been processed, eg, you may forget to manual ack message when using client ack mode or forget to commit session when using transaction, those messages will be redelivered when consumer or broker gets restarted. 2014-02-20 11:24 GMT+08:00 ramdassv : > Hi Torsten, > > Thanks for your response. Yes I have both the broker instances work on th= e > same levelDB. I am OK if the some messaged are getting enqueued, But what > happened here it is processing the Old messages which are already > Delivered. > For Example: > Per day There are 100,000 Message are getting processed. When I take down > the Master, Then slave is started processing message around 150,000 alrea= dy > delivered message, which 1.5 days old. > > Thanks, > Ram > > > On Wed, Feb 19, 2014 at 11:18 AM, Torsten Mielke-3 [via ActiveMQ] < > ml-node+s2283324n4678166h93@n4.nabble.com> wrote: > > > Hi Ram, > > > > Assuming both broker instances master and slave work on the same levelD= B > > persistence store. Is it possible that you have some messages enqueued > when > > the master broker goes down? > > When the slave takes over, it would reload the messages from the > > persistence store and hence they will be available right after startup = on > > the slave broker as well. > > > > Regards, > > > > Torsten Mielke > > tmielke.blogspot.com > > > > On 19 Feb 2014, at 07:29 am, ramdassv <[hidden email]< > http://user/SendEmail.jtp?type=3Dnode&node=3D4678166&i=3D0>> > > wrote: > > > > > Here is the my implementation we have in production, We have Master > > Slave > > > with LevelDB for persistence. For some reason when Master node goes > down > > or > > > getting restarted the Queue is getting initialized with some already > > > Delivered message. Is there some setting we are missing. > > > Thanks, > > > Ram > > > > > > > > > > > > -- > > > View this message in context: > > > http://activemq.2283324.n4.nabble.com/Activemq-issue-when-Slave-started-t= p4678113.html > > > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > > > > > > > > > > > > > > > ------------------------------ > > If you reply to this email, your message will be added to the discussi= on > > below: > > > > > http://activemq.2283324.n4.nabble.com/Activemq-issue-when-Slave-started-t= p4678113p4678166.html > > To unsubscribe from Activemq issue when Slave started, click here< > http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=3Dun= subscribe_by_code&node=3D4678113&code=3DcnZlbmthZGFzd2FteUBhcHB0aXZvLm5ldHw= 0Njc4MTEzfDE4MDMyMzY5ODE=3D > > > > . > > NAML< > http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=3Dma= cro_viewer&id=3Dinstant_html%21nabble%3Aemail.naml&base=3Dnabble.naml.names= paces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.w= eb.template.NodeNamespace&breadcrumbs=3Dnotify_subscribers%21nabble%3Aemail= .naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aem= ail.naml > > > > > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Activemq-issue-when-Slave-started-t= p4678113p4678182.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > --089e0160c1aab3f3f704f2d132a4--