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 DB3D111F89 for ; Wed, 30 Jul 2014 22:08:46 +0000 (UTC) Received: (qmail 66589 invoked by uid 500); 30 Jul 2014 22:08:46 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 66548 invoked by uid 500); 30 Jul 2014 22:08: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 66536 invoked by uid 99); 30 Jul 2014 22:08:46 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jul 2014 22:08:46 +0000 X-ASF-Spam-Status: No, hits=1.8 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_REMOTE_IMAGE X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of burtonator2011@gmail.com designates 209.85.217.172 as permitted sender) Received: from [209.85.217.172] (HELO mail-lb0-f172.google.com) (209.85.217.172) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jul 2014 22:08:44 +0000 Received: by mail-lb0-f172.google.com with SMTP id z11so1385027lbi.31 for ; Wed, 30 Jul 2014 15:08:19 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:from:date:message-id :subject:to:content-type; bh=qPhHDUwOSTlCGLzajWiHyHaXCSVSGkGM5Xt2EoeHU7g=; b=OOZN4/DKsZK4in/SV2Y7wQNHU6FVakPnwcSuvJAAoL+I+JdNY4UyAsDV+sixt4DkHN nzeoLs+vb7Lj8ziHrtbctYbY33WbhW3U3xJLXBZfxh3++UTHNHbF9j/KUVHG6kXv9bQD DAipkL0SD7LsJarHjezuLInHyrGKvGawV9rfmf+34QkzCg57in5AT4jnXpbpG1p1xyfZ f4miNXkBlemOwUZMOuvAEy31TNHA0SHyFG4OEwAFOdWhUT2iewk6M5OgGOcrpR1cqTnu B/kTPi6Ueeaj4rKvATcXa7ZLHUOKMdXANqLFDwwSPqCAAsy/MynmfKxVccr4AABoZDVO Icaw== X-Received: by 10.112.147.41 with SMTP id th9mr7316442lbb.12.1406758099619; Wed, 30 Jul 2014 15:08:19 -0700 (PDT) MIME-Version: 1.0 Sender: burtonator2011@gmail.com Received: by 10.112.180.137 with HTTP; Wed, 30 Jul 2014 15:07:59 -0700 (PDT) In-Reply-To: <53D8536B.2050103@gmail.com> References: <53D8317C.8090403@gmail.com> <53D8536B.2050103@gmail.com> From: Kevin Burton Date: Wed, 30 Jul 2014 15:07:59 -0700 X-Google-Sender-Auth: zf7bkOplEqFac0zS8yAo7TKRHXg Message-ID: Subject: =?UTF-8?Q?Re=3A_replicated_leveldb_and_scheduled_messages=E2=80=A6is_i?= =?UTF-8?Q?t_being_worked_on=3F?= To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=047d7b3a84c4d012cf04ff70646b X-Virus-Checked: Checked by ClamAV on apache.org --047d7b3a84c4d012cf04ff70646b Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Ah=E2=80=A6 nice. I'll take a look at it. I was thinking about it this morn= ing and this is probably more complicated than it initially seems. Logically it's somewhat straight forward, but there are a lot of steps involved. Lots of moving parts. So what I will probably do is try to get this code in production=E2=80=A6 a= nd when we're ready to allocate a week or so to building this out, I'll post a proposal to the list for an implementation strategy. On Tue, Jul 29, 2014 at 7:07 PM, Timothy Bish wrote: > On 07/29/2014 09:06 PM, Kevin Burton wrote: > >> Just looking at it now=E2=80=A6 I think what might be interesting is wri= ting a >> JobSchedulerStore without persistence and just using java.util.concurren= t >> collections interfaces=E2=80=A6 >> >> Just to prove that the semantics work and as a template for future >> versions. Then use that to get the LevelDB version to work. >> > > Refer to InMemoryJobSchedulerStore.java on trunk for an scheduler store > without persistence. > > >> On Tue, Jul 29, 2014 at 5:30 PM, Kevin Burton wrote= : >> >> OK=E2=80=A6 I assume the current one is based on KahaDB? >>> >>> >>> On Tue, Jul 29, 2014 at 4:42 PM, Timothy Bish >>> wrote: >>> >>> On 07/29/2014 07:19 PM, Kevin Burton wrote: >>>> >>>> So currently, the big caveat for leveldb replication is that >>>>> replicating >>>>> the schedule db doesn't work=E2=80=A6 >>>>> >>>>> How complicated is it going to be to get this to work with leveldb? >>>>> >>>>> Is anyone actively working on this? I kind of painted myself into a >>>>> corner >>>>> on this one. ActiveMQ does literally 95% of what I need and then I >>>>> realized that this isn't going to work. >>>>> >>>>> If it's being fixed=E2=80=A6 that's great. If not I might need to s= tep in and >>>>> help out. >>>>> >>>>> >>>>> >>>>> The LevelDB store does not yet support storing data associated with >>>>> Delay >>>>> and Schedule Message Delivery >>>>> = . >>>>> >>>>> Those are are stored in a separate non-replicated KahaDB data files. >>>>> Unexpected results will occur if you use Delay and Schedule Message >>>>> Delivery >>>>> >>>>> with >>>>> >>>>> the replicated leveldb store since that data will be not be there whe= n >>>>> the >>>>> master fails over to a slave. >>>>> >>>>> >>>>> There's no one currently working on this, we love contributions >>>>> though. >>>>> >>>> Trunk ActiveMQ has been updated to allow each of the persistence >>>> adapters >>>> to provide it's own implementation of JobSchedulerStore, so you'd need >>>> to >>>> implement one for LevelDB >>>> >>>> -- >>>> Tim Bish >>>> Sr Software Engineer | RedHat Inc. >>>> tim.bish@redhat.com | www.fusesource.com | www.redhat.com >>>> skype: tabish121 | twitter: @tabish121 >>>> blog: http://timbish.blogspot.com/ >>>> >>>> >>>> >>> -- >>> >>> Founder/CEO Spinn3r.com >>> Location: *San Francisco, CA* >>> >>> blog: http://burtonator.wordpress.com >>> =E2=80=A6 or check out my Google+ profile >>> >>> >>> >>> >>> >> > > -- > Tim Bish > Sr Software Engineer | RedHat Inc. > tim.bish@redhat.com | www.fusesource.com | www.redhat.com > skype: tabish121 | twitter: @tabish121 > blog: http://timbish.blogspot.com/ > > --=20 Founder/CEO Spinn3r.com Location: *San Francisco, CA* blog: http://burtonator.wordpress.com =E2=80=A6 or check out my Google+ profile --047d7b3a84c4d012cf04ff70646b--