Sounds good ! Lahiru
On Tue, May 29, 2012 at 2:58 PM, Hasitha Aravinda <[email protected]>wrote: > Hi all, > > I looked at test case SimpleWorkflowExecution [1] and it answered my > all questions. We can subscribed to all notification by setting ">" to > topicExpression ( see testSimpleTest() in [1] ). Thank you all for > your comments and guidance. > > Thank you, > Hasitha > > [1] - > https://svn.apache.org/repos/asf/incubator/airavata/trunk/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleWorkflowExecution.java > > > > On Tue, May 29, 2012 at 7:27 PM, Hasitha Aravinda > <[email protected]> wrote: > > Hi all, > > > > Thank you Suresh. I'll check workflow-monitoring-util project. But it > > will take some time to understand its basic. So I started with topic > > Based Subscription Sample [1] and have a question. > > > > What are operations I should implement when writing a axis2 > ConsumerService ? > > Is there any sample axis2 ConsumerService implementation ? > > > > Thank you, > > Hasitha. > > > > [1] - > https://svn.apache.org/repos/asf/incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-topic-subscription/ > > > > > > > > On Tue, May 29, 2012 at 4:19 AM, Suresh Marru <[email protected]> wrote: > >> > >> On May 26, 2012, at 10:16 PM, Saminda Wijeratne wrote: > >> > >>> You are correct. You can use the WSMessager service to do the job. > XBaya > >>> wraps this service and is exposed as a Monitor API through the > >>> AiravataClient. > >>> > >>> If you know the topic id of a running workflow use the function, > >>> > airavataClient.getWorkflowExecutionMonitor(topicid,monitorEventListener) > >>> which will do the subscribing for you. > >>> > >>> From the time you call this function, all the messages received for > that > >>> running workflow will be passed to the monitorEventListener object > (where > >>> you can do whatever you want with it). > >>> > >>> Unfortunately you cannot subscribe to all workflow notifications using > a > >>> single call.. you have to subscribe to each of them separately using > the > >>> above function... in order to retrieve all existing topic ids use the > >>> function > >>> airavataClient.getRegistry().getWorkflowExecutionIdByUser(user); > >> > >> Actually you can subscribe to all notifications. > >> > >> Hasitha, > >> > >> Please refer to the sandbox project - [1] which should answer all your > questions. Note that the code is based on legacy version (XSUL SOAP Engine) > of WS Messenger service and needs to be updated to Axis 2 based Messenger > service. I recently created a JIRA for this task [2]. For your next > question on topic Based Subscription you can also refer to the samples in > WS Messenger - [3] - > https://svn.apache.org/repos/asf/incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-topic-subscription/. > Ideally we should expose this from Airavata Client API as well, feel free > to create a JIRA when you see these kind of missing features. And ofcourse > you are more then welcome to submit patches for the JIRA's you create :). > >> > >> Cheers, > >> Suresh > >> > >> [1] - > https://svn.apache.org/repos/asf/incubator/airavata/sandbox/workflow-monitoring-util/ > >> [2] - https://issues.apache.org/jira/browse/AIRAVATA-419 > >> [3] - > https://svn.apache.org/repos/asf/incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-topic-subscription/ > >> > >>> Note that here parameter "user" corresponds to the user who executed > the > >>> workflow... passing null to it should return all topicid regardless the > >>> user who executed it. > >>> > >>> Please feel free to ask for more clarifications. > >>> > >>> Regards, > >>> Saminda > >>> On Sat, May 26, 2012 at 10:18 AM, Hasitha Aravinda < > [email protected] > >>>> wrote: > >>> > >>>> Hi devs, > >>>> > >>>> Currently we are working on implementing Metadata Catalog for Apache > >>>> Airavata. We stared developing a dummy workflow notification generator > >>>> to test our tool, but found that it is not suitable for testing. So > >>>> now we are thinking to get workflow notification from a Airavata > >>>> server. > >>>> > >>>> Our Requirement is to subscribe to all workflow notifications to have > >>>> them in our Metadata Catalog. I went through Airavata documentations > >>>> and found that this can be done using Ws-messanger component, but > >>>> don't have clear idea to how to do this. > >>>> > >>>> Any thoughts ? > >>>> > >>>> Thank you, > >>>> Hasitha. > >>>> > >> > > > > -- > -- > Hasitha Aravinda, > > | hasitha.aravinda > -- System Analyst Programmer PTI Lab Indiana University
