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 net.kano.joustsim.oscar.AimConnection.addStateListener()


      Screenname sn = new Screenname(getScreenName());
      _aimSession = new DefaultAimSession(sn);
      AimConnectionProperties props = new AimConnectionProperties(sn, getPassword());
      AimConnection conn = _aimSession.openConnection(props);
      conn.addStateListener(new AimStateHandler());
      conn.connect();
    }
    else {
      throw new ConnectedTooFastException("You attempted to connect repeatedly too quickly.");
    }

View Full Code Here

Examples of net.rubyeye.xmemcached.MemcachedClientBuilder.addStateListener()


  @Override
  protected void setUp() throws Exception {
    MemcachedClientBuilder builder = new XMemcachedClientBuilder();
    listener = new MockMemcachedClientStateListener();
    builder.addStateListener(listener);
    memcachedClient = builder.build();
  }


  public void testStarted() {
    assertEquals(1, listener.getNum());

View Full Code Here

Examples of net.rubyeye.xmemcached.MemcachedClientBuilder.addStateListener()

    try {
      // use text protocol by default
      MemcachedClientBuilder builder = new XMemcachedClientBuilder(
          AddrUtil.getAddresses(servers));
      // Add my state listener
      builder.addStateListener(new MyListener());
      return builder.build();
    } catch (IOException e) {
      System.err.println("Create MemcachedClient fail");
      e.printStackTrace();
    }

View Full Code Here

Examples of net.rubyeye.xmemcached.XMemcachedClientBuilder.addStateListener()


  @Override
  protected void setUp() throws Exception {
    MemcachedClientBuilder builder = new XMemcachedClientBuilder();
    listener = new MockMemcachedClientStateListener();
    builder.addStateListener(listener);
    memcachedClient = builder.build();
  }


  public void testStarted() {
    assertEquals(1, listener.getNum());

View Full Code Here

Examples of net.rubyeye.xmemcached.XMemcachedClientBuilder.addStateListener()

    try {
      // use text protocol by default
      MemcachedClientBuilder builder = new XMemcachedClientBuilder(
          AddrUtil.getAddresses(servers));
      // Add my state listener
      builder.addStateListener(new MyListener());
      return builder.build();
    } catch (IOException e) {
      System.err.println("Create MemcachedClient fail");
      e.printStackTrace();
    }

View Full Code Here

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

            .add(m.createServiceDependency()
            .setService(ServiceInterface.class)
            .setRequired(true)
            .setInstanceBound(true));
        // add a component state listener
        component.addStateListener(new ComponentStateListenerImpl(e));
        // add the resource adapter
        m.add(component);
        // wait until the single resource is available (the adapter has been started)
        e.waitForStep(1, 5000);
        // trigger a 'change' in our resource

View Full Code Here

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

        ComponentStateListeningInstance implementation = new ComponentStateListeningInstance(e);
        Component s = m.createComponent()
            .setInterface(MyInterface.class.getName(), null)
            .setImplementation(implementation);
        // add the state listener
        s.addStateListener(implementation);
        // add it, and since it has no dependencies, it should be activated immediately
        m.add(s);
        // remove it so it gets destroyed
        m.remove(s);
        // remove the state listener

View Full Code Here

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

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

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;                
        }
        
        /**

View Full Code Here

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

            .add(m.createServiceDependency()
            .setService(ServiceInterface.class, "(id=1)")
            .setRequired(true)
            .setInstanceBound(true)
        );
        component.addStateListener(new ComponentStateListenerImpl(e));
        m.add(component);
        // wait until the single resource is available
        e.waitForStep(1, 5000);
        // trigger a 'change' in our resource
        provider.change();

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.