Examples of AddObserver()

Examples of com.caucho.config.event.EventManager.addObserver()

261
262
263
264
265
266
267
268
269
270
271
          throw new ConfigException(L.l("{0}.{1} is an invalid @Observes method because @Observes must be in the @Local API.",
                                        beanMethod.getDeclaringType().getJavaClass().getSimpleName(),
                                        beanMethod.getJavaMember().getName()));
        }
         
        eventManager.addObserver(this, apiMethod);
      }
    }
  }
 
  @Override
View Full Code Here

Examples of com.couchbase.client.CouchbaseConnection.addObserver()

238
239
240
241
242
243
244
245
246
247
248
    String appliedConfig = connection.replaceConfigWildcards(
      configs.get(0));
    Bucket config = configurationParser.parseBucket(appliedConfig);
    setConfig(config);
    connection.addObserver(new ConnectionObserver() {
      @Override
      public void connectionEstablished(SocketAddress sa, int reconnectCount) {
        getLogger().debug("Carrier Config Connection established to " + sa);
      }
View Full Code Here

Examples of com.google.appengine.demos.sticky.client.model.Surface.addObserver()

441
442
443
444
445
446
447
448
449
450
451
    add(controller.getButton());

    editController = new EditController(model, images, "header-author-edit");

    final Surface surface = model.getSelectedSurface();
    surface.addObserver(this);
    attachTitleView(images, surface);

    add(new LoginInfoView(model.getCurrentAuthor(), model.getLogoutUrl()));
    model.addDataObserver(this);
  }
View Full Code Here

Examples of com.neophob.sematrix.core.glue.Collector.addObserver()

807
808
809
810
811
812
813
814
815
816
817
        selectedVisualList.activate(0);
        selectedOutputs.activate(0);
       
        //register callback function
    GuiUpdateFeedback guf = new GuiUpdateFeedback(this);
    col.addObserver(guf);
    col.notifyGuiUpdate();
   
        initialized = true;
    }
View Full Code Here

Examples of com.nilhcem.fakesmtp.server.MailSaver.addObserver()

116
117
118
119
120
121
122
123
124
125
126
    // Once we chose a directory
    dirChooser.addObserver(saveMsgTextField);

    // When a message is received
    MailSaver mailSaver = SMTPServerHandler.INSTANCE.getMailSaver();
    mailSaver.addObserver(nbReceivedLabel);
    mailSaver.addObserver(mailsListPane);
    mailSaver.addObserver(lastMailPane);
    mailSaver.addObserver(clearAll);

    // When we click on "clear all"
View Full Code Here

Examples of com.sun.corba.ee.spi.folb.GroupInfoService.addObserver()

280
281
282
283
284
285
286
287
288
289
290
                                ex);
                    }

                    giso = new GroupInfoServiceObserverImpl( gis, rrPolicy );

                    gis.addObserver(giso);

                    // fineLog( "getInitialContext: rrPolicy = {0}", rrPolicy );

                    // this should force the initialization of the resources providers
                    if (habitat!=null) {
View Full Code Here

Examples of com.sun.jini.system.FileWalker.addObserver()

111
112
113
114
115
116
117
118
119
120
121
            print("treewalker.not.directory",startDir);
            System.exit(0);
        }
        FileWalker fileWalker = new FileWalker();
        FileObserver fileObserver = new FileObserver(suffix);
        fileWalker.addObserver(fileObserver);
        fileWalker.walk(startFD,recurse);
        return fileObserver.getFileList();
    }//end getFilesList

    /** Converts the elements of the given ArrayList from directory format
View Full Code Here

Examples of com.webobjects.foundation.NSNotificationCenter.addObserver()

39
40
41
42
43
44
45
46
47
48
49
    _registerForAdaptorContextNotifications();
  }

  public void _registerForAdaptorContextNotifications() {
    NSNotificationCenter notificationCenter = NSNotificationCenter.defaultCenter();
    notificationCenter.addObserver(this, ERXForwardingAdaptorContext._beginTransactionSelector, EOAdaptorContext.AdaptorContextBeginTransactionNotification, _forwardedContext);
    notificationCenter.addObserver(this, ERXForwardingAdaptorContext._commitTransactionSelector, EOAdaptorContext.AdaptorContextCommitTransactionNotification, _forwardedContext);
    notificationCenter.addObserver(this, ERXForwardingAdaptorContext._rollbackTransactionSelector, EOAdaptorContext.AdaptorContextRollbackTransactionNotification, _forwardedContext);
  }

  public void _unregisterForAdaptorContextNotifications() {
View Full Code Here

Examples of cu.repsystestbed.graphs.FeedbackHistoryGraph.addObserver()

108
109
110
111
112
113
114
115
116
117
118
    EigenTrust repAlg = (EigenTrust) ReputationAlgorithm.getInstance("cu.repsystestbed.algorithms.examples.EigenTrust");
    repAlg.setGraph2Listen(feedbackHistoryGraph);
    repAlg.setGraph2Output(repGraph);
   
    //add eigentrust as an observer to the feedback history graph
    feedbackHistoryGraph.addObserver(repAlg);
   
    //rank based trust alg needs to use the reputation graph
    RankbasedTrustAlg trustAlg = (RankbasedTrustAlg) TrustAlgorithm.getInstance("cu.repsystestbed.algorithms.examples.RankbasedTrustAlg");
    trustAlg.setRatio(0.7);
    //must be called in this sequence otherwise setReputationGraph() will create a new trust graph
View Full Code Here

Examples of cu.repsystestbed.graphs.ReputationGraph.addObserver()

119
120
121
122
123
124
125
126
127
128
129
    trustAlg.setGraph2Output(trustGraph);
    trustAlg.setGraph2Listen(repGraph);

   
    //add rank based trust alg as an observer to the reputation graph
    repGraph.addObserver(trustAlg);
   
    //parse the feedbacks from the arff file
    DefaultArffFeedbackGenerator feedbackGen = new DefaultArffFeedbackGenerator();
    ArrayList<Feedback> feedbacks = (ArrayList<Feedback>) feedbackGen.generateHardcoded("feedbacks.arff");
   
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.