List of registerObserver() Examples

Examples of registerObserver()

org.apache.synapse.config.SynapseConfiguration.registerObserver()
org.jamesii.core.base.IEntity.registerObserver()
org.jamesii.core.model.AbstractState.registerObserver()
org.jamesii.core.services.management.ServiceManagement.registerObserver()
org.openbp.server.context.TokenContext.registerObserver()
Registers an observer. @param observer The observer; The observer's observeEvent method will receive events of the type{@link EngineEvent} or {@link EngineTraceEvent}. @param eventTypes Lit of event types the observer wants to be notified ofor null for all event types
org.w3c.util.ObservableProperties.registerObserver()
Subscribe for property monitoring. @param observer The object that handles the PropertyMonitoring interface.
org.wso2.carbon.mediation.statistics.MediationStatisticsStore.registerObserver()
Register a custom statistics consumer to receive updates from this statistics store @param o The MediationStatisticsObserver instance to be notified of data updates

Examples of org.apache.synapse.config.SynapseConfiguration.registerObserver()


    protected SynapseConfiguration createSynapseConfig() {
        SynapseConfiguration synapseConfig = new SynapseConfiguration();
        synapseConfig.setAxisConfiguration(new AxisConfiguration());
        DependencyTracker tracker = new DependencyTracker();
        synapseConfig.registerObserver(tracker);
        dependencyMgtSvc = new DependencyManagementServiceImpl(tracker);
        return synapseConfig;
    }


    protected void assertDependency(int type, String id, String dependentId) {

View Full Code Here

Examples of org.jamesii.core.base.IEntity.registerObserver()

  @SuppressWarnings("unchecked")
  // Has to be ensured by observer to use, otherwise exception should be thrown
  public void instrumentComputation(IComputationTask computation) {
    IEntity target = getObservationTarget(computation);
    Mediator.create(target);
    target.registerObserver(observerToUse);
    try {
      ((IObserver<IEntity>) observerToUse).update(target,
          new ProcessorObservationHint(this));
    } catch (ClassCastException ex) {
      throw new IllegalArgumentException(

View Full Code Here

Examples of org.jamesii.core.model.AbstractState.registerObserver()


    if (obs == null) {
      return;
    }


    mapState.registerObserver(obs);
    observers = new ArrayList<>();
    // observers.clear();
    observers.add(obs);
  }

View Full Code Here

Examples of org.jamesii.core.services.management.ServiceManagement.registerObserver()

    ServiceManagement newSM = new ServiceManagement();
    serviceTypes.put(serviceType, newSM);


    // enable forwarding of observer notifications from the management classes
    newSM.setMediator(managementMediator);
    newSM.registerObserver(managementObserver);


    // enable availability checking for the new service type, i.e., availability
    // is enabled per service type, and tus it could be configured per service
    // type (by exploiting the plug-in mechanism as well).
    serviceAvailability.put(serviceType, new Availability(newSM, null,

View Full Code Here

Examples of org.openbp.server.context.TokenContext.registerObserver()

  public void testStandardRollbackProcessor()
    throws Exception
  {
    // Create the process context and start the process
    TokenContext token = createToken();
    token.registerObserver(this, new String[] { EngineExceptionHandlerEvent.HANDLE_EXCEPTION });


    getProcessFacade().startToken(token, "/TestCase/RollbackLocalErrorHandlerTest.Start", null);


    Engine engine = this.getProcessServer().getEngine();
    engine.executeContext(token);

View Full Code Here

Examples of org.w3c.util.ObservableProperties.registerObserver()

  manager.timeout = props.getInteger(TIMEOUT_P, manager.timeout);
  // connection timeout
  manager.conn_timeout = props.getInteger(CONN_TIMEOUT_P, 
            manager.conn_timeout);
  // Register ourself as a property observer:
  props.registerObserver(manager);
  // Register that manager in our knwon managers:
  for (int i = 0 ; i < managers.length ; i++) {
      if ( managers[i] == null ) {
    managers[i] = new ManagerDescription(manager, p);
    return manager;

View Full Code Here

Examples of org.wso2.carbon.mediation.statistics.MediationStatisticsStore.registerObserver()




            MediationStatisticsStore mediationStatisticsStore = mediationStatisticsService.getStatisticsStore();
            //in any occurence if 'mediationStatisticsStore' is null, observre wont be registered
            BAMMediationStatisticsObserver observer = new BAMMediationStatisticsObserver();
            mediationStatisticsStore.registerObserver(observer);
            observer.setTenantId(mediationStatisticsService.getTenantId()); // 'MediationStat
            // service' will
            // be deployed
            // per tenant (cardinality="1..n")
            observer.setTenantAxisConfiguration(mediationStatisticsService.getConfigurationContext().

View Full Code Here

Examples of org.wso2.carbon.mediation.statistics.MediationStatisticsStore.registerObserver()

        }
        if (activated && mediationStatisticsService != null) {
            MediationStatisticsStore mediationStatisticsStore =
                    mediationStatisticsService.getStatisticsStore();
            BAMMediationStatisticsObserver observer = new BAMMediationStatisticsObserver();
            mediationStatisticsStore.registerObserver(observer);
            observer.setTenantId(mediationStatisticsService.getTenantId());
            observer.setTenantAxisConfiguration(
                    mediationStatisticsService.getConfigurationContext().getAxisConfiguration());
            log.info("Registering BamMediationStatistics Observer for tenant: " +
                     mediationStatisticsService.getTenantId());

View Full Code Here

TOP

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.