public void configure() {
	
                 from("file:/home/admin/kgw/input?noop=true").process(new Processor() {
			
			 @Override
			public void process(Exchange exchange) throws Exception {
				 Object fileName = exchange.getIn().getHeader("CamelFileName");
				 exchange.getIn().setBody(fileName+"\n");
				System.out.println(fileName);
			}
		}).to("file:/home/admin/kgw/?fileName=fileContainer.txt&fileExist=Append");

@Component
public class MyRoute extends RouteBuilder {
	@Autowired
	private MyNotifer eventHandler;

	public void configure() {
		 getContext().getManagementStrategy().addEventNotifier(eventHandler);
                 from("file:/home/admin/kgw/input?noop=true&idempotent=false&delay=2000").stop(); 
	}
}

@Component
public class MyNotifer extends EventNotifierSupport{

	@Autowired
	private ImgFileWatcher fileWatcher;
	
    public void notify(EventObject event) throws Exception {
    	 if(event instanceof ExchangeCreatedEvent){
    		 ExchangeCreatedEvent createdEvent = (ExchangeCreatedEvent) event;
    		 Message mes = createdEvent.getExchange().getIn();
    		 if(true){
    			 fileWatcher.contentChanged();
    		 }
    	 }
 
    }
 
    public boolean isEnabled(EventObject event) {
        return true;
    }
}

public interface ImgFileWatcher {
	public void contentChanged();
}