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 asia.stampy.examples.client.mina.MinaAutoTerminatingClientGateway.addMessageListener()


    RawClientMinaHandler handler = new RawClientMinaHandler();
    handler.setHeartbeatContainer(heartbeatContainer);
    handler.setGateway(gateway);


    gateway.addMessageListener(new IDontNeedSecurity());


    gateway.setHandler(handler);


    return gateway;

View Full Code Here

Examples of asia.stampy.examples.client.netty.NettyAutoTerminatingClientGateway.addMessageListener()


    ClientNettyChannelHandler handler = new ClientNettyChannelHandler();
    handler.setHeartbeatContainer(heartbeatContainer);
    handler.setGateway(gateway);


    gateway.addMessageListener(new IDontNeedSecurity());


    gateway.setHandler(handler);


    return gateway;

View Full Code Here

Examples of asia.stampy.server.mina.ServerMinaMessageGateway.addMessageListener()

    handler.setHeartbeatContainer(heartbeatContainer);
    handler.setGateway(gateway);


    gateway.setHandler(handler);


    gateway.addMessageListener(new IDontNeedSecurity());


    MinaConnectResponseListener connectResponse = new MinaConnectResponseListener();
    connectResponse.setGateway(gateway);
    gateway.addMessageListener(connectResponse);

View Full Code Here

Examples of asia.stampy.server.netty.ServerNettyMessageGateway.addMessageListener()

    handler.setHeartbeatContainer(heartbeatContainer);
    handler.setGateway(gateway);


    gateway.setHandler(handler);


    gateway.addMessageListener(new IDontNeedSecurity());


    NettyConnectResponseListener connectResponse = new NettyConnectResponseListener();
    connectResponse.setGateway(gateway);
    gateway.addMessageListener(connectResponse);

View Full Code Here

Examples of co.paralleluniverse.galaxy.quasar.Messenger.addMessageListener()

    }


    private void subscribe() {
        final Messenger messenger = GlxRemoteChannel.getMessenger();
        if (topic instanceof String)
            messenger.addMessageListener((String) topic, this);
        else
            messenger.addMessageListener((Long) topic, this);
    }


    private void unsubscribe() {

View Full Code Here

Examples of co.paralleluniverse.galaxy.quasar.Messenger.addMessageListener()

    private void subscribe() {
        final Messenger messenger = GlxRemoteChannel.getMessenger();
        if (topic instanceof String)
            messenger.addMessageListener((String) topic, this);
        else
            messenger.addMessageListener((Long) topic, this);
    }


    private void unsubscribe() {
        final Messenger messenger = GlxRemoteChannel.getMessenger();
        if (topic instanceof String)

View Full Code Here

Examples of com.aelitis.azureus.core.messenger.ClientMessageContext.addMessageListener()

   */
  private void initializePlatformClientMessageContext() {
    ClientMessageContext clientMsgContext = PlatformMessenger.getClientMessageContext();
    if (clientMsgContext != null) {
      clientMsgContext.setMessageDispatcher(new MessageDispatcherSWT(clientMsgContext));
      clientMsgContext.addMessageListener(new TorrentListener());
      clientMsgContext.addMessageListener(new VuzeListener());
      clientMsgContext.addMessageListener(new DisplayListener(null));
      clientMsgContext.addMessageListener(new ConfigListener(null));
    }
    PluginInitializer.getDefaultInterface().addEventListener(new PluginEventListener() {

View Full Code Here

Examples of com.aelitis.azureus.core.messenger.ClientMessageContext.addMessageListener()

  private void initializePlatformClientMessageContext() {
    ClientMessageContext clientMsgContext = PlatformMessenger.getClientMessageContext();
    if (clientMsgContext != null) {
      clientMsgContext.setMessageDispatcher(new MessageDispatcherSWT(clientMsgContext));
      clientMsgContext.addMessageListener(new TorrentListener());
      clientMsgContext.addMessageListener(new VuzeListener());
      clientMsgContext.addMessageListener(new DisplayListener(null));
      clientMsgContext.addMessageListener(new ConfigListener(null));
    }
    PluginInitializer.getDefaultInterface().addEventListener(new PluginEventListener() {
      public void handleEvent(PluginEvent ev) {

View Full Code Here

Examples of com.aelitis.azureus.core.messenger.ClientMessageContext.addMessageListener()

    ClientMessageContext clientMsgContext = PlatformMessenger.getClientMessageContext();
    if (clientMsgContext != null) {
      clientMsgContext.setMessageDispatcher(new MessageDispatcherSWT(clientMsgContext));
      clientMsgContext.addMessageListener(new TorrentListener());
      clientMsgContext.addMessageListener(new VuzeListener());
      clientMsgContext.addMessageListener(new DisplayListener(null));
      clientMsgContext.addMessageListener(new ConfigListener(null));
    }
    PluginInitializer.getDefaultInterface().addEventListener(new PluginEventListener() {
      public void handleEvent(PluginEvent ev) {
        try {

View Full Code Here

Examples of com.aelitis.azureus.core.messenger.ClientMessageContext.addMessageListener()

    if (clientMsgContext != null) {
      clientMsgContext.setMessageDispatcher(new MessageDispatcherSWT(clientMsgContext));
      clientMsgContext.addMessageListener(new TorrentListener());
      clientMsgContext.addMessageListener(new VuzeListener());
      clientMsgContext.addMessageListener(new DisplayListener(null));
      clientMsgContext.addMessageListener(new ConfigListener(null));
    }
    PluginInitializer.getDefaultInterface().addEventListener(new PluginEventListener() {
      public void handleEvent(PluginEvent ev) {
        try {
          int type = ev.getType();

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.