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