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 <[email protected]> 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 > <[email protected]>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 < >> [email protected]> 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 >>> >>> >>> >>
