List of registerListener() Examples

Examples of registerListener()

chatbot.client.MessageChannel.registerListener()
com.alibaba.wasp.executor.ExecutorService.registerListener()
Subscribe to updates before and after processing instances of {@link EventHandler.EventType}. Currently only one listener per event type. @param type Type of event we're registering listener for @param listener The listener to run.
com.alibaba.wasp.zookeeper.ZooKeeperWatcher.registerListener()
Register the specified listener to receive ZooKeeper events. @param listener
com.hazelcast.cache.impl.CacheService.registerListener()
com.hazelcast.client.spi.impl.ClientInvocationServiceImpl.registerListener()
com.hazelcast.spi.EventService.registerListener()
Registers a listener on all cluster nodes. @param serviceName service name @param topic topic name @param listener listener instance @return event registration
com.orientechnologies.orient.core.db.record.ODatabaseFlat.registerListener()
com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryAsynchClient.registerListener()
eu.admire.gateway.engine.DISPELGraphExecutor.registerListener()
Registers the given progress listener. @param listener progress listener to register
net.sf.ehcache.event.RegisteredEventListeners.registerListener()
Adds a listener to the notification service. No guarantee is made that listeners will be notified in the order they were added. @param cacheEventListener @return true if the listener is being added and was not already added
nfc.sample.Ndef.Read.NdefListenerManager.registerListener()
org.apache.cxf.endpoint.ClientLifeCycleManager.registerListener()
org.apache.cxf.endpoint.ServerLifeCycleManager.registerListener()
org.apache.hadoop.hbase.executor.ExecutorService.registerListener()
Subscribe to updates before and after processing instances of {@link EventHandler.EventType}. Currently only one listener per event type. @param type Type of event we're registering listener for @param listener The listener to run.
org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.registerListener()
Register the specified listener to receive ZooKeeper events. @param listener
org.apache.hadoop.hbase.zookeeper.ZooKeeperWrapper.registerListener()
org.apache.lenya.cms.observation.ObservationRegistry.registerListener()
@param listener The listener. @param document The document to listen to. @throws ObservationException if the listener is already registered for this document.
org.apache.oodt.cas.workflow.gui.perspective.view.View.registerListener()
org.apache.pig.tools.pigstats.ScriptState.registerListener()
org.apache.poi.hssf.eventmodel.EventRecordFactory.registerListener()
Register a listener for records. These can be for all records or just a subset. @param sids an array of Record.sid values identifying the recordsthe listener will work with. Alternatively if this is "null" then all records are passed.
org.apache.poi.poifs.eventfilesystem.POIFSReader.registerListener()
Register a POIFSReaderListener for all documents @param listener the listener to be registered @exception NullPointerException if listener is null @exception IllegalStateException if read() has already beencalled
org.axonframework.unitofwork.UnitOfWork.registerListener()
Register a listener that listens to state changes in this UnitOfWork. This typically allows components to clean up resources, such as locks, when a UnitOfWork is committed or rolled back. If a UnitOfWork is partially committed, only the listeners bound to one of the committed aggregates is notified. @param listener The listener to notify when the UnitOfWork's state changes.
org.b3log.latke.event.EventManager.registerListener()
Registers the specified event listener. @param eventListener the specified event listener
org.drools.compiler.kie.builder.impl.InternalKieServices.registerListener()
org.eclipse.jetty.client.HttpClient.registerListener()
org.hornetq.core.cluster.DiscoveryGroup.registerListener()
org.hornetq.core.cluster.impl.DiscoveryGroupImpl.registerListener()
org.jboss.ha.core.framework.server.DistributedReplicantManagerImpl.registerListener()
org.jboss.ha.framework.interfaces.DistributedReplicantManager.registerListener()
Subscribe a new {@link ReplicantListener listener } for replicant changes @param key Name of the replicant, must be identical cluster-wide for all related replicants @param subscriber The subscribing {@link ReplicantListener}
org.jboss.ha.framework.server.DistributedReplicantManagerImpl.registerListener()
org.jboss.kernel.spi.event.KernelEventManager.registerListener()
Register a listener @param name the name of the object to register on @param listener the listener @param filter the filter @param handback the handback object @throws Throwable for any error
org.jboss.messaging.core.plugin.contract.Replicator.registerListener()
org.jboss.test.kernel.event.support.TestEmitter.registerListener()
org.mule.api.MuleContext.registerListener()
Registers an intenal server event listener. The listener will be notified when a particular event happens within the server. Typically this is not an event in the same sense as an MuleEvent (although there is nothing stopping the implementation of this class triggering listeners when a MuleEvent is received).
The types of notifications fired is entirely defined by the implementation of this class @param l the listener to register
org.mule.api.transport.Connector.registerListener()
Registers a MessageProcessor listener which will listen to new message received from a specific transport channel and then processed by the endpoint. Only a single listener can be registered for a given endpoints. Attempts to register a listener when one is already registered will fail. @param endpoint defines both the transport and channel/resource uri as wellthe processing (transformation/filtering) that should occur when the endpoint processes a new message from the transport receiver. @param listener the listener that will be invoked when messages are receivedon the endpoint. @param flowConstruct reference to the flow construct that the listener is partof for use as context for logging, notifications and error handling.
org.picketlink.idm.api.IdentitySession.registerListener()
org.springframework.batch.repeat.support.RepeatTemplate.registerListener()
Register an additional listener. @param listener
org.terasology.world.WorldProvider.registerListener()
org.wildfly.extension.undertow.UndertowService.registerListener()
Registers custom Event listener to server @param listener event listener to register
org.xvr.cam.widgets.CameraViewer.registerListener()

