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 Thu, 06 Aug 2015 06:30:03 GMT
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 <dhananjaya92@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 <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