Hi All, I have finished writing the documentation. You can find the doc from here[1]. Please update me on the changes that needed to be done. Any comment will be really appreciated to improve the documentation.
[1]= https://docs.google.com/document/d/1hUjGG1TW2KhCxW5IhrbAJQTgsa34GzDmmaxeLrtiry4/edit?usp=sharing Thank You! Best Regards, Ashan On Thu, Aug 6, 2015 at 12:00 PM, Ashan Dhananjaya <dhananjay...@gmail.com> wrote: > Hi All, > > I have changed the REST API to a generic one. Now it will be able to query > the health statistics data when we provide the startTime and endTime. > Please find the fallowing commits for the improvement [1] [2].And i > updated the REST API documentation as well [3]. Currently i'm working with > UI against the new REST calls. > > [1] = > https://github.com/apache/stratos/commit/0b84314889e86c07e108605587c09c5c45cca05e > [2] = > https://github.com/apache/stratos/commit/beea1272681791bdb18ccfbb49e48f8fd44b5682 > [3] = > https://docs.google.com/document/d/1kvEExNCv2RYsdk9PIM22RsTXxWX003NQoqKuJ1-Cxck/edit?usp=sharing > > Thank You! > Best Regards, > Ashan > > > On Tue, Aug 4, 2015 at 3:57 PM, Ashan Dhananjaya <dhananjay...@gmail.com> > wrote: > >> Hi Imesh, >> >> Noted the feedback. I will do the necessary changes to the REST API. >> >> Thank You! >> Best Regards, >> Ashan >> >> On Tue, Aug 4, 2015 at 12:44 PM, Imesh Gunaratne <im...@apache.org> >> wrote: >> >>> Hi Ashan, >>> >>> IMO an API should be generic, it should not be designed by looking at >>> the functional requirement of the UI. There could be many users using this >>> API. >>> >>> Thanks >>> >>> On Tue, Aug 4, 2015 at 9:46 AM, Ashan Dhananjaya <dhananjay...@gmail.com >>> > wrote: >>> >>>> Hi Imesh, >>>> >>>> Currently it is not possible to give a date range. We have included 5 >>>> different options as time period in the UI select to user like 30 minutes, >>>> 1hour ,1 day, 1 week, 1 month. >>>> >>>> Thank You! >>>> Best Regards, >>>> Ashan >>>> >>>> On Tue, Aug 4, 2015 at 9:22 AM, Imesh Gunaratne <im...@apache.org> >>>> wrote: >>>> >>>>> Hi Ashan, >>>>> >>>>> The API documentation looks good. Isn't it possible for us to specify >>>>> a date range when querying statistics? Currently in the API methods I can >>>>> only see a parameter called interval. >>>>> >>>>> Thanks >>>>> >>>>> On Tue, Aug 4, 2015 at 8:21 AM, Ashan Dhananjaya < >>>>> dhananjay...@gmail.com> wrote: >>>>> >>>>>> Hi All, >>>>>> >>>>>> I wrote a REST api documentation for the methods i implemented in the >>>>>> org.apache.stratos.rest.endpoint. You can find it from here[1]. >>>>>> >>>>>> Please update me on the changes that needed to be done. Any comment >>>>>> will be really appreciated to improve the documentation. >>>>>> >>>>>> [1]= >>>>>> https://docs.google.com/document/d/1kvEExNCv2RYsdk9PIM22RsTXxWX003NQoqKuJ1-Cxck/edit?usp=sharing >>>>>> >>>>>> Thank You! >>>>>> Best Regards, >>>>>> Ashan >>>>>> >>>>>> On Mon, Aug 3, 2015 at 12:40 PM, Ashan Dhananjaya < >>>>>> dhananjay...@gmail.com> wrote: >>>>>> >>>>>>> Hi All, >>>>>>> >>>>>>> As for the today's offline meeting. We have decided to add a >>>>>>> functionality to enable and disable the Health Statistic UI. I will be >>>>>>> working on this now onward. And after completing the chart with the tool >>>>>>> tip we will going to have the public hangout. >>>>>>> >>>>>>> Thank You! >>>>>>> Best Regards, >>>>>>> Ashan >>>>>>> >>>>>>> On Sun, Aug 2, 2015 at 8:35 PM, Ashan Dhananjaya < >>>>>>> dhananjay...@gmail.com> wrote: >>>>>>> >>>>>>>> Hi Imesh, >>>>>>>> >>>>>>>> I will be free for the whole next week. We can have the google >>>>>>>> hangout any day.Please give me a time slot to have the hangout. >>>>>>>> >>>>>>>> Thank You! >>>>>>>> Best Regards, >>>>>>>> Ashan >>>>>>>> >>>>>>>> On Sun, Aug 2, 2015 at 5:59 PM, Imesh Gunaratne <im...@apache.org> >>>>>>>> wrote: >>>>>>>> >>>>>>>>> Hi Ashan, >>>>>>>>> >>>>>>>>> Great work! May be we could arrange a public Google Hangout when >>>>>>>>> you are available to present the current status of the project. >>>>>>>>> >>>>>>>>> Thanks >>>>>>>>> >>>>>>>>> On Thu, Jul 30, 2015 at 11:00 PM, Ashan Dhananjaya < >>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>> >>>>>>>>>> Hi All, >>>>>>>>>> >>>>>>>>>> I have implemented formatters and did some changes in the cep >>>>>>>>>> event flow to change the RDBMS 3 tables in to one table as we >>>>>>>>>> discussed >>>>>>>>>> last week. And committed it. And id did few changes to the UI >>>>>>>>>> according to >>>>>>>>>> the feedback i had last week. I finished writing the REST API >>>>>>>>>> documentation >>>>>>>>>> and sent it to everyone. >>>>>>>>>> >>>>>>>>>> I have started to write a blog for the marketing aspect for >>>>>>>>>> stratos how Health Stat UI works and a documentation for the health >>>>>>>>>> statistics UI. >>>>>>>>>> >>>>>>>>>> [1]= >>>>>>>>>> https://github.com/apache/stratos/commit/1490310cae3ba085fbb77d84346dd66fd2b12132 >>>>>>>>>> >>>>>>>>>> Thank You! >>>>>>>>>> Best Regards, >>>>>>>>>> Ashan >>>>>>>>>> >>>>>>>>>> On Fri, Jul 24, 2015 at 11:17 PM, Imesh Gunaratne < >>>>>>>>>> im...@apache.org> wrote: >>>>>>>>>> >>>>>>>>>>> Great work Ashan! >>>>>>>>>>> >>>>>>>>>>> Actually you don't need to replace MySQL database with H2 rather >>>>>>>>>>> both options might be needed. The reason for having H2 is to allow >>>>>>>>>>> users to >>>>>>>>>>> see the statistics when running on Single-JVM mode with embedded H2 >>>>>>>>>>> database. >>>>>>>>>>> >>>>>>>>>>> On Thu, Jul 23, 2015 at 12:35 AM, Ashan Dhananjaya < >>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>> >>>>>>>>>>>> Hi All, >>>>>>>>>>>> >>>>>>>>>>>> I have implemented the UI for the Health Statistics UI. The git >>>>>>>>>>>> hub commits can be find from here [1]. >>>>>>>>>>>> >>>>>>>>>>>> And im moving forward to replace the MySql database from the >>>>>>>>>>>> embedded H2 RDBMS as we discussed offline on 22nd of July. >>>>>>>>>>>> >>>>>>>>>>>> Thank You! >>>>>>>>>>>> Best Regards, >>>>>>>>>>>> Ashan >>>>>>>>>>>> >>>>>>>>>>>> >>>>>>>>>>>> [1]= >>>>>>>>>>>> https://github.com/ashandk/stratos/commit/310ea343d80d009778f572da12a4098c7d2177ec >>>>>>>>>>>> >>>>>>>>>>>> >>>>>>>>>>>> On Thu, Jul 16, 2015 at 7:29 PM, Ashan Dhananjaya < >>>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>>> >>>>>>>>>>>>> Hi Imesh, >>>>>>>>>>>>> >>>>>>>>>>>>> Noted. I will create a documentation for the REST API. >>>>>>>>>>>>> >>>>>>>>>>>>> Thank You! >>>>>>>>>>>>> Best Regards, >>>>>>>>>>>>> Ashan >>>>>>>>>>>>> >>>>>>>>>>>>> On Thu, Jul 16, 2015 at 10:51 AM, Imesh Gunaratne < >>>>>>>>>>>>> im...@apache.org> wrote: >>>>>>>>>>>>> >>>>>>>>>>>>>> >>>>>>>>>>>>>> On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu < >>>>>>>>>>>>>> r...@wso2.com> wrote: >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 1.getAverageClusterMemoryByClusterId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /cluster/averageMemory/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 2.getAverageClusterLoadByClusterId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /cluster/averageLoad/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 3.getAverageMemberMemoryByMemberId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /member/averageMemory/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> 4.getAverageMemberLoadByMemberId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /member/averageLoad/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 5.getAverageClusterFlightRequestCountByClusterId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /cluster/flightRequestCount/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>> >>>>>>>>>>>>>> +1 A great thought! @Ashan: It would be better if you can >>>>>>>>>>>>>> document the API methods (may be in a Google doc). >>>>>>>>>>>>>> >>>>>>>>>>>>>> Thanks >>>>>>>>>>>>>> >>>>>>>>>>>>>> On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu < >>>>>>>>>>>>>> r...@wso2.com> wrote: >>>>>>>>>>>>>> >>>>>>>>>>>>>>> Hi Ashan, >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> Wouldn't it be better to stick with the REST API paths >>>>>>>>>>>>>>> currently used by stratos? You can inherit and add more stuffs >>>>>>>>>>>>>>> as you want. >>>>>>>>>>>>>>> Please see below for some sample paths: >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> On Tue, Jul 14, 2015 at 1:55 AM, Ashan Dhananjaya < >>>>>>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> Hi All, >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> I have implemented the REST api methods for the health >>>>>>>>>>>>>>>> statistics UI in the stratos existing REST API. >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 1.getAverageClusterMemoryByClusterId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /cluster/averageMemory/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 2.getAverageClusterLoadByClusterId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /cluster/averageLoad/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 3.getAverageMemberMemoryByMemberId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /member/averageMemory/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> 4.getAverageMemberLoadByMemberId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /member/averageLoad/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> 5.getAverageClusterFlightRequestCountByClusterId >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> /cluster/flightRequestCount/{Id}/{Interval}} >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> Thanks, >>>>>>>>>>>>>>> Reka >>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> Please find the Github commit here[1]. >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> [1]= >>>>>>>>>>>>>>>> https://github.com/apache/stratos/commit/5ab9159744f136e649174f7293adabe5c77fb4bd >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> Thank You! >>>>>>>>>>>>>>>> Best Regards, >>>>>>>>>>>>>>>> Ashan >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> On Thu, Jul 9, 2015 at 8:30 PM, Ashan Dhananjaya < >>>>>>>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>> Noted Lahiru. >>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>> On Thu, Jul 9, 2015 at 7:48 PM, Lahiru Sandaruwan < >>>>>>>>>>>>>>>>> lahi...@wso2.com> wrote: >>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> Hi Ashan, >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> Good stuff. It is fine to set the time stamp from CEP for >>>>>>>>>>>>>>>>>> now. But ultimately we need the timestamp to be sent from >>>>>>>>>>>>>>>>>> Python cartridge >>>>>>>>>>>>>>>>>> agent. Let's fix that part we proceed. >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> Thanks. >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> On Thu, Jul 9, 2015 at 7:38 PM, Ashan Dhananjaya < >>>>>>>>>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>> Hi All, >>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>> I was able to get the TimeaStamp to the RDBMS without >>>>>>>>>>>>>>>>>>> any conflict AFAIK. I am testing the flow more. Please find >>>>>>>>>>>>>>>>>>> the commits >>>>>>>>>>>>>>>>>>> [1], [2] for the Formatters. >>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>> [1]= >>>>>>>>>>>>>>>>>>> https://github.com/ashandk/stratos/commit/efa25eb255cadbf2843e5f0d0e13b34c09535f91 >>>>>>>>>>>>>>>>>>> [2]= >>>>>>>>>>>>>>>>>>> https://github.com/ashandk/stratos/commit/9c0fce9081c299c34031d602c94ea712602c7a6c >>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>> Thank You! >>>>>>>>>>>>>>>>>>> Best Regards, >>>>>>>>>>>>>>>>>>> Ashan >>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>> On Thu, Jul 9, 2015 at 2:41 PM, Lahiru Sandaruwan < >>>>>>>>>>>>>>>>>>> lahi...@wso2.com> wrote: >>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> Great work Ashan. >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> On Thu, Jul 9, 2015 at 2:39 PM, Ashan Dhananjaya < >>>>>>>>>>>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> Hi All, >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> I was able to take the timestamp from the cartridge >>>>>>>>>>>>>>>>>>>>> agent (WSO2CEPHealthStatisticsPublisher and >>>>>>>>>>>>>>>>>>>>> WSO2CEPInFlightRequestPublisher) to CEP PayLoad >>>>>>>>>>>>>>>>>>>>> definition.Git Hub commits >>>>>>>>>>>>>>>>>>>>> can be found here[1], [2]. Currently working on sending >>>>>>>>>>>>>>>>>>>>> the timestamp to >>>>>>>>>>>>>>>>>>>>> the RDBMS without conflicting execution plans. >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> I have included the read-me [2] file to the cep >>>>>>>>>>>>>>>>>>>>> extensions how to configure should happen for the Health >>>>>>>>>>>>>>>>>>>>> Stat publishing to >>>>>>>>>>>>>>>>>>>>> the RDBMS. >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> [1]= >>>>>>>>>>>>>>>>>>>>> https://github.com/apache/stratos/commit/4c65e705be822fd420b4e48ebafef789c8686b76 >>>>>>>>>>>>>>>>>>>>> [2]= >>>>>>>>>>>>>>>>>>>>> https://github.com/apache/stratos/commit/e09334cd98f245a4633c992f02db2878ac24d3d0 >>>>>>>>>>>>>>>>>>>>> [3]= >>>>>>>>>>>>>>>>>>>>> https://github.com/apache/stratos/commit/5ca895ef030f6aaeba56183d982aa5ae95db9337 >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> Thank You! >>>>>>>>>>>>>>>>>>>>> Best Regards, >>>>>>>>>>>>>>>>>>>>> Ashan >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> On Tue, Jul 7, 2015 at 1:13 PM, Lasantha Fernando < >>>>>>>>>>>>>>>>>>>>> lasantha....@gmail.com> wrote: >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>>> Hi Ashan, >>>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>>> Currently, you would not be able to get the timestamp >>>>>>>>>>>>>>>>>>>>>> out of the event >>>>>>>>>>>>>>>>>>>>>> unless you use a databridge agent callback. In that >>>>>>>>>>>>>>>>>>>>>> case, you can use >>>>>>>>>>>>>>>>>>>>>> Java code to simply get by calling >>>>>>>>>>>>>>>>>>>>>> event.getTimestamp(). >>>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>>> However, if you want to use the timestamp as an >>>>>>>>>>>>>>>>>>>>>> attribute while doing >>>>>>>>>>>>>>>>>>>>>> processing within CEP, you would have to pass the >>>>>>>>>>>>>>>>>>>>>> timestamp as an >>>>>>>>>>>>>>>>>>>>>> attribute of the stream. i.e. add it as an attribute >>>>>>>>>>>>>>>>>>>>>> of either meta, >>>>>>>>>>>>>>>>>>>>>> correlation or payload data. Then you can use that >>>>>>>>>>>>>>>>>>>>>> timestamp and >>>>>>>>>>>>>>>>>>>>>> format the output event as necessary. >>>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>>> Thanks, >>>>>>>>>>>>>>>>>>>>>> Lasantha >>>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>>> On Tue, Jul 7, 2015 at 1:04 PM, Ashan Dhananjaya < >>>>>>>>>>>>>>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>>>>>>>>>>>>>> > Hi All, >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> > I applied the above patch and get the timestamp in >>>>>>>>>>>>>>>>>>>>>> the Input Adapter. The >>>>>>>>>>>>>>>>>>>>>> > formatter i used was >>>>>>>>>>>>>>>>>>>>>> "member_average_memory_consumption_stats:1.0.0". I >>>>>>>>>>>>>>>>>>>>>> > tried several time to get the timeStamp attribute >>>>>>>>>>>>>>>>>>>>>> but failed. Is there any >>>>>>>>>>>>>>>>>>>>>> > way to get a data which is outside in the payload? >>>>>>>>>>>>>>>>>>>>>> The Input stream is as >>>>>>>>>>>>>>>>>>>>>> > below, >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> > 10:40:27,757 [-] [DataBridge-Core-pool-2-thread-1] >>>>>>>>>>>>>>>>>>>>>> INFO TenantId=-1234 : >>>>>>>>>>>>>>>>>>>>>> > Input Event Adaptor : DefaultWSO2EventInputAdaptor, >>>>>>>>>>>>>>>>>>>>>> received >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> > Event{ >>>>>>>>>>>>>>>>>>>>>> > streamId='cartridge_agent_health_stats:1.0.0', >>>>>>>>>>>>>>>>>>>>>> > timeStamp=1436245827731, >>>>>>>>>>>>>>>>>>>>>> > metaData=null, >>>>>>>>>>>>>>>>>>>>>> > correlationData=null, >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> payloadData=[single-cartridge-app.my-php.php.domain, >>>>>>>>>>>>>>>>>>>>>> > single-cartridge-app-1, network-partition-1, >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> single-cartridge-app.my-php.php.domaina5598e2b-995f-4620-b652-e66341e24c99, >>>>>>>>>>>>>>>>>>>>>> > partition-1, memory_consumption, 20.0], >>>>>>>>>>>>>>>>>>>>>> > arbitraryDataMap={}, >>>>>>>>>>>>>>>>>>>>>> > } >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> > Any help will be really appreciated. >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> > Thank You! >>>>>>>>>>>>>>>>>>>>>> > Best Regards, >>>>>>>>>>>>>>>>>>>>>> > Ashan >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> > On Tue, Jul 7, 2015 at 9:32 AM, Chamila De Alwis < >>>>>>>>>>>>>>>>>>>>>> chami...@wso2.com> wrote: >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> Hi Ashan, >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> As I've seen from the PCA testing recently, the >>>>>>>>>>>>>>>>>>>>>> timestamp is added to >>>>>>>>>>>>>>>>>>>>>> >> every ThriftEvent before publishing. Are you >>>>>>>>>>>>>>>>>>>>>> working on PCA or the Mock >>>>>>>>>>>>>>>>>>>>>> >> IaaS? I took a look at the Mock IaaS and the >>>>>>>>>>>>>>>>>>>>>> WSO2CEPStatisticsPublisher as >>>>>>>>>>>>>>>>>>>>>> >> well, and found out that the latter indeed doesn't >>>>>>>>>>>>>>>>>>>>>> add the timestamp to the >>>>>>>>>>>>>>>>>>>>>> >> ThriftEvents. This means that the JCA also >>>>>>>>>>>>>>>>>>>>>> publishes Thrift Events with >>>>>>>>>>>>>>>>>>>>>> >> empty timestamp fields. >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> Following is the simple fix for that. I've >>>>>>>>>>>>>>>>>>>>>> attached the patch herewith. >>>>>>>>>>>>>>>>>>>>>> >> Could you quickly verify with the patch applied >>>>>>>>>>>>>>>>>>>>>> build also? >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> chamilad@chamilad-ThinkPad-T530:~/dev/stratos[master >>>>>>>>>>>>>>>>>>>>>> *]$ git diff >>>>>>>>>>>>>>>>>>>>>> >> diff --git >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java >>>>>>>>>>>>>>>>>>>>>> >> b/c >>>>>>>>>>>>>>>>>>>>>> >> index 653288d..f1fe426 100644 >>>>>>>>>>>>>>>>>>>>>> >> --- >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java >>>>>>>>>>>>>>>>>>>>>> >> +++ >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java >>>>>>>>>>>>>>>>>>>>>> >> @@ -29,6 +29,7 @@ import >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> org.wso2.carbon.databridge.agent.thrift.exception.AgentException; >>>>>>>>>>>>>>>>>>>>>> >> import org.wso2.carbon.databridge.commons.Event; >>>>>>>>>>>>>>>>>>>>>> >> import >>>>>>>>>>>>>>>>>>>>>> org.wso2.carbon.databridge.commons.StreamDefinition; >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> +import java.util.Date; >>>>>>>>>>>>>>>>>>>>>> >> import java.util.HashMap; >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> /** >>>>>>>>>>>>>>>>>>>>>> >> @@ -98,6 +99,7 @@ public class >>>>>>>>>>>>>>>>>>>>>> WSO2CEPStatisticsPublisher implements >>>>>>>>>>>>>>>>>>>>>> >> StatisticsPublisher { >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> Event event = new Event(); >>>>>>>>>>>>>>>>>>>>>> >> event.setPayloadData(payload); >>>>>>>>>>>>>>>>>>>>>> >> + event.setTimeStamp(new Date().getTime()); >>>>>>>>>>>>>>>>>>>>>> >> event.setArbitraryDataMap(new >>>>>>>>>>>>>>>>>>>>>> HashMap<String, String>()); >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> try { >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> Regards, >>>>>>>>>>>>>>>>>>>>>> >> Chamila de Alwis >>>>>>>>>>>>>>>>>>>>>> >> Committer and PMC Member - Apache Stratos >>>>>>>>>>>>>>>>>>>>>> >> Software Engineer | WSO2 | +94772207163 >>>>>>>>>>>>>>>>>>>>>> >> Blog: code.chamiladealwis.com >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> >> >>>>>>>>>>>>>>>>>>>>>> > >>>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> -- >>>>>>>>>>>>>>>>>>>> -- >>>>>>>>>>>>>>>>>>>> Lahiru Sandaruwan >>>>>>>>>>>>>>>>>>>> Committer and PMC member, Apache Stratos, >>>>>>>>>>>>>>>>>>>> Senior Software Engineer, >>>>>>>>>>>>>>>>>>>> WSO2 Inc., http://wso2.com >>>>>>>>>>>>>>>>>>>> lean.enterprise.middleware >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> phone: +94773325954 >>>>>>>>>>>>>>>>>>>> email: lahi...@wso2.com blog: >>>>>>>>>>>>>>>>>>>> http://lahiruwrites.blogspot.com/ >>>>>>>>>>>>>>>>>>>> linked-in: >>>>>>>>>>>>>>>>>>>> http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146 >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> _______________________________________________ >>>>>>>>>>>>>>>>>>>> Dev mailing list >>>>>>>>>>>>>>>>>>>> d...@wso2.org >>>>>>>>>>>>>>>>>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> -- >>>>>>>>>>>>>>>>>> -- >>>>>>>>>>>>>>>>>> Lahiru Sandaruwan >>>>>>>>>>>>>>>>>> Committer and PMC member, Apache Stratos, >>>>>>>>>>>>>>>>>> Senior Software Engineer, >>>>>>>>>>>>>>>>>> WSO2 Inc., http://wso2.com >>>>>>>>>>>>>>>>>> lean.enterprise.middleware >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> phone: +94773325954 >>>>>>>>>>>>>>>>>> email: lahi...@wso2.com blog: >>>>>>>>>>>>>>>>>> http://lahiruwrites.blogspot.com/ >>>>>>>>>>>>>>>>>> linked-in: >>>>>>>>>>>>>>>>>> http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146 >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>>> >>>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> -- >>>>>>>>>>>>>>> Reka Thirunavukkarasu >>>>>>>>>>>>>>> Senior Software Engineer, >>>>>>>>>>>>>>> WSO2, Inc.:http://wso2.com, >>>>>>>>>>>>>>> Mobile: +94776442007 >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>> >>>>>>>>>>>>>> >>>>>>>>>>>>>> -- >>>>>>>>>>>>>> Imesh Gunaratne >>>>>>>>>>>>>> >>>>>>>>>>>>>> Senior Technical Lead, WSO2 >>>>>>>>>>>>>> Committer & PMC Member, Apache Stratos >>>>>>>>>>>>>> >>>>>>>>>>>>> >>>>>>>>>>>>> >>>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> -- >>>>>>>>>>> Imesh Gunaratne >>>>>>>>>>> >>>>>>>>>>> Senior Technical Lead, WSO2 >>>>>>>>>>> Committer & PMC Member, Apache Stratos >>>>>>>>>>> >>>>>>>>>> >>>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> -- >>>>>>>>> Imesh Gunaratne >>>>>>>>> >>>>>>>>> Senior Technical Lead, WSO2 >>>>>>>>> Committer & PMC Member, Apache Stratos >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>> >>>>>> >>>>> >>>>> >>>>> -- >>>>> Imesh Gunaratne >>>>> >>>>> Senior Technical Lead, WSO2 >>>>> Committer & PMC Member, Apache Stratos >>>>> >>>> >>>> >>> >>> >>> -- >>> Imesh Gunaratne >>> >>> Senior Technical Lead, WSO2 >>> Committer & PMC Member, Apache Stratos >>> >> >> >
