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 > > > > > > >
