Hi Suresh, Maybe not as a reference as things will become richer as I keep adding things. I just wanted to spread the word when I saw it stared to work :-). I will anyway create a wiki and have the screenshots along with a brief description just to mark the inaugural event flow over AMQP :-).
Cheers, Danushka On Thu, Jun 27, 2013 at 5:24 PM, Suresh Marru <[email protected]> wrote: > 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 > >>> > >>> > >>> > >> > >
