List of addMessageListener() Examples

Examples of addMessageListener()

asia.stampy.examples.client.mina.MinaAutoTerminatingClientGateway.addMessageListener()
asia.stampy.examples.client.netty.NettyAutoTerminatingClientGateway.addMessageListener()
asia.stampy.server.mina.ServerMinaMessageGateway.addMessageListener()
asia.stampy.server.netty.ServerNettyMessageGateway.addMessageListener()
co.paralleluniverse.galaxy.quasar.Messenger.addMessageListener()
Adds a message listener on a {@code lonng} topic. @param topic The topic. @param listener The listener.
com.aelitis.azureus.core.messenger.ClientMessageContext.addMessageListener()
com.aelitis.azureus.ui.swt.browser.BrowserContext.addMessageListener()
com.hazelcast.core.ITopic.addMessageListener()
Subscribes to this topic. When someone publishes a message on this topic. onMessage() function of the given MessageListener is called. More than one message listener can be added on one instance. @param listener @return returns registration id.
com.hazelcast.topic.TopicService.addMessageListener()
com.hazelcast.topic.impl.TopicService.addMessageListener()
com.jme3.network.Client.addMessageListener()
com.jme3.network.Server.addMessageListener()
com.linkedin.helix.HelixManager.addMessageListener()
@see MessageListener#onMessage(String,List,NotificationContext) @param listener @param instanceName
com.linkedin.helix.manager.file.StaticFileHelixManager.addMessageListener()
com.sun.enterprise.deployment.InboundResourceAdapter.addMessageListener()
de.bamberg.ha.api.remote.Connector.addMessageListener()
add a listener which is called every time a message is received. the listeners acts as callback functions @param listener
net.rim.blackberry.api.mail.Message.addMessageListener()
org.apache.helix.HelixManager.addMessageListener()
@see MessageListener#onMessage(String,List,NotificationContext) @param listener @param instanceName
org.apache.muse.ws.notification.NotificationConsumer.addMessageListener()
Adds the listener to the list of listeners that will be notified whenever a message is received by the resource. @param listener
org.apache.openejb.jee.MessageAdapter.addMessageListener()
org.asmatron.messengine.engines.DefaultMessagingDelegate.addMessageListener()
org.eclipse.ecf.presence.chatroom.IChatRoomContainer.addMessageListener()
Add message listener. @param listener the listener to add. Must not be null.
org.eclipse.ecf.presence.im.IChatManager.addMessageListener()
Add message listener. @param listener the listener to add. Must not be null.
org.jivesoftware.smack.Chat.addMessageListener()
Adds a packet listener that will be notified of any new messages in the chat. @param listener a packet listener.
org.jivesoftware.smackx.muc.MultiUserChat.addMessageListener()
Adds a packet listener that will be notified of any new messages in the group chat. Only "group chat" messages addressed to this group chat will be delivered to the listener. If you wish to listen for other packets that may be associated with this group chat, you should register a PacketListener directly with the Connection with the appropriate PacketListener. @param listener a packet listener.
org.springframework.data.redis.listener.RedisMessageListenerContainer.addMessageListener()
Adds a message listener to the (potentially running) container. If the container is running, the listener starts receiving (matching) messages as soon as possible. @param listener message listener @param topics message listener topic
rocks.xmpp.core.session.TestXmppSession.addMessageListener()
rocks.xmpp.core.session.XmppSession.addMessageListener()
Adds a message listener to the connection, which will get notified, whenever a message is received. @param messageListener The message listener. @see #removeMessageListener(MessageListener)

