Cannot use ConsumerTemplate in route

[simplex-software]

Greetings,

I have the following  route:

      from(

          "file:...")

          .split(body().tokenize("\n"))

          .streaming()

          .process(new FileConsumer())

..........................................................

and the following camel context:

The FileConsumer looks like this:

public class FileConsumer implements Processor

{

  private ConsumerTemplate consumerTemplate;

  public ConsumerTemplate getConsumerTemplate()

  {

    return consumerTemplate;

  }

  public void setConsumerTemplate(ConsumerTemplate consumerTemplate)

  {

    this.consumerTemplate = consumerTemplate;

  }

.............................................

Running the route with camel:run raises the following exception:

Error occurred while running main from: org.apache.camel.spring.Main

java.lang.reflect.InvocationTargetException

     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)

     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)

     at java.lang.reflect.Method.invoke(Method.java:597)

     at org.apache.camel.maven.RunMojo$1.run(RunMojo.java:440)

     at java.lang.Thread.run(Thread.java:662)

Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'fileConsumerBean' defined in file : Error setting property values; nested exception is org.springframework.beans.NotWritablePropertyException: Invalid property 'fileConsumer' of bean class : Bean property 'fileConsumer' is not writable or has an invalid setter method. Does the parameter type of the setter match the return type of the getter?

     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1361)

     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1086)

     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:517)

     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)

     at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:291)

     at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)

     at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:288)

     at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:190)

     at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:580)

     at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:895)

     at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:425)

     at org.springframework.context.support.ClassPathXmlApplicationContext.(ClassPathXmlApplicationContext.java:93)

     at org.apache.camel.spring.Main.createDefaultApplicationContext(Main.java:186)

     at org.apache.camel.spring.Main.doStart(Main.java:140)

     at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)

     at org.apache.camel.main.MainSupport.run(MainSupport.java:140)

     at org.apache.camel.main.MainSupport.run(MainSupport.java:326)

     at org.apache.camel.spring.Main.main(Main.java:73)

     ... 6 more

Caused by: org.springframework.beans.NotWritablePropertyException: Invalid property 'fileConsumer' of bean class : Bean property 'fileConsumer' is not writable or has an invalid setter method. Does the parameter type of the setter match the return type of the getter?

     at org.springframework.beans.BeanWrapperImpl.setPropertyValue(BeanWrapperImpl.java:1024)

     at org.springframework.beans.BeanWrapperImpl.setPropertyValue(BeanWrapperImpl.java:900)

     at org.springframework.beans.AbstractPropertyAccessor.setPropertyValues(AbstractPropertyAccessor.java:76)

     at org.springframework.beans.AbstractPropertyAccessor.setPropertyValues(AbstractPropertyAccessor.java:58)

     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1358)

     ... 24 more

*************************************

However, the parametter type of the setter correctly matches the return type of the getter.

What could be wrong here ?

Many thanks in advance.

Kind regards,

Nicolas

[njiang]

Hi,

You should use "consumerTemplate" instead of  "fileConsumer".

BTW, I do know why are you using ConsumerTemplate in the processor, it looks like you should use a ProducerTemplate this time.

Willem

[simplex-software]

Hi Wilem,

Many thanks for having taken the time to answer to me. I tried reading your text several times but I failed to understand what you mean, probably because I'm not a native english speaker. So, if you could be less hermetical, it would help.

Kind regards,

Nicolas

[davsclaus]

In the XML

The property name should match the name of the getter/setter you have in the code.

[davsclaus]

And in your route you should not create the bean yourself, but refer to it by its name (eg its id) and use the bean in the DSL

.process(new FileConsumer())

should be

.beanRef("theIdOfTheBean")

or alternative

.to("bean:theIdOfTheBean")

[simplex-software]

Hi Claus,

Many thanks, but this is exactly what I have:

Kind regards,

Nicolas

[simplex-software]

Ah, okay, I understand now, many thanks and sorry for being too heavy.