/**
     * (Internal use only)
     */
    public void next(Message message) throws FieldNotFound, RejectLogon, IncorrectDataFormat,
            IncorrectTagValue, UnsupportedMessageType, IOException, InvalidMessage {
    	
    	if(!processMessage(message)){
    		return;
    	}

        nextQueued();
        if (isLoggedOn()) {
            next();
        }
    }
    
    private boolean processMessage(Message message) throws FieldNotFound, RejectLogon, IncorrectDataFormat,
    IncorrectTagValue, UnsupportedMessageType, IOException, InvalidMessage {

        if (!checkSessionTime()) {
            reset();
            return false;
        }

        Header header = message.getHeader();
        String msgType = header.getString(MsgType.FIELD);

        try {

            String beginString = header.getString(BeginString.FIELD);

            if (!beginString.equals(sessionID.getBeginString())) {
                throw new UnsupportedVersion();
            }

            if (msgType.equals(MsgType.LOGON)) {
                if (sessionID.isFIXT()) {
                    targetDefaultApplVerID.set(new ApplVerID(message.getString(DefaultApplVerID.FIELD)));

                } else {
                    targetDefaultApplVerID.set(MessageUtils.toApplVerID(beginString));
                }
            }

            if (dataDictionaryProvider != null) {
                DataDictionary sessionDataDictionary = dataDictionaryProvider
                        .getSessionDataDictionary(beginString);
    
                String customApplVerID = header.isSetField(CstmApplVerID.FIELD) ? header
                        .getString(CstmApplVerID.FIELD) : null;
    
                ApplVerID applVerID = header.isSetField(ApplVerID.FIELD) ? new ApplVerID(header
                        .getString(ApplVerID.FIELD)) : targetDefaultApplVerID.get();
    
                DataDictionary applicationDataDictionary = isAdminMessage(msgType)
                        ? dataDictionaryProvider.getSessionDataDictionary(beginString)
                        : dataDictionaryProvider.getApplicationDataDictionary(applVerID,
                                customApplVerID);
                
                DataDictionary.validate(message, sessionDataDictionary, applicationDataDictionary);
            }
            
            if (msgType.equals(MsgType.LOGON)) {
                nextLogon(message);
            } else if (msgType.equals(MsgType.HEARTBEAT)) {
                nextHeartBeat(message);
            } else if (msgType.equals(MsgType.TEST_REQUEST)) {
                nextTestRequest(message);
            } else if (msgType.equals(MsgType.SEQUENCE_RESET)) {
                nextSequenceReset(message);
            } else if (msgType.equals(MsgType.LOGOUT)) {
                nextLogout(message);
            } else if (msgType.equals(MsgType.RESEND_REQUEST)) {
                nextResendRequest(message);
            } else if (msgType.equals(MsgType.REJECT)) {
                nextReject(message);
            } else {
                if (!verify(message)) {
                    return false;
                }
                state.incrNextTargetMsgSeqNum();
            }
        } catch (FieldException e) {
            generateReject(message, e.getSessionRejectReason(), e.getField());
        } catch (FieldNotFound e) {
            if (sessionID.getBeginString().compareTo(FixVersions.BEGINSTRING_FIX42) >= 0
                    && message.isApp()) {
                generateBusinessReject(message,
                        BusinessRejectReason.CONDITIONALLY_REQUIRED_FIELD_MISSING, e.field);
            } else {
                if (msgType.equals(MsgType.LOGON)) {
                    getLog().onEvent("Required field missing from logon");
                    disconnect();
                } else {
                    generateReject(message, SessionRejectReason.REQUIRED_TAG_MISSING, e.field);
                }
            }
        } catch (IncorrectDataFormat e) {
            generateReject(message, SessionRejectReason.INCORRECT_DATA_FORMAT_FOR_VALUE, e.field);
        } catch (IncorrectTagValue e) {
            generateReject(message, SessionRejectReason.VALUE_IS_INCORRECT, e.field);
        } catch (InvalidMessage e) {
            getLog().onEvent("Skipping invalid message: " + e.getMessage());
        } catch (RejectLogon e) {
            String rejectMessage = e.getMessage() != null ? (": " + e.getMessage()) : "";
            getLog().onEvent("Logon rejected" + rejectMessage);
            if (e.isLogoutBeforeDisconnect()) {
                generateLogout(e.getMessage());
            }
            state.incrNextTargetMsgSeqNum();
            disconnect();
        } catch (UnsupportedMessageType e) {
            if (sessionID.getBeginString().compareTo(FixVersions.BEGINSTRING_FIX42) >= 0) {
                generateBusinessReject(message, BusinessRejectReason.UNSUPPORTED_MESSAGE_TYPE, 0);
            } else {
                generateReject(message, "Unsupported message type");
            }
        } catch (UnsupportedVersion e) {
            if (msgType.equals(MsgType.LOGOUT)) {
                nextLogout(message);
            } else {
                generateLogout("Incorrect BeginString");
                state.incrNextTargetMsgSeqNum();
                // 1d_InvalidLogonWrongBeginString.def appears to require
                // a disconnect although the C++ didn't appear to be doing it.
                // ???
                disconnect();
            }
        } catch (IOException e) {
            LogUtil.logThrowable(sessionID, "error processing message", e);
        }
        return true;
    }

    private void next(String msg) throws InvalidMessage, FieldNotFound, RejectLogon,
            IncorrectDataFormat, IncorrectTagValue, UnsupportedMessageType, IOException {
        try {
            processMessage(parseMessage(msg));
        } catch (InvalidMessage e) {
            String message = e.getMessage();
            getLog().onEvent(message);
            if (MsgType.LOGON.equals(MessageUtils.getMessageType(msg))) {
                getLog().onEvent("Logon message is not valid");
                disconnect();
            }
            throw e;
        }
    }