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.jivesoftware.smackx.muc.MultiUserChat.addMessageListener()

        consumerCon.login("consumer", "consumer");
        MultiUserChat consumerMuc = new MultiUserChat(consumerCon, "muc-test");
        consumerMuc.join("consumer");


        ConsumerMUCMessageListener listener = new ConsumerMUCMessageListener();
        consumerMuc.addMessageListener(listener);


        XMPPConnection producerCon = new XMPPConnection(config);
        producerCon.connect();
        producerCon.login("producer", "producer");
        MultiUserChat producerMuc = new MultiUserChat(producerCon, "muc-test");

View Full Code Here

Examples of org.jivesoftware.smackx.muc.MultiUserChat.addMessageListener()

        consumerCon.login("consumer", "consumer");
        MultiUserChat consumerMuc = new MultiUserChat(consumerCon, "muc-test");
        consumerMuc.join("consumer");


        ConsumerMUCMessageListener listener = new ConsumerMUCMessageListener();
        consumerMuc.addMessageListener(listener);


        XMPPConnection producerCon = new XMPPConnection(config);
        producerCon.connect();
        producerCon.login("producer", "producer");
        MultiUserChat producerMuc = new MultiUserChat(producerCon, "muc-test");

View Full Code Here

Examples of org.jivesoftware.smackx.muc.MultiUserChat.addMessageListener()

        consumerCon.login("consumer", "consumer");
        MultiUserChat consumerMuc = new MultiUserChat(consumerCon, "muc-test");
        consumerMuc.join("consumer");


        final ConsumerMUCMessageListener listener = new ConsumerMUCMessageListener();
        consumerMuc.addMessageListener(listener);


        XMPPConnection producerCon = new XMPPConnection(config);
        producerCon.connect();
        producerCon.login("producer", "producer");
        MultiUserChat producerMuc = new MultiUserChat(producerCon, "muc-test");

View Full Code Here

Examples of org.jivesoftware.smackx.muc.MultiUserChat.addMessageListener()

                        }
                    }
                }
            }
        };
        muc.addMessageListener(myListener);


        PacketListener peopleListener = new PacketListener() {


            @Override
            public void processPacket(Packet packet) {

View Full Code Here

Examples of org.jivesoftware.smackx.muc.MultiUserChat.addMessageListener()

                        }


                    }
                }
            };
            muc.addMessageListener(myListener);


            PacketListener peopleListener = new PacketListener() {


                @Override
                public void processPacket(Packet packet) {

View Full Code Here

Examples of org.springframework.data.redis.listener.RedisMessageListenerContainer.addMessageListener()

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(
            RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(redisSessionMessageListener(),
                new PatternTopic("__keyspace@0__:spring:session:sessions:*"));
        return container;
    }


    @Bean

View Full Code Here

Examples of rocks.xmpp.core.session.TestXmppSession.addMessageListener()


        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);
        XmppSession xmppSession2 = new TestXmppSession(JULIET, mockServer);


        final boolean[] attentionReceived = {false};
        xmppSession2.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (e.isIncoming() && e.getMessage().getExtension(Attention.class) != null && e.getMessage().getType() == AbstractMessage.Type.HEADLINE) {
                    attentionReceived[0] = true;
                    Assert.assertEquals(e.getMessage().getType(), AbstractMessage.Type.HEADLINE);

View Full Code Here

Examples of rocks.xmpp.core.session.XmppSession.addMessageListener()


        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);
        XmppSession xmppSession2 = new TestXmppSession(JULIET, mockServer);


        final boolean[] attentionReceived = {false};
        xmppSession2.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (e.isIncoming() && e.getMessage().getExtension(Attention.class) != null && e.getMessage().getType() == AbstractMessage.Type.HEADLINE) {
                    attentionReceived[0] = true;
                    Assert.assertEquals(e.getMessage().getType(), AbstractMessage.Type.HEADLINE);

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.