Examples of MessageListener

Examples of javax.jms.MessageListener

800
801
802
803
804
805
806
807
808
809
810
   {
      if (trace) { log.trace("setMessageListener()"); }
     
      MethodInvocation mi = (MethodInvocation)invocation;
     
      MessageListener listener = (MessageListener)mi.getArguments()[0];
     
      if (listener == null)
      {
         throw new IllegalStateException("Cannot set a null MessageListener on the session");
      }
View Full Code Here

Examples of javax.jms.MessageListener

474
475
476
477
478
479
480
481
482
483
484
   {
      JBossConnectionFactory cf1 = (JBossConnectionFactory)ic[1].lookup("/ConnectionFactory");
      Connection conn1 = cf1.createConnection();
      Session sess1 = conn1.createSession(false, Session.CLIENT_ACKNOWLEDGE);
      MessageConsumer cons1 = sess1.createConsumer(queue[1]);
      cons1.setMessageListener(new MessageListener() {
         public void onMessage(Message m)
         {
            try
            {
               log.error("receiving " + m);
View Full Code Here

Examples of listeners.MessageListener

116
117
118
119
120
121
122
123
124
125
126
          ListenerManager<? extends PircBotX> l = bot.getListenerManager();
          l.addListener(conndat);
          l.addListener(new RoomListener(nc));
          l.addListener(new ServerListener(nc));
          l.addListener(new UserListener(nc));
          l.addListener(new MessageListener(nc));
          l.addListener(new ScriptListener(nc));
          l.addListener(new DisconnectListener(nc));
          // connecting to server
          try {
            attemptToConnect(cs);
View Full Code Here

Examples of net.rim.device.api.io.messaging.MessageListener

231
232
233
234
235
236
237
238
239
240
241
            nonBlockRecvDest =
                    (NonBlockingReceiverDestination) DestinationFactory
                            .getReceiverDestination(URI.create(uriStr));
            if (nonBlockRecvDest == null) // Not registered yet
            {
                final MessageListener responseListener =
                        new DestinationListener("NonBlockingReceiverBES", true);

                // Prepare the in-bound destination for incoming messages
                // (BES/http)
                final InboundDestinationConfiguration config =
View Full Code Here

Examples of net.sf.myway.gps.garmin.unit.MessageListener

45
46
47
48
49
50
51
52
53
54
55
  public GarminSerialDownloadHandler(final ProtocolListener unit, final ProtocolFinder finder,
    final InputStream gpsInputStream, final SerialPort serialPort) {
    try {
      _reader = new SerialMessageReader(gpsInputStream);
      serialPort.addEventListener(_reader);
      _reader.addMessageListener(new MessageListener() {
        @Override
        public void messageReceived(final GarminMessage m) {
          _log.info("received " + m);
          if (_currentProtocol == null)
            _currentProtocol = finder.findProtocol(m);
View Full Code Here

Examples of net.sf.saxon.s9api.MessageListener

55
56
57
58
59
60
61
62
63
64
65
                                       new XdmAtomicValue(entry.getValue()));
                }

               
                trans.setMessageListener(
                   new MessageListener(){
                       @Override
                       public void message(XdmNode xn, boolean bln, SourceLocator sl) {
                            String msg = "[XSLT MSG] " + xn.getStringValue();
                            updateMessage(msg);
                       }
View Full Code Here

Examples of nu.fw.jeti.events.MessageListener

136
137
138
139
140
141
142
143
144
145
146
147
148
149
  }
 
  /*-------------------------------Message-------------------------*/
  private void message(Message message)
  {
    MessageListener messageListener = backend.getMessageListener(message.getFrom());
    if(messageListener != null)
    {
      messageListener.message(message);
       return;
    }
   
    if (message.getBody() != null || message.getType().equals("groupchat"))
    {
View Full Code Here

Examples of org.apache.catalina.cluster.MessageListener

527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
                        log.warn("Context manager doesn't exist:" + ctxname);
                }//end if
            }  else {
                //invoke all the listeners
                for ( int i=0; i<clusterListeners.size(); i++ ) {
                    MessageListener listener = (MessageListener)clusterListeners.elementAt(i);
                    if ( myobj!=null &&
                         myobj instanceof ClusterMessage &&
                         listener.accept((ClusterMessage)myobj) ) {
                        listener.messageReceived((ClusterMessage)myobj);
                    }//end if
                   
                }//for
            }//end if
               
View Full Code Here

Examples of org.apache.catalina.tribes.MessageListener

99
100
101
102
103
104
105
106
107
108
            if (aCluster instanceof SimpleTcpCluster) {
                // Store nested <Listener> elements
                LifecycleListener listeners[] = ((SimpleTcpCluster)cluster).findLifecycleListeners();
                storeElementArray(aWriter, indent, listeners);
                // Store nested <ClusterListener> elements
                MessageListener mlisteners[] = ((SimpleTcpCluster)cluster).findClusterListeners();
                storeElementArray(aWriter, indent, mlisteners);
            }           
        }
    }
View Full Code Here

Examples of org.apache.helix.MessageListener

165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
                                                 changeContext);

      }
      else if (_changeType == MESSAGE)
      {
        MessageListener messageListener = (MessageListener) _listener;
        subscribeForChanges(changeContext, _path, true, false);
        String instanceName = PropertyPathConfig.getInstanceNameFromPath(_path);
        List<Message> messages =
            _accessor.getChildValues(keyBuilder.messages(instanceName));

        messageListener.onMessage(instanceName, messages, changeContext);

      }
      else if (_changeType == MESSAGES_CONTROLLER)
      {
        MessageListener messageListener = (MessageListener) _listener;
        subscribeForChanges(changeContext, _path, true, false);
        List<Message> messages =
            _accessor.getChildValues(keyBuilder.controllerMessages());

        messageListener.onMessage(_manager.getInstanceName(), messages, changeContext);

      }
      else if (_changeType == EXTERNAL_VIEW)
      {
        ExternalViewChangeListener externalViewListener =
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.