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.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()


    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.muse.ws.notification.NotificationConsumer.addMessageListener()

        
        //
        // register for messages so we can add them to the data store
        //
        NotificationConsumer wsn = (NotificationConsumer)getResource().getCapability(WsnConstants.CONSUMER_URI);
        wsn.addMessageListener(this);
    }
    
    public void process(NotificationMessage message) 
        throws SoapFault
    {

View Full Code Here

Examples of org.apache.openejb.jee.MessageAdapter.addMessageListener()


        Connector connector = new Connector("email-ra");
        ResourceAdapter adapter = connector.setResourceAdapter(new ResourceAdapter(EmailResourceAdapter.class));
        InboundResource inbound = adapter.setInboundResourceAdapter(new InboundResource());
        MessageAdapter messageAdapter = inbound.setMessageAdapter(new MessageAdapter());
        MessageListener listener = messageAdapter.addMessageListener(new MessageListener(EmailConsumer.class, EmailAccountInfo.class));
        listener.getActivationSpec().addRequiredConfigProperty("address");
        app.getResourceModules().add(new ConnectorModule(connector));


        EjbJar ejbJar = new EjbJar();
        ejbJar.addEnterpriseBean(new MessageDrivenBean(EmailBean.class));

View Full Code Here

Examples of org.apache.openejb.jee.MessageAdapter.addMessageListener()

        }


        if (messageListener == null) {
          Class<?>[] listeners = activationAnnotation.messageListeners();
          for (Class<?> listener : listeners) {
            messageAdapter.addMessageListener(new MessageListener(listener.getName(), cls.getName()));
          }
        }
      }


          classes = finder.findAnnotatedClasses(AdministeredObject.class);

View Full Code Here

Examples of org.apache.openejb.jee.MessageAdapter.addMessageListener()

                }


                if (messageListener == null) {
                    final Class<?>[] listeners = activationAnnotation.messageListeners();
                    for (final Class<?> listener : listeners) {
                        messageAdapter.addMessageListener(new MessageListener(listener.getName(), cls.getName()));
                    }
                }
            }


            classes = finder.findAnnotatedClasses(AdministeredObject.class);

View Full Code Here

Examples of org.apache.openejb.jee.MessageAdapter.addMessageListener()

        Connector connector = new Connector("email-ra");
        ResourceAdapter adapter = new ResourceAdapter(EmailResourceAdapter.class);
        connector.setResourceAdapter(adapter);
        InboundResourceadapter inbound = adapter.setInboundResourceAdapter(new InboundResourceadapter());
        MessageAdapter messageAdapter = inbound.setMessageAdapter(new MessageAdapter());
        MessageListener listener = messageAdapter.addMessageListener(new MessageListener(EmailConsumer.class, EmailAccountInfo.class));
        listener.getActivationSpec().addRequiredConfigProperty("address");
        app.getConnectorModules().add(new ConnectorModule(connector));


        EjbJar ejbJar = new EjbJar();
        ejbJar.addEnterpriseBean(new MessageDrivenBean(EmailBean.class));

View Full Code Here

Examples of org.apache.openejb.jee.MessageAdapter.addMessageListener()

        Connector connector = new Connector("email-ra");
        ResourceAdapter adapter = new ResourceAdapter(QuartzResourceAdapter.class);
        connector.setResourceAdapter(adapter);
        InboundResourceadapter inbound = adapter.setInboundResourceAdapter(new InboundResourceadapter());
        MessageAdapter messageAdapter = inbound.setMessageAdapter(new MessageAdapter());
        MessageListener listener = messageAdapter.addMessageListener(new MessageListener(Job.class, JobSpec.class));
        listener.getActivationSpec().addRequiredConfigProperty("cronExpression");
        app.getConnectorModules().add(new ConnectorModule(connector));


        EjbJar ejbJar = new EjbJar();
        ejbJar.addEnterpriseBean(new MessageDrivenBean(CronBean.class));

View Full Code Here

Examples of org.apache.openejb.jee.MessageAdapter.addMessageListener()

        }


        if (messageListener == null) {
          Class<?>[] listeners = activationAnnotation.messageListeners();
          for (Class<?> listener : listeners) {
            messageAdapter.addMessageListener(new MessageListener(listener.getName(), cls.getName()));
          }
        }
      }


          classes = finder.findAnnotatedClasses(AdministeredObject.class);

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.