Examples of org.jboss.ha.core.framework.server.DistributedReplicantManagerImpl.registerListener()

            // Register a MockHASingletonDeployer, but since we're in
            // non-conflicting mode, the DeployerThreads won't deal with it
            MockHASingletonDeployer listener = 
                  new MockHASingletonDeployer(deployer, "HASingleton", log);
            
            drm.registerListener("HASingleton", listener);
            drm.add("HASingleton", "HASingleton");            
         }
         
         // Create a semaphore to gate the threads and acquire all its permits
         Semaphore semaphore = new Semaphore(count + 1);

View Full Code Here

Examples of org.jboss.ha.core.framework.server.DistributedReplicantManagerImpl.registerListener()

         DistributedReplicantManagerImpl drm = new DistributedReplicantManagerImpl(partition);
         drm.createService();
         drm.startService();
         
         CachingListener listener = new CachingListener();
         drm.registerListener("TEST", listener);
         
         SecureRandom random = new SecureRandom();
         boolean[] added = new boolean[nodes.length];
         List lookup = null;
         for (int i = 0; i < 10; i++)

View Full Code Here

Examples of org.jboss.ha.core.framework.server.DistributedReplicantManagerImpl.registerListener()

         DistributedReplicantManagerImpl drm = new DistributedReplicantManagerImpl(partition);
         drm.createService();
         drm.startService();
         
         CachingListener listener = new CachingListener();
         drm.registerListener("TEST", listener);
         
         SecureRandom random = new SecureRandom();
         boolean[] added = new boolean[nodes.length];
         List lookup = null;
         List<ClusterNode> lookupReplicantsNodes = null;

View Full Code Here

Examples of org.jboss.ha.framework.interfaces.DistributedReplicantManager.registerListener()


      DistributedReplicantManager drm = this.partition.getDistributedReplicantManager();
      DistributedState ds = this.partition.getDistributedStateService();
      
      drm.add(this.RPC_HANDLER_NAME, "");
      drm.registerListener(this.RPC_HANDLER_NAME, this);
      ds.registerDSListenerEx(this.RPC_HANDLER_NAME, this);
      this.partition.registerRPCHandler(this.RPC_HANDLER_NAME, this);


      // we now publish the list of caches we have access to
      if (this.invalMgr == null)

