processor

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.component.file.GenericFile;
import org.apache.camel.component.file.GenericFileConverter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CompareProcessor implements Processor {
static Logger LOG = LoggerFactory.getLogger(CompareProcessor.class);
static StringBuilder sb = new StringBuilder();

public CompareProcessor() {
};

public void process(Exchange exchange) {
InputStream inputStream = null;
Message msg = exchange.getIn();
String fileName = (String) msg.getHeader("CamelFileName");
InputStream is = null;
try {
is = GenericFileConverter.genericFileToInputStream(
(GenericFile) msg.getBody(), exchange);
} catch (Exception e1) {
e1.printStackTrace();
}
BufferedReader reader = new BufferedReader(new InputStreamReader(is));
String line = null;
boolean filenotExsit = false;
// reader specify directory file
try {
inputStream = new FileInputStream(new File("end/" + fileName));
System.out.println("SSSSSSSSB:"
+ new File("end/" + fileName).getAbsolutePath());

} catch (FileNotFoundException e1) {
LOG.error("can't find the file:" + fileName +"\t" + e1.getMessage());
filenotExsit = true;
//e1.printStackTrace();
}
BufferedReader reader1 = new BufferedReader(new InputStreamReader(
inputStream));
String line1 = null;
boolean flag = true; //if true, show that there has difference between two files;
try {

int i = 0;
while (true) {
line = reader.readLine();
line1 = reader1.readLine();
i++;
if(i==1){//ignore the first line, compare from second line.
System.out.println("ignore the first line+--" + i);
continue;
}
System.out.println("+++++++++++++++++line-" + line);
System.out.println("+++++++++++++++++line1-" + line1);
if(line != null && line1 != null){
if(!line.equals(line1)){

System.out.println("+++++++++++++++++--" + i);
flag = false;
sb.append(fileName + ";");
break;
}
} else if(line!=null && line1==null){
i++;
System.out.println("+++line!=null && line1==null++--" + i);
flag = false;
sb.append(fileName + ";");
break;
} else if(line==null && line1!=null) {
flag = false;
sb.append(fileName + ";");
break;
} else if(line==null && line1==null){
flag = true;
break;
}
}
    inputStream.close();
is.close();
} catch (IOException e) {
e.printStackTrace();
}
if (!flag) {
System.out.println("++++++++++++++++difference=" + msg);
} else {
System.out.println("@@@@@@@@@@@no difference=");
}
LOG.info("processing:", exchange);
System.out.println(sb.toString());

}

}