Great!!, this is exactly what you want to do. We will lie, the documentation will lie but the code cannot not lie, so thats your reliable friend always :)
Suresh On May 29, 2012, at 2:58 PM, Hasitha Aravinda 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
signature.asc
Description: Message signed with OpenPGP using GPGMail
