airavata-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vijayendra Grampurohit <vijayendra....@gmail.com>
Subject Re: Airavata + AMQP in Action
Date Fri, 28 Jun 2013 06:16:55 GMT
Hi Danushka/All

> >  As we have
> > discussed thus far, the plan is to wrap Java API calls in the JS API.

Does this mean running a javascript library in java programs ?
If so can we use  Rhino. It is an open-source implementation of JavaScript
written entirely in Java. It is typically embedded into Java applications
to provide scripting to end users.

Regards
Vijayendra


On Thu, Jun 27, 2013 at 6:13 PM, Danushka Menikkumbura <
danushka.menikkumbura@gmail.com> wrote:

> 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 <smarru@apache.org> 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 <
> > 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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message