My guess is that your client side application (the main thread) terminates before the listener gets any messages from the server. Thus you don't see any output.
On Fri, Nov 15, 2013 at 7:59 PM, Nipuni Piyabasi Perera < [email protected]> wrote: > Hi, > > Yes it is working after calling > > airavataAPI.getExecutionManager().waitForExperimentTermination(...) > > > Thanks, > Nipuni > > > > > On Sat, Nov 16, 2013 at 3:54 AM, Saminda Wijeratne <[email protected]>wrote: > >> hmmm... >> >> Can you see the experiment getting executed at the backend server? >> >> Can you also please call the following after the "...startMonitoring()" >> >> airavataAPI.getExecutionManager().waitForExperimentTermination(...) >> >> >> >> >> >> On Thu, Nov 14, 2013 at 11:14 PM, Nipuni Piyabasi Perera < >> [email protected]> wrote: >> >>> Yes. I does call >>> >>> experimentMonitor.startMonitoring(); >>> >>> >>> >>> >>> Thanks, >>> >>> Nipuni >>> >>> >>> >>> >>> On Fri, Nov 15, 2013 at 9:37 AM, Saminda Wijeratne >>> <[email protected]>wrote: >>> >>>> Does your code call >>>> >>>> experimentMonitor.startMonitoring(); ??? >>>> >>>> EventDataRepository object (and EventData) is managed inside the >>>> monitor object returned by the >>>> airavataAPI.getExecutionManager().getExperimentMonitor(...) >>>> function. And the monitor object will call the notify method in the >>>> listener with those objects as parameters >>>> >>>> On Thu, Nov 14, 2013 at 11:02 PM, Nipuni Piyabasi Perera < >>>> [email protected]> wrote: >>>> >>>>> Hi, >>>>> >>>>> Inside MonitorListner class, how does it set up the >>>>> EventDataRepository and EventData parameters that are passed into notify() >>>>> mthod? >>>>> >>>>> Thanks, >>>>> Nipuni >>>>> >>>>> >>>>> >>>>> On Fri, Nov 15, 2013 at 8:51 AM, Nipuni Piyabasi Perera < >>>>> [email protected]> wrote: >>>>> >>>>>> Hi, >>>>>> >>>>>> Given workflow name and its inputs, I am receiving the experiment id >>>>>> with, >>>>>> >>>>>> String experimentId >>>>>> =airavataAPI.getExecutionManager().runExperiment(workflowId, >>>>>> workflowInputs); >>>>>> >>>>>> Then start monitoring here, >>>>>> >>>>>> MonitorListener monitorListener = new MonitorListener(); >>>>>> Monitor experimentMonitor = >>>>>> airavataAPI.getExecutionManager().getExperimentMonitor(experimentId, >>>>>> monitorListener); >>>>>> log.info("Started the Workflow monitor"); >>>>>> >>>>>> This code executes and prints the log message. But this does not >>>>>> print log messages inside notify() method in "MonitorListner" class >>>>>> >>>>>> public void notify(EventDataRepository eventDataRepo, EventData >>>>>> eventData) { >>>>>> log.info("ExperimentID: " + eventData.getExperimentID()); >>>>>> log.info("Message: " + eventData.getMessage()); >>>>>> } >>>>>> >>>>>> >>>>>> >>>>>> On Fri, Nov 15, 2013 at 8:25 AM, Saminda Wijeratne < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> hi Nipuni, >>>>>>> When the experiment starts the events are generated at the server >>>>>>> side regardless whether anyone starts monitoring or not. By >>>>>>> startMonitoring() at the client side it will subscribe to those >>>>>>> generated >>>>>>> events. Server will send the client a copy of those events. >>>>>>> >>>>>>> How are you passing your listener to the API? Can you illustrate >>>>>>> what you are doing in code? >>>>>>> >>>>>>> >>>>>>> On Thu, Nov 14, 2013 at 9:14 PM, Nipuni Piyabasi Perera < >>>>>>> [email protected]> wrote: >>>>>>> >>>>>>>> Hi, >>>>>>>> >>>>>>>> To monitor workflow execution, I have registered a listener with >>>>>>>> monitor as in the sample code here[1]. My Listener class [2] should >>>>>>>> call >>>>>>>> notify() method if there is any events generated while workflow >>>>>>>> execution. >>>>>>>> But it does not call notify method. After "startMonitoring()" is called >>>>>>>> does it automatically generate events?. >>>>>>>> >>>>>>>> I am using Airavata 0.7 release. >>>>>>>> >>>>>>>> [1] >>>>>>>> https://svn.apache.org/repos/asf/airavata/trunk/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorWorkflow.java >>>>>>>> >>>>>>>> >>>>>>>> [2] >>>>>>>> https://svn.apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorListener.java >>>>>>>> >>>>>>>> Thanks, >>>>>>>> Nipuni. >>>>>>>> >>>>>>>> >>>>>>>> On Wed, Aug 7, 2013 at 7:07 PM, Raminder Singh < >>>>>>>> [email protected]> wrote: >>>>>>>> >>>>>>>>> Thanks for your interest in Airavata. You need not to poll. You >>>>>>>>> can register a listener with your monitor to get constant updates. >>>>>>>>> Please >>>>>>>>> look into following class. >>>>>>>>> >>>>>>>>> >>>>>>>>> https://svn.apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorListener.java >>>>>>>>> >>>>>>>>> Thanks >>>>>>>>> Raminder >>>>>>>>> >>>>>>>>> On Aug 7, 2013, at 1:22 AM, Nipuni Piyabasi Perera < >>>>>>>>> [email protected]> wrote: >>>>>>>>> >>>>>>>>> >>>>>>>>> Hi, >>>>>>>>> >>>>>>>>> I am implementing Airavata client API and I need to monitor >>>>>>>>> running workflow status. I have noticed that a "Monitor" can be >>>>>>>>> accessed >>>>>>>>> via "ExecutionManager" [1], and it provides startMonitoring() and >>>>>>>>> stopMonitoring() methods. >>>>>>>>> I need to clarify whether it allows to display workflow status >>>>>>>>> continuously or does it need poll to view status. >>>>>>>>> >>>>>>>>> [1] >>>>>>>>> https://svn.apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorWorkflow.java >>>>>>>>> >>>>>>>>> Thanks, >>>>>>>>> Nipuni >>>>>>>>> -- >>>>>>>>> Nipuni Piyabasi Perera >>>>>>>>> Undergraduate >>>>>>>>> Department of Computer Science And Engineering >>>>>>>>> University of Moratuwa >>>>>>>>> Sri Lanka >>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> Nipuni Piyabasi Perera >>>>>>>> Undergraduate >>>>>>>> Department of Computer Science And Engineering >>>>>>>> University of Moratuwa >>>>>>>> Sri Lanka >>>>>>>> >>>>>>> >>>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Nipuni Piyabasi Perera >>>>>> Undergraduate >>>>>> Department of Computer Science And Engineering >>>>>> University of Moratuwa >>>>>> Sri Lanka >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> Nipuni Piyabasi Perera >>>>> Undergraduate >>>>> Department of Computer Science And Engineering >>>>> University of Moratuwa >>>>> Sri Lanka >>>>> >>>> >>>> >>> >>> >>> -- >>> Nipuni Piyabasi Perera >>> Undergraduate >>> Department of Computer Science And Engineering >>> University of Moratuwa >>> Sri Lanka >>> >> >> > > > -- > Nipuni Piyabasi Perera > Undergraduate > Department of Computer Science And Engineering > University of Moratuwa > Sri Lanka >