View Full Code Here

Examples of org.jboss.ha.framework.interfaces.DistributedReplicantManager.registerListener()

      partition.registerRPCHandler(getServiceHAName(), rpcTarget);
      
      DistributedReplicantManager drm = partition.getDistributedReplicantManager();
      drm.add(getServiceHAName(), partition.getClusterNode());
      coordinator = drm.isMasterReplica(getServiceHAName());
      drm.registerListener(getServiceHAName(), drmListener);
      
      statusCheck();
   }
   
   /**

View Full Code Here

Examples of org.jboss.ha.framework.interfaces.DistributedReplicantManager.registerListener()

      this.partition.registerRPCHandler(getServiceHAName(), rpcTarget);
      
      DistributedReplicantManager drm = this.partition.getDistributedReplicantManager();
      drm.add(getServiceHAName(), this.partition.getClusterNode());
      this.serviceView = drm.lookupReplicantsNodes(getServiceHAName());
      drm.registerListener(getServiceHAName(), drmListener);
      
      this.initialized = true;
   }
   
   public void shutdown() throws Exception

View Full Code Here

Examples of org.jboss.ha.framework.server.DistributedReplicantManagerImpl.registerListener()

            // Register a MockHASingletonDeployer, but since we're in
            // non-conflicting mode, the DeployerThreads won't deal with it
            MockHASingletonDeployer listener = 
                  new MockHASingletonDeployer(deployer, "HASingleton", log);
            
            drm.registerListener("HASingleton", listener);
            drm.add("HASingleton", "HASingleton");            
         }
         
         // Create a semaphore to gate the threads and acquire all its permits
         Semaphore semaphore = new Semaphore(count + 1);

View Full Code Here

Examples of org.jboss.kernel.spi.event.KernelEventManager.registerListener()

      KernelEventManager eventManager = kernel.getEventManager();
      TestEmitter emitter = new TestEmitter();
      KernelRegistryEntry entry = makeEntry(emitter);
      registry.registerEntry("Emitter", entry);
      TestListener listener = new TestListener();
      eventManager.registerListener("Emitter", listener, null, null);
      emitter.testFire("testtype", null);
      ArrayList expected = new ArrayList();
      expected.add(EventTestCaseSupport.makeExpected(emitter, "testtype", 0, null, null));
      EventTestCaseSupport.check(listener, expected);
   }

View Full Code Here

Examples of org.jboss.kernel.spi.event.KernelEventManager.registerListener()

      KernelEventManager eventManager = kernel.getEventManager();
      TestEmitter emitter = new TestEmitter();
      KernelRegistryEntry entry = makeEntry(emitter);
      registry.registerEntry("Emitter", entry);
      TestListener listener = new TestListener();
      eventManager.registerListener("Emitter", listener, null, null);
      emitter.testFire("testtype", null);
      emitter.testFire("testtype", null);
      ArrayList expected = new ArrayList();
      expected.add(EventTestCaseSupport.makeExpected(emitter, "testtype", 0, null, null));
      expected.add(EventTestCaseSupport.makeExpected(emitter, "testtype", 1, null, null));

View Full Code Here

Examples of org.jboss.kernel.spi.event.KernelEventManager.registerListener()

      TestEmitter emitter = new TestEmitter();
      KernelRegistryEntry entry = makeEntry(emitter);
      registry.registerEntry("Emitter", entry);
      TestListener listener = new TestListener();
      TestFilter filter = new TestFilter();
      eventManager.registerListener("Emitter", listener, filter, null);
      emitter.testFire("testtype", null);
      filter.fireEvent = false;
      emitter.testFire("testtype", null);
      ArrayList expected = new ArrayList();
      expected.add(EventTestCaseSupport.makeExpected(emitter, "testtype", 0, null, null));

View Full Code Here

0 1 2 3 4 5 6 7

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.