hmm there's no camel locks in there.
i deleted the directoyr, recreated it still doesn't work.
here's my files
package com.ccti.carnelian.ufm.routes;
import java.io.File;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultMessage;
import org.apache.commons.io.FileUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.ccti.base.camel.model.FileModel;
import com.ccti.base.camel.processors.FileWaitProcessor;
import com.ccti.base.dao.syspar.SysParDao;
public class FileRouteBuilder extends RouteBuilder {
private static final Logger logger =
LoggerFactory.getLogger(FileRouteBuilder.class);
private SysParDao sysParDao;
@Override
public void configure() throws Exception {
from("file:" + "c:/ufm/upload/" ).process(new
FileWaitProcessor()).process(new Processor() {
public void process(Exchange exchange) throws Exception {
try {
FileModel fileModel = new FileModel();
logExchangeDetails(exchange);
// kailangan ko ipa write ito sa isang directory
logger.debug("Making A copy Of File In Processed
Directory.");
String processedDirectory =
sysParDao.findValueByCd("USR082");
String inputDirectory =
sysParDao.findValueByCd("USR081");
FileUtils.copyFile(new File(inputDirectory +
exchange.getIn().getHeader("org.apache.camel.file.name")), new
File(processedDirectory + exchange.getIn().getHeader("
org.apache.camel.file.name") + "-USED"));
DefaultMessage defaultMessage = new
DefaultMessage();
fileModel.setFileName(processedDirectory +
exchange.getIn().getHeader("org.apache.camel.file.name").toString() +
"-USED");
fileModel.setCoverName(exchange.getIn().getHeader("
org.apache.camel.file.name").toString());
defaultMessage.setBody(fileModel);
exchange.setOut(defaultMessage);
logger.debug("Successfuly Copied File.");
}
catch (Exception e) {
logger.error(e.getMessage());
e.printStackTrace();
}
}
private void logExchangeDetails(Exchange exchange) {
if(logger.isDebugEnabled()) {
logger.debug(exchange.getIn() + "");
logger.debug(exchange.getIn().getClass().getName());
logger.debug(exchange.getIn().getHeader("
org.apache.camel.file.name").toString());
logger.debug(exchange.getOut() + "");
}
}
}).to("direct:processingQueue");
}
public SysParDao getSysParDao() {
return sysParDao;
}
public void setSysParDao(SysParDao sysParDao) {
this.sysParDao = sysParDao;
}
}
<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:jms="http://www.springframework.org/schema/jms";
xmlns:tx="http://www.springframework.org/schema/tx";
xmlns:camel="http://camel.apache.org/schema/spring";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms-2.5.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
">
<camel:camelContext id="camelContext">
<camel:package>com.ccti.carnelian.ufm.routes</camel:package>
<camel:jmxAgent id = "agent" disabled="true"/>
</camel:camelContext>
I will be insvesitigating also. maybe it's just a simple mistake or
something
On Thu, Jul 16, 2009 at 2:33 PM, Claus Ibsen <[email protected]> wrote:
> On Thu, Jul 16, 2009 at 8:29 AM, Carlo Camerino<[email protected]>
> wrote:
> > it doesn't even enter the filewaitprocessor
>
> Could you take a look into the c:/ufm/upload folder. There could be
> some .camelLock file lurking that blocks it.
> eg you can try removing this folder all together and create a new empty
> one.
>
>
>
> >
> > On Thu, Jul 16, 2009 at 2:26 PM, Carlo Camerino <[email protected]
> >wrote:
> >
> >> Hi,
> >>
> >> Here is my route.
> >>
> >> public void configure() throws Exception {
> >> from("file://" + "c:/ufm/upload/" +
> "?delete=true").process(new
> >> FileWaitProcessor()).process(new Processor() {
> >>
> >> public void process(Exchange exchange) throws Exception
> {
> >> try {
> >> FileModel fileModel = new FileModel();
> >> logExchangeDetails(exchange);
> >> // kailangan ko ipa write ito sa isang directory
> >> logger.debug("Making A copy Of File In Processed
> >> Directory.");
> >> String processedDirectory =
> >> sysParDao.findValueByCd("USR082");
> >> String inputDirectory =
> >> sysParDao.findValueByCd("USR081");
> >> FileUtils.copyFile(new File(inputDirectory +
> >> exchange.getIn().getHeader("org.apache.camel.file.name")), new
> >> File(processedDirectory + exchange.getIn().getHeader("
> >> org.apache.camel.file.name") + "-USED"));
> >> DefaultMessage defaultMessage = new
> >> DefaultMessage();
> >> fileModel.setFileName(processedDirectory +
> >> exchange.getIn().getHeader("org.apache.camel.file.name").toString() +
> >> "-USED");
> >>
> fileModel.setCoverName(exchange.getIn().getHeader("
> >> org.apache.camel.file.name").toString());
> >> defaultMessage.setBody(fileModel);
> >> exchange.setOut(defaultMessage);
> >> logger.debug("Successfuly Copied File.");
> >> }
> >> catch (Exception e) {
> >> logger.error(e.getMessage());
> >> e.printStackTrace();
> >> }
> >> }
> >>
> >> private void logExchangeDetails(Exchange exchange) {
> >> if(logger.isDebugEnabled()) {
> >> logger.debug(exchange.getIn() + "");
> >>
> >> logger.debug(exchange.getIn().getClass().getName());
> >> logger.debug(exchange.getIn().getHeader("
> >> org.apache.camel.file.name").toString());
> >> logger.debug(exchange.getOut() + "");
> >> }
> >> }
> >>
> >> }).to("direct:processingQueue");
> >>
> >> Thanks In Advance
> >>
> >>
> >> On Thu, Jul 16, 2009 at 1:02 PM, Claus Ibsen <[email protected]
> >wrote:
> >>
> >>> Hi
> >>>
> >>> On Thu, Jul 16, 2009 at 6:29 AM, Carlo Camerino<
> [email protected]>
> >>> wrote:
> >>> > hi,
> >>> >
> >>> > i'm currently using file component in camel 2.0-M2. I'm finding out
> that
> >>> > it's not working properly already unlike in camel 1.6 below.
> >>> > is there any changes that I need to be implemented?
> >>> >
> >>> > The same route that I used for Camel 1.5 is not working for camel
> 2.0-M2
> >>>
> >>> Camel 2 have a rewritten file component so some options in 1.5 is eg
> >>> not the same in 2.0.
> >>>
> >>>
> >>> >
> >>> > It's not getting properly from the directory that I set it to get
> from.
> >>> > Do I need to change anything?
> >>>
> >>> First you need to post what the problem is. Writing that X does not
> >>> work is not gonna help to much without
> >>> being more specific.
> >>>
> >>> And also posting your route will help.
> >>>
> >>>
> >>> >
> >>> > Should I use file2 instead?
> >>> >
> >>>
> >>> No there is no file2 as such. Its just the camel documentation being
> >>> divided into the old and the new (file2).
> >>>
> >>>
> >>>
> >>> > Carlo
> >>> >
> >>>
> >>>
> >>>
> >>> --
> >>> Claus Ibsen
> >>> Apache Camel Committer
> >>>
> >>> Open Source Integration: http://fusesource.com
> >>> Blog: http://davsclaus.blogspot.com/
> >>> Twitter: http://twitter.com/davsclaus
> >>>
> >>
> >>
> >
>
>
>
> --
> Claus Ibsen
> Apache Camel Committer
>
> Open Source Integration: http://fusesource.com
> Blog: http://davsclaus.blogspot.com/
> Twitter: http://twitter.com/davsclaus
>
