java/protoCtrl/src/main/java/com/pravala/protocol/ctrl/SocketMessageManager.java
private void dispatchDirectly ( Message baseMessage, boolean onlyIndependentUpdates )
    {
        final Integer msgType = baseMessage.getType();

        Log.v ( TAG, "Attempting to decode the message into a derived type; Type: " + msgType );

        synchronized ( messageHandlers )
        {
            final ProtocolMessageHandler msgHandler = messageHandlers.get ( msgType );

            if ( msgHandler == null )
            {
                Log.w ( TAG, "There is no handler set for message type " + msgType
                           + "; Ignoring" );
                return;
            }

            if ( onlyIndependentUpdates && msgHandler.deliverEntireSimpleSubscriptionResponse() )
            {
                Log.d ( TAG, "Message handler for type " + msgType
                           + " wants entire SimpleSubscriptionResponse message; "
                           + "Skipping individual update delivery" );
                return;
            }

            try
            {
                msgHandler.handleMessage ( baseMessage );
            }
            catch ( CodecException e )
            {
                Log.e ( TAG, "Protocol.CodecException while handling a message type "
                           + msgType + "; Error: " + e );
            }
        }
    }
/**
     * Dispatches a message. Doesn't care whether it is a SimpleSubscriptionResponse.
     * @param baseMessage The message to dispatch.
     * @param onlyIndependentUpdates If set to true, this message will be delivered only
     *                               if handler's deliverEntireSimpleSubscriptionResponse()
     *                               method returns false.
     */
Dispatches a message. Doesn't care whether it is a SimpleSubscriptionResponse.
@param baseMessage The message to dispatch.
@param onlyIndependentUpdates If set to true, this message will be delivered only
if handler's deliverEntireSimpleSubscriptionResponse()
method returns false.
Dispatches a message . Doesn ' t care whether it is a SimpleSubscriptionResponse . @param baseMessage The message to dispatch . @param onlyIndependentUpdates If set to true this message will be delivered only if handler ' s deliverEntireSimpleSubscriptionResponse () method returns false .
private void dispatchDirectly ( Message baseMessage, boolean onlyIndependentUpdates )
    {
        final Integer msgType = baseMessage.getType();
        Log.v ( TAG, "Attempting to decode the message into a derived type; Type: " + msgType );
        synchronized ( messageHandlers )
        {
            final ProtocolMessageHandler msgHandler = messageHandlers.get ( msgType );
            if ( msgHandler == null )
            {
                Log.w ( TAG, "There is no handler set for message type " + msgType
                           + "; Ignoring" );
                return;
            }
            if ( onlyIndependentUpdates && msgHandler.deliverEntireSimpleSubscriptionResponse() )
            {
                Log.d ( TAG, "Message handler for type " + msgType
                           + " wants entire SimpleSubscriptionResponse message; "
                           + "Skipping individual update delivery" );
                return;
            }
            try
            {
                msgHandler.handleMessage ( baseMessage );
            }
            catch ( CodecException e )
            {
                Log.e ( TAG, "Protocol.CodecException while handling a message type "
                           + msgType + "; Error: " + e );
            }
        }
    }
private void dispatchDirectly ( Message baseMessage , boolean onlyIndependentUpdates ) { final Integer msgType = baseMessage . getType ( ) ; Log . v ( TAG , "Attempting to decode the message into a derived type; Type: " + msgType ) ; synchronized ( messageHandlers ) { final ProtocolMessageHandler msgHandler = messageHandlers . get ( msgType ) ; if ( msgHandler == null ) { Log . w ( TAG , "There is no handler set for message type " + msgType + "; Ignoring" ) ; return ; } if ( onlyIndependentUpdates && msgHandler . deliverEntireSimpleSubscriptionResponse ( ) ) { Log . d ( TAG , "Message handler for type " + msgType + " wants entire SimpleSubscriptionResponse message; " + "Skipping individual update delivery" ) ; return ; } try { msgHandler . handleMessage ( baseMessage ) ; } catch ( CodecException e ) { Log . e ( TAG , "Protocol.CodecException while handling a message type " + msgType + "; Error: " + e ) ; } } }
Dispatches a message.
Dispatches a message .