Examples of com.nokia.dempsy.messagetransport.Listener.onMessage()

com.nokia.dempsy.messagetransport.Listener.onMessage()

Method that accepts the callback for received messages. Given that the transport is responsible for managing threads, the transport will also let the Listener implementation know if it should make every effort to handle the request or if it should "fail-fast."

fail-fast means that the Listener should not attempt to handle a request if any blocking is required. In cases where the Listener determines there is going to be a delay in processing the request it should simple return 'false' as an indication that the message was not handled and allow the transport implementation to deal with it.

@param messageBytes The message bytes received @throws MessageTransportException

         try
         {
            byte[] val = destination.queue.take();
            Listener curListener = listener.get();
            
            boolean messageSuccess = curListener == null ? false : curListener.onMessage(val, failFast);
            if (overflowHandler != null && !messageSuccess)
               overflowHandler.overflow(val);
         }
         catch (InterruptedException ie)
         {

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.