question: @ Override protected boolean doControlLogic ( ) throws AdeException { IMessageInstanceTarget miTarget = getMITarget ( ) ; AdeInputStreamHandlerExt streamHandler ; StreamHandlerExtFactory streamHandlerExtFactory = new StreamHandlerExtFactory ( ) ; streamHandler = streamHandlerExtFactory . getStreamHandler ( m_osType , m_adeExtProperties ) ; if ( streamHandler == null ) { throw new AdeInternalException ( "Stream Handler does not exist for operating system type " + m_osType ) ; } streamHandler . addTarget ( miTarget ) ; streamHandler . beginOfStream ( ) ; streamHandler . sendDiscontinuitySeperator ( ) ; if ( m_inputSource == INPUT_SOURCE . LOGDIR ) { for ( File file : m_inputDir . listFiles ( getFilenameFilter ( ) ) ) { streamHandler . incomingStreamFromFile ( file ) ; } } else if ( m_inputSource == INPUT_SOURCE . LOGFILE ) { streamHandler . incomingStreamFromFile ( m_inputFile ) ; } else { streamHandler . incomingStreamFromSTDIN ( ) ; } streamHandler . endOfStream ( ) ; String lastNewlySeenSourceId = m_adeExtProperties . getLastNewlySeenSourceId ( ) ; if ( lastNewlySeenSourceId != null ) { RuntimeModelDataManager runtimeModelDataManager = new RuntimeModelDataManager ( ) ; runtimeModelDataManager . writeModelDataToFile ( lastNewlySeenSourceId ) ; } return true ; }
target:  Handle the logMessages, and send them to the AdeInputStreamHandlerExt. 