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.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.registerListener()

    // Close the first server and delete it's master node
    ms1.stop("stopping first server");


    // Use a listener to capture when the node is actually deleted
    NodeDeletionListener listener = new NodeDeletionListener(zk, zk.masterAddressZNode);
    zk.registerListener(listener);


    LOG.info("Deleting master node");
    ZKUtil.deleteNode(zk, zk.masterAddressZNode);


    // Wait for the node to be deleted

View Full Code Here

Examples of org.apache.hadoop.hbase.zookeeper.ZooKeeperWrapper.registerListener()

    otherConf.set(HConstants.ZOOKEEPER_QUORUM, ensemble[0]);
    otherConf.set("hbase.zookeeper.property.clientPort", ensemble[1]);
    otherConf.set(HConstants.ZOOKEEPER_ZNODE_PARENT, ensemble[2]);
    ZooKeeperWrapper zkw = ZooKeeperWrapper.createInstance(otherConf,
        "connection to cluster: " + peerId);
    zkw.registerListener(new ReplicationStatusWatcher());
    this.peerClusters.put(peerId, zkw);
    this.zookeeperWrapper.ensureExists(this.zookeeperWrapper.getZNode(
        this.rsServerNameZnode, peerId));
    LOG.info("Added new peer cluster " + StringUtils.arrayToString(ensemble));
  }

View Full Code Here

Examples of org.apache.lenya.cms.observation.ObservationRegistry.registerListener()


    public void start() throws Exception {
        ObservationRegistry registry = null;
        try {
            registry = (ObservationRegistry) this.manager.lookup(ObservationRegistry.ROLE);
            registry.registerListener(this);
        } finally {
            if (registry != null) {
                this.manager.release(registry);
            }
        }

View Full Code Here

Examples of org.apache.oodt.cas.workflow.gui.perspective.view.View.registerListener()


  private View createProjectView() {
    try {
      View view = this.projectViewClass.getConstructor(String.class)
          .newInstance(this.projectViewClass.getSimpleName());
      view.registerListener(this);
      return view;
    } catch (Exception e) {
      e.printStackTrace();
      return null;
    }

View Full Code Here

Examples of org.apache.pig.tools.pigstats.ScriptState.registerListener()

        
        // create the static script state object
        String commandLine = LoadFunc.join((AbstractList<String>)Arrays.asList(args), " ");
        ScriptState scriptState = ScriptState.start(commandLine);
        if (listener != null) {
            scriptState.registerListener(listener);
        }
        


        if(logFileName == null && !userSpecifiedLog) {
            logFileName = validateLogFile(properties.getProperty("pig.logfile"), null);

View Full Code Here

Examples of org.apache.poi.hssf.eventmodel.EventRecordFactory.registerListener()

        int size = sheet.getSize();
        byte[] data = new byte[size];
        sheet.serialize(0, data);
        EventRecordFactory erf = new EventRecordFactory();
        MyIndexRecordListener myIndexListener = new MyIndexRecordListener();
        erf.registerListener(myIndexListener, new short[] { IndexRecord.sid, });
        erf.processRecords(new ByteArrayInputStream(data));
        IndexRecord indexRecord = myIndexListener.getIndexRecord();
        int dbCellRecordPos = indexRecord.getDbcellAt(0);
        return dbCellRecordPos;
    }

View Full Code Here

Examples of org.apache.poi.poifs.eventfilesystem.POIFSReader.registerListener()

  
  
  public static void extractText(InputStream inStream, OutputStream stream ) throws IOException {
    POIFSReader r = new POIFSReader();
    /* Register a listener for *all* documents. */
    r.registerListener(new MyPOIFSReaderListener(stream));
    r.read(inStream);
  }


  static class MyPOIFSReaderListener implements POIFSReaderListener {
    private static final OLog log = Tracing.createLoggerFor(PPT2Text.class);

View Full Code Here

Examples of org.apache.poi.poifs.eventfilesystem.POIFSReader.registerListener()

      try
      {
        // Use POIFS to traverse the file
        POIFSReader reader = new POIFSReader();
        ReaderListener listener = new ReaderListener();
        reader.registerListener(listener,"\u0005SummaryInformation");
        reader.read(is);
        if (Logging.ingest.isDebugEnabled())
          Logging.ingest.debug("GTS: Done finding appname for '"+documentPath.toString()+"'");
        return listener.getAppName();
      }

View Full Code Here

Examples of org.apache.poi.poifs.eventfilesystem.POIFSReader.registerListener()

                    }
                    try {
                        ByteArrayOutputStream baos = new ByteArrayOutputStream();
                        MsPowerPointListener listener = new MsPowerPointListener(baos);
                        POIFSReader reader = new POIFSReader();
                        reader.registerListener(listener);
                        reader.read(in);


                        delegate = new InputStreamReader(
                            new ByteArrayInputStream(baos.toByteArray()));
                    } finally {

View Full Code Here

Examples of org.apache.poi.poifs.eventfilesystem.POIFSReader.registerListener()

        poiFs.writeFilesystem(out);
        out.close();


        /* Read the POIFS: */
        final POIFSReader r = new POIFSReader();
        r.registerListener(new MyPOIFSReaderListener(),
                           SummaryInformation.DEFAULT_STREAM_NAME);
        r.read(new FileInputStream(filename));
    }

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.