List of addStateListener() Examples

Examples of addStateListener()

net.kano.joustsim.oscar.AimConnection.addStateListener()
net.rubyeye.xmemcached.MemcachedClientBuilder.addStateListener()
Add a state listener @param stateListener
net.rubyeye.xmemcached.XMemcachedClientBuilder.addStateListener()
org.apache.felix.dm.Component.addStateListener()
Adds a component state listener to this component. @param listener the state listener
org.rhq.enterprise.communications.command.client.ClientCommandSender.addStateListener()
Adds the given listener to this sender object. When the sender {@link #startSending() starts sending} or{@link #stopSending(boolean) stops sending}, this listener will be notified. If the listener already exists in the list of known listeners (i.e. it has been added before), a duplicate will not be added; however, if immediately_notify is true, it will be notified now. @param listener @param immediately_notify if true, the listener will be immediately notified of the current state ofthe sender; if false, the listener will next be notified when the state changes next
org.springframework.osgi.service.importer.support.internal.controller.ImporterInternalActions.addStateListener()

Examples of org.apache.felix.dm.Component.addStateListener()

            for (int i = 0; i < dependencies.size(); i++) {
                service.add(((Dependency) dependencies.get(i)).createCopy());
            }


            for (int i = 0; i < m_stateListeners.size(); i ++) {
                service.addStateListener((ComponentStateListener) m_stateListeners.get(i));
            }
            return service;
        }
    }
}

View Full Code Here

Examples of org.apache.felix.dm.Component.addStateListener()

            for (int i = 0; i < dependencies.size(); i++) {
                service.add(((Dependency) dependencies.get(i)).createCopy());
            }


            for (int i = 0; i < m_stateListeners.size(); i ++) {
                service.addStateListener((ComponentStateListener) m_stateListeners.get(i));
            }
            configureAutoConfigState(service, m_component);
            return service;
        }
    }

View Full Code Here

Examples of org.apache.felix.dm.Component.addStateListener()

            for (int i = 0; i < dependencies.size(); i++) {
                service.add(((Dependency) dependencies.get(i)).createCopy());
            }
            
            for (int i = 0; i < m_stateListeners.size(); i ++) {
                service.addStateListener((ComponentStateListener) m_stateListeners.get(i));
            }
            return service;
        }
        
        public String toString() {

View Full Code Here

Examples of org.apache.felix.dm.Component.addStateListener()

                        }
                        topicLatch.countDown();
                    }
                }
            });
        comp.addStateListener(new ComponentStateListener() {
            public void stopping(Component comp) {
            }


            public void stopped(Component comp) {
            }

View Full Code Here

Examples of org.apache.felix.dm.Component.addStateListener()

        m_dm = new DependencyManager(m_context);
        Component comp =
            m_dm.createComponent().setImplementation(this)
                .add(m_dm.createServiceDependency().setService(ConfigurationAdmin.class).setRequired(true));


        comp.addStateListener(new ComponentStateListener() {
            public void started(Component c) {
                latch.countDown();
            }


            public void starting(Component c) {

View Full Code Here

Examples of org.rhq.enterprise.communications.command.client.ClientCommandSender.addStateListener()

        ClientCommandSender sender_to_server = getClientCommandSender();


        boolean zero = false;
        if (sender_to_server != null) {
            LOG.debug(AgentI18NResourceKeys.WAITING_FOR_SERVER, wait_ms);
            sender_to_server.addStateListener(listener, true);
            try {
                zero = latch.await(wait_ms, TimeUnit.MILLISECONDS);
                // if this agent is updating, break the loop immediately by throwing exception
                if (AgentUpdateThread.isUpdatingNow()) {
                    throw new AgentNotSupportedException();

View Full Code Here

Examples of org.springframework.osgi.service.importer.support.internal.controller.ImporterInternalActions.addStateListener()

    ExporterControllerUtils.getControllerFor(exporter).unregisterService();
  }


  private void addListener(Object importer, ImporterStateListener stateListener) {
    ImporterInternalActions controller = ImporterControllerUtils.getControllerFor(importer);
    controller.addStateListener(stateListener);
  }


  private void removeListener(Object importer, ImporterStateListener stateListener) {
    ImporterInternalActions controller = ImporterControllerUtils.getControllerFor(importer);
    controller.removeStateListener(stateListener);

View Full Code Here

Examples of org.springframework.osgi.service.importer.support.internal.controller.ImporterInternalActions.addStateListener()

    ExporterControllerUtils.getControllerFor(exporter).unregisterService();
  }


  private void addListener(Object importer, ImporterStateListener stateListener) {
    ImporterInternalActions controller = ImporterControllerUtils.getControllerFor(importer);
    controller.addStateListener(stateListener);
  }


  private void removeListener(Object importer, ImporterStateListener stateListener) {
    ImporterInternalActions controller = ImporterControllerUtils.getControllerFor(importer);
    controller.removeStateListener(stateListener);

View Full Code Here

0 1

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.