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 >
