airavata-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Suresh Marru <sma...@apache.org>
Subject Re: Airavata + AMQP in Action
Date Thu, 27 Jun 2013 11:54:16 GMT
Hi Danushka,

Can you please create a WIKI page and attach the figures and any descriptions. This is exciting
to hear.

Suresh
 
On Jun 26, 2013, at 4:49 PM, Danushka Menikkumbura <danushka.menikkumbura@gmail.com>
wrote:

> Hi Amila,
> 
> Oops!. I thought it was possible to send attachments. Maybe the size is
> limited.
> 
> Anyway the output is as follows.
> 
> <java-client>
> 
> E:\MSc\Research\RabbitMQ\rabbitmq-java-client-bin-3.1.2>java -cp
> .;commons-io-1.2.jar;commons-cli-1.1.jar;rabbitmq-client.jar ReceiveEvents
> [*] Waiting for messages. To exit press CTRL+C
> 
> [x] Received '<ns:workflowInvoked infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25
> 890f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:07.511+05:30</ns:timestamp><ns:description>echo=Airavata
> + AMQP</ns:description><ns:annota
> tion/><ns:initiator
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"/></ns:workflowInvoked>'
> 
> [x] Received '<ns:invokingService infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25
> 890f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:09.181+05:30</ns:timestamp><ns:description>echo=Airavata
> + AMQP</ns:description><ns:annota
> tion/><ns:request><ns:body><n1:greet xmlns:n1="
> http://samples.airavata.apache.org"><n1:echo>Airavata +
> AMQP</n1:echo></n1:greet></ns:body></ns:request><ns:receiver
> ns:serviceID="SimpleMathServicePortT
> ype_greet"
> ns:workflowID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"
> ns:workflowTimestep="0"
> ns:workflowNodeID="SimpleMathServicePortType_greet"/></ns:invokingService>'
> 
> [x] Received '<ns:receivedResult infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc258
> 90f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:09.853+05:30</ns:timestamp><ns:description>return=Hello
> World Airavata + AMQP !</ns:descrip
> tion><ns:annotation/><ns:result><ns:body><ns:greetResponse xmlns:ns="
> http://samples.airavata.apache.org"><ns:return>Hello World Airavata + AMQP
> !</ns:return></ns:greetResponse></ns:body></ns:result><n
> s:responder ns:serviceID="SimpleMathServicePortType_greet"
> ns:workflowID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"
> ns:workflowTimestep="0" ns:workflowNodeID="SimpleMathServicePortType_gre
> et"/></ns:receivedResult>'
> 
> [x] Received '<ns:sendingResult infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc2589
> 0f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:13.056+05:30</ns:timestamp><ns:description/><ns:annotation/><ns:receiver
> ns:serviceID="FiveM
> inWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"/></ns:sendingResult>'
> 
> [x] Received '<ns:workflowTerminated infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298b
> c25890f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:13.919+05:30</ns:timestamp><ns:description>Workflow
> finished successfully.</ns:descript
> ion><ns:annotation/></ns:workflowTerminated>'
> 
> [x] Received '<ns:sendingResult infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc2589
> 0f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:13.946+05:30</ns:timestamp><ns:description/><ns:annotation/><ns:receiver
> ns:serviceID="FiveM
> inWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"/></ns:sendingResult>'
> 
> </java-client>
> 
> <python-client>
> 
> E:\MSc\Research\Pika\pika-0.9.13>python receive_events.py
> [*] Waiting for messages. To exit press CTRL+C
> 
> [x] '<ns:workflowInvoked infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0" ns
> :experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:07.511+05:30</ns:timestamp><ns:description>echo=Airavata
> + AMQP</ns:description><ns:annotation/><ns
> :initiator
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"/></ns:workflowInvoked>'
> 
> [x] '<ns:invokingService infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0" ns
> :experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:09.181+05:30</ns:timestamp><ns:description>echo=Airavata
> + AMQP</ns:description><ns:annotation/><ns
> :request><ns:body><n1:greet
> xmlns:n1="http://samples.airavata.apache.org"><n1:echo>Airavata
> + AMQP</n1:echo></n1:greet></ns:body></ns:request><ns:receiver
> ns:serviceID="SimpleMathServicePortType_greet
> " ns:workflowID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"
> ns:workflowTimestep="0"
> ns:workflowNodeID="SimpleMathServicePortType_greet"/></ns:invokingService>'
> 
> [x] '<ns:receivedResult infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0" ns:
> experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:09.853+05:30</ns:timestamp><ns:description>return=Hello
> World Airavata + AMQP !</ns:description><ns:
> annotation/><ns:result><ns:body><ns:greetResponse xmlns:ns="
> http://samples.airavata.apache.org"><ns:return>Hello World Airavata + AMQP
> !</ns:return></ns:greetResponse></ns:body></ns:result><ns:respond
> er ns:serviceID="SimpleMathServicePortType_greet"
> ns:workflowID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"
> ns:workflowTimestep="0"
> ns:workflowNodeID="SimpleMathServicePortType_greet"/></ns
> :receivedResult>'
> 
> [x] '<ns:sendingResult infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0" ns:e
> xperimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:13.056+05:30</ns:timestamp><ns:description/><ns:annotation/><ns:receiver
> ns:serviceID="FiveMinWorkflo
> w_eb6efe00_ee18_4f32_b589_298bc25890f0"/></ns:sendingResult>'
> 
> [x] '<ns:workflowTerminated infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0"
> ns:experimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:13.919+05:30</ns:timestamp><ns:description>Workflow
> finished successfully.</ns:description><ns:a
> nnotation/></ns:workflowTerminated>'
> 
> [x] '<ns:sendingResult infoModelVersion="2.6" xmlns:ns="
> http://airavata.apache.org/schemas/wft/2011/08"><ns:notificationSource
> ns:serviceID="FiveMinWorkflow_eb6efe00_ee18_4f32_b589_298bc25890f0" ns:e
> xperimentID="FiveMinWorkflow_eb6efe00-ee18-4f32-b589-298bc25890f0"/><ns:timestamp>2013-06-27T01:35:13.946+05:30</ns:timestamp><ns:description/><ns:annotation/><ns:receiver
> ns:serviceID="FiveMinWorkflo
> w_eb6efe00_ee18_4f32_b589_298bc25890f0"/></ns:sendingResult>'
> 
> </python-client>
> 
> Cheers,
> Danushka
> 
> 
> 
> On Thu, Jun 27, 2013 at 1:57 AM, Amila Jayasekara
> <thejaka.amila@gmail.com>wrote:
> 
>> Hi Danushka,
>> 
>> Seems like attachments are dropped from the mailing list.
>> 
>> Thanks
>> Amila
>> 
>> 
>> On Wed, Jun 26, 2013 at 4:20 PM, Danushka Menikkumbura <
>> danushka.menikkumbura@gmail.com> wrote:
>> 
>>> Hi,
>>> 
>>> We can now receive Airavata events/notifications using AMQP.
>>> 
>>> Please find the attached images. java_client.png and python_client.png
>>> that show the notifications received by a java client and by a python
>>> client respectively for our 5-min tutorial example. These 6 notifications
>>> are exactly what we see in XBaya when the workflow is invoked.
>>> 
>>> Not very sexy and at a fairly high level. Need more work but required
>>> elements are now in place.
>>> 
>>> Cheers,
>>> Danushka
>>> 
>>> 
>>> 
>> 


Mime
View raw message