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 org.asmatron.messengine.engines.DefaultMessagingDelegate.addMessageListener()

        lock.release();
      }
    };
    final String type = "foo";
    Message<String> message = new TestMessage<String>(type, expectedBody);
    engine.addMessageListener(type, listener);
    final int totalMessages = 1000;
    for (int i = 0; i < totalMessages; i++) {
      engine.send(message);
    }
    lock.tryAcquire(totalMessages, 3, TimeUnit.SECONDS);

View Full Code Here

Examples of org.asmatron.messengine.engines.DefaultMessagingDelegate.addMessageListener()

      }
    };
    final String type = "foo";
    final String expectedBody = "HELLO WORLD!";
    Message<String> message = new TestMessage<String>(type, expectedBody);
    engine.addMessageListener(type, listenerA);
    engine.addMessageListener(type, listenerB);
    final int totalMessages = 1000;
    for (int i = 0; i < totalMessages; i++) {
      engine.send(message);
    }

View Full Code Here

Examples of org.asmatron.messengine.engines.DefaultMessagingDelegate.addMessageListener()

    };
    final String type = "foo";
    final String expectedBody = "HELLO WORLD!";
    Message<String> message = new TestMessage<String>(type, expectedBody);
    engine.addMessageListener(type, listenerA);
    engine.addMessageListener(type, listenerB);
    final int totalMessages = 1000;
    for (int i = 0; i < totalMessages; i++) {
      engine.send(message);
    }
    lock.tryAcquire(totalMessages * 2, 3, TimeUnit.SECONDS);

View Full Code Here

Examples of org.asmatron.messengine.engines.DefaultMessagingDelegate.addMessageListener()

      public void onMessage(Message<String> message) {
        counter.incrementAndGet();
      }
    };
    String type = "foo";
    engine.addMessageListener(type, listener);
    engine.send(new TestMessage<String>(type, "body"));
    Thread.sleep(100);
    engine.removeMessageListener(type, listener);
    engine.send(new TestMessage<String>(type, "body"));
    Thread.sleep(100);

View Full Code Here

Examples of org.eclipse.ecf.presence.chatroom.IChatRoomContainer.addMessageListener()

    }
    this.container = container;
    IChatRoomContainer chatRoomContainer = (IChatRoomContainer) container
        .getAdapter(IChatRoomContainer.class);
    chatMessageSender = chatRoomContainer.getPrivateMessageSender();
    chatRoomContainer.addMessageListener(new IIMMessageListener() {
      public void handleMessageEvent(IIMMessageEvent e) {
        if (e instanceof IChatMessageEvent) {
          IChatMessageEvent event = (IChatMessageEvent) e;
          String msg = event.getChatMessage().getBody();
          switch (msg.charAt(0)) {

View Full Code Here

Examples of org.eclipse.ecf.presence.im.IChatManager.addMessageListener()


    final IChatManager icm = adapter.getChatManager();
    icms = icm.getChatMessageSender();
    itms = icm.getTypingMessageSender();


    icm.addMessageListener(new IIMMessageListener() {
      public void handleMessageEvent(IIMMessageEvent e) {
        if (e instanceof IChatMessageEvent) {
          displayMessage((IChatMessageEvent) e);
        } else if (e instanceof ITypingMessageEvent) {
          displayTypingNotification((ITypingMessageEvent) e);

View Full Code Here

Examples of org.jivesoftware.smack.Chat.addMessageListener()

        addLoggingListeners("LASTGUY", consumerCon);
        lastguyCon.login("consumer", "consumer");
        final ConsumerMessageListener listener2 = new ConsumerMessageListener();
        lastguyCon.getChatManager().addChatListener(new ChatManagerListener() {
            public void chatCreated(Chat chat, boolean createdLocally) {
                chat.addMessageListener(listener2);
            }
        });


        for (int i = 0; i < 10; i++) {
            System.out.println("Sending message: " + i);

View Full Code Here

Examples of org.jivesoftware.smack.Chat.addMessageListener()

        addLoggingListeners("LASTGUY", consumerCon);
        lastguyCon.login("consumer", "consumer");
        final ConsumerMessageListener listener2 = new ConsumerMessageListener();
        lastguyCon.getChatManager().addChatListener(new ChatManagerListener() {
            public void chatCreated(Chat chat, boolean createdLocally) {
                chat.addMessageListener(listener2);
            }
        });


        for (int i = 0; i < 10; i++) {
            System.out.println("Sending message: " + i);

View Full Code Here

Examples of org.jivesoftware.smack.Chat.addMessageListener()

        addLoggingListeners("LASTGUY", consumerCon);
        lastguyCon.login("consumer", "consumer");
        final ConsumerMessageListener listener2 = new ConsumerMessageListener();
        lastguyCon.getChatManager().addChatListener(new ChatManagerListener() {
            public void chatCreated(Chat chat, boolean createdLocally) {
                chat.addMessageListener(listener2);
            }
        });


        for (int i = 0; i < 10; i++) {
            LOG.info("Sending message: " + i);

View Full Code Here

Examples of org.jivesoftware.smack.Chat.addMessageListener()

            // just add a listener to that chat
            Chat privateChat = connection.getChatManager().getThreadChat(endpoint.getParticipant());


            if (privateChat != null) {
                LOG.debug("Adding listener to existing chat opened to " + privateChat.getParticipant());
                privateChat.addMessageListener(this);
            } else {                
                privateChat = connection.getChatManager().createChat(endpoint.getParticipant(), endpoint.getParticipant(), this);
                LOG.debug("Opening private chat to " + privateChat.getParticipant());
            }

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.