@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;
}

@ 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 ; }
handle the logmessages , and send them to the adeinputstreamhandlerext .
