Return-Path: X-Original-To: apmail-streams-dev-archive@minotaur.apache.org Delivered-To: apmail-streams-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3756810CC2 for ; Thu, 1 Aug 2013 18:38:13 +0000 (UTC) Received: (qmail 82905 invoked by uid 500); 1 Aug 2013 18:38:13 -0000 Delivered-To: apmail-streams-dev-archive@streams.apache.org Received: (qmail 82871 invoked by uid 500); 1 Aug 2013 18:38:11 -0000 Mailing-List: contact dev-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list dev@streams.incubator.apache.org Received: (qmail 82863 invoked by uid 99); 1 Aug 2013 18:38:09 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Aug 2013 18:38:09 +0000 X-ASF-Spam-Status: No, hits=-2001.5 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Thu, 01 Aug 2013 18:38:08 +0000 Received: (qmail 82011 invoked by uid 99); 1 Aug 2013 18:37:48 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Aug 2013 18:37:48 +0000 Date: Thu, 1 Aug 2013 18:37:48 +0000 (UTC) From: "Danny Sullivan (JIRA)" To: dev@streams.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (STREAMS-19) create persistence layer to maintain an on-going activity stream MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/STREAMS-19?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13726719#comment-13726719 ] Danny Sullivan commented on STREAMS-19: --------------------------------------- How about this idea: The repository layer would take the place in the camel context where the activityWarehouseDistributer is now (the distributeToSubscribers method). In place of the distributeToSubscribers method would be a repository service method that takes in the Exchange object, extracts the Activity Streams Java object from the body and stores it in the database. Then the distributeToSubscribers method would iterate through every subscriber (as it does now), make a call to the database according to the subscriber's filters, and add whatever activity objects are returned to the subscriber's stream array. This distributeToSubscribers method would then run on a timer (like every 60 seconds or so). This might make it harder for the database to be optional. Perhaps the distributeToSubscribers method can first check to see if there is a repository connection open, and if not turn to the activities queue? > create persistence layer to maintain an on-going activity stream > ---------------------------------------------------------------- > > Key: STREAMS-19 > URL: https://issues.apache.org/jira/browse/STREAMS-19 > Project: Streams > Issue Type: New Feature > Reporter: Danny Sullivan > > Should be located in the architecture where the activity queue is located. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira