airavata-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Danushka Menikkumbura <danushka.menikkumb...@gmail.com>
Subject Re: Airavata + AMQP in Action
Date Wed, 26 Jun 2013 20:49:21 GMT
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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message