stratos-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ashan Dhananjaya <dhananjay...@gmail.com>
Subject Re: [Dev] [GSoC-2015] Showing health statistics in GUI
Date Tue, 04 Aug 2015 10:27:57 GMT
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 <imesh@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 <dhananjaya92@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 <imesh@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 <dhananjaya92@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 <
>>>> dhananjaya92@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 <
>>>>> dhananjaya92@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 <imesh@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 <
>>>>>>> dhananjaya92@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 <imesh@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 <
>>>>>>>>> dhananjaya92@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
<
>>>>>>>>>> dhananjaya92@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
<
>>>>>>>>>>> imesh@apache.org> wrote:
>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>> On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu
<
>>>>>>>>>>>> reka@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
<
>>>>>>>>>>>> reka@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 <
>>>>>>>>>>>>> dhananjaya92@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 <
>>>>>>>>>>>>>> dhananjaya92@gmail.com> wrote:
>>>>>>>>>>>>>>
>>>>>>>>>>>>>>> Noted Lahiru.
>>>>>>>>>>>>>>>
>>>>>>>>>>>>>>> On Thu, Jul 9, 2015 at 7:48 PM,
Lahiru Sandaruwan <
>>>>>>>>>>>>>>> lahirus@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 <
>>>>>>>>>>>>>>>> dhananjaya92@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 <
>>>>>>>>>>>>>>>>> lahirus@wso2.com>
wrote:
>>>>>>>>>>>>>>>>>
>>>>>>>>>>>>>>>>>> Great work Ashan.
>>>>>>>>>>>>>>>>>>
>>>>>>>>>>>>>>>>>> On Thu, Jul 9, 2015
at 2:39 PM, Ashan Dhananjaya <
>>>>>>>>>>>>>>>>>> dhananjaya92@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.fdo@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 <
>>>>>>>>>>>>>>>>>>>> dhananjaya92@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 <
>>>>>>>>>>>>>>>>>>>> chamilad@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: lahirus@wso2.com
blog:
>>>>>>>>>>>>>>>>>> http://lahiruwrites.blogspot.com/
>>>>>>>>>>>>>>>>>> linked-in:
>>>>>>>>>>>>>>>>>> http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146
>>>>>>>>>>>>>>>>>>
>>>>>>>>>>>>>>>>>>
>>>>>>>>>>>>>>>>>> _______________________________________________
>>>>>>>>>>>>>>>>>> Dev mailing list
>>>>>>>>>>>>>>>>>> Dev@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: lahirus@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
>

Mime
View raw message