Examples of com.linkedin.helix.HelixManager.addMessageListener()

  
  for (String instance : curInstances.keySet()) {
    if (lastInstances == null || !lastInstances.containsKey(instance)) {
          try {
            // add message listeners for new sessions
            manager.addMessageListener(this, instance);
            LOG.info("Succeed in adding message listener for " + instance);
          }
          catch (Exception e)
          {
            LOG.error("Fail to add message listener for instance:" + instance, e);

View Full Code Here

Examples of com.linkedin.helix.manager.file.StaticFileHelixManager.addMessageListener()

    controllerListener.reset();


    controller.addIdealStateChangeListener(controllerListener);
    AssertJUnit.assertTrue(controllerListener.isIdealStateChangeListenerInvoked);


    controller.addMessageListener(controllerListener, "localhost_8900");
    AssertJUnit.assertTrue(controllerListener.isMessageListenerInvoked);


    exceptionCaught = false;
    try
    {

View Full Code Here

Examples of com.sun.enterprise.deployment.InboundResourceAdapter.addMessageListener()

                    MessageListener ml = new MessageListener();
                    ml.setActivationSpecClass(activationSpecClass);
                    ml.setMessageListenerType(mlClass.getName());


                    if (!ira.hasMessageListenerType(mlClass.getName())) {
                        ira.addMessageListener(ml);
                    }// else {
                        // ignore the duplicates
                        // duplicates can be via :
                        // (i) message listner defined in DD
                        // (ii) as part of this particular annotation processing,

View Full Code Here

Examples of de.bamberg.ha.api.remote.Connector.addMessageListener()

  @Test
  public void testAllListenerCalled() throws Exception {
    Connector connector=createConnector();
    JUnitMessageListener l1=new JUnitMessageListener();
    JUnitMessageListener l2=new JUnitMessageListener();
    connector.addMessageListener(l1);
    connector.addMessageListener(l2);
    connector.messageReceived(new MessageEvent(HELLO_WORLD));
    assertEquals(HELLO_WORLD,l1.getMessage());
    assertEquals(HELLO_WORLD,l2.getMessage());

View Full Code Here

Examples of net.rim.blackberry.api.mail.Message.addMessageListener()


            // Populate the list with the messages in the current folder and
            // add a message listener to them.
            for (int messageIndex = 0; messageIndex < messages.length; messageIndex++) {
                final Message message = messages[messageIndex];
                message.addMessageListener(this);
                _messages.addElement(message);
            }
        }
    }

View Full Code Here

Examples of org.apache.helix.HelixManager.addMessageListener()

      if (!_instanceSubscriptionNames.contains(instanceName))
      {
        try
        {
          logger.info("Adding message listener for " + instanceName);
          manager.addMessageListener(this, instanceName);
          _instanceSubscriptionNames.add(instanceName);
        }
        catch (Exception e)
        {
          logger.error("Exception adding message listener for instance:" + instanceName,

View Full Code Here

Examples of org.apache.helix.HelixManager.addMessageListener()


    TestZKCallback test = new TestZKCallback();


    TestZKCallback.TestCallbackListener testListener = test.new TestCallbackListener();


    testHelixManager.addMessageListener(testListener, "localhost_8900");
    testHelixManager.addCurrentStateChangeListener(testListener, "localhost_8900",
        testHelixManager.getSessionId());
    testHelixManager.addConfigChangeListener(testListener);
    testHelixManager.addIdealStateChangeListener(testListener);
    testHelixManager.addExternalViewChangeListener(testListener);

View Full Code Here

Examples of org.apache.helix.HelixManager.addMessageListener()


    for (String instance : curInstances.keySet()) {
      if (lastInstances == null || !lastInstances.containsKey(instance)) {
        try {
          // add message listeners for new instances
          manager.addMessageListener(this, instance);
          logger.info(manager.getInstanceName() + " added message listener for " + instance
              + ", listener: " + this);
        } catch (Exception e) {
          logger.error("Fail to add message listener for instance: " + instance, e);
        }

View Full Code Here

Examples of org.apache.helix.HelixManager.addMessageListener()


    for (String instance : curInstances.keySet()) {
      if (lastInstances == null || !lastInstances.containsKey(instance)) {
        try {
          // add message listeners for new instances
          manager.addMessageListener(this, instance);
          logger.info(manager.getInstanceName() + " added message listener for " + instance
              + ", listener: " + this);
        } catch (Exception e) {
          logger.error("Fail to add message listener for instance: " + instance, e);
        }

View Full Code Here

Examples of org.apache.helix.HelixManager.addMessageListener()


    TestZKCallback test = new TestZKCallback();


    TestZKCallback.TestCallbackListener testListener = test.new TestCallbackListener();


    testHelixManager.addMessageListener(testListener, "localhost_8900");
    testHelixManager.addCurrentStateChangeListener(testListener, "localhost_8900",
        testHelixManager.getSessionId());
    testHelixManager.addConfigChangeListener(testListener);
    testHelixManager.addIdealStateChangeListener(testListener);
    testHelixManager.addExternalViewChangeListener(testListener);

View Full Code Here

0 1 2 3 4 5 6

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.