Hi
Yeah use the spring / JSR standard annotations for that @Service or
whatever it was called
And then you can refer to the consumer template from the camel context
<camelContext ...>
<consumerTemplate id="myFoo"/>
<..>
@Service or whatever its named ("myFoo")
ConsumerTemplate consumer;
On Mon, Sep 21, 2009 at 4:22 PM, Charles Moulliard <[email protected]> wrote:
> Concerning the point 2)
>
> it does not work too with this syntax :
>
> �...@endpointinject()
> private ConsumerTemplate consumer;
>
> �...@endpointinject(name = "queueReportingEndpoint")
> private Endpoint endpoint;
>
>
> the following error is generated :
>
> 16:16:33,796 | ERROR | xtenderThread-56 | ContextLoaderListener
> | BundleApplicationContextListener 50 | Application context
> refresh failed
> (OsgiBundleXmlApplicationContext(bundle=com.xpectis.x3s.x3s-core,
> config=osgibundle:/META-INF/spring/*.xml))
> org.springframework.beans.factory.BeanCreationException: Error
> creating bean with name 'reportingConsumer' defined in URL
> [bundle://208.0:0/META-INF/spring/core-reporting.xml]: Initialization
> of bean failed; nested exception is
> java.lang.IllegalArgumentException: registry entry called consumer of
> type org.apache.camel.Endpoint must be specified
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:480)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409)
> at java.security.AccessController.doPrivileged(Native Method)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:380)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:264)
> at
> org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)
> at
> org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:429)
> at
> org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:728)
> at
> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.access$1600(AbstractDelegatedExecutionApplicationContext.java:69)
> at
> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:355)
> at
> org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)
> at
> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:320)
> at
> org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:136)
> at java.lang.Thread.run(Thread.java:595)
> Caused by: java.lang.IllegalArgumentException: registry entry called
> consumer of type org.apache.camel.Endpoint must be specified
> at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:242)
> at
> org.apache.camel.util.CamelContextHelper.mandatoryLookup(CamelContextHelper.java:168)
> at
> org.apache.camel.util.CamelContextHelper.getEndpointInjection(CamelContextHelper.java:213)
> at
> org.apache.camel.impl.CamelPostProcessorHelper.getEndpointInjection(CamelPostProcessorHelper.java:121)
> at
> org.apache.camel.impl.CamelPostProcessorHelper.getInjectionValue(CamelPostProcessorHelper.java:131)
> at
> org.apache.camel.spring.CamelBeanPostProcessor.injectField(CamelBeanPostProcessor.java:215)
> at
> org.apache.camel.spring.CamelBeanPostProcessor$2.doWith(CamelBeanPostProcessor.java:203)
> at
> org.springframework.util.ReflectionUtils.doWithFields(ReflectionUtils.java:523)
> at
> org.springframework.util.ReflectionUtils.doWithFields(ReflectionUtils.java:500)
> at
> org.apache.camel.spring.CamelBeanPostProcessor.injectFields(CamelBeanPostProcessor.java:199)
> at
> org.apache.camel.spring.CamelBeanPostProcessor.postProcessBeforeInitialization(CamelBeanPostProcessor.java:91)
>
> -2€/paypall account
>
>
> Charles Moulliard
> Senior Enterprise Architect
> Apache Camel Committer
>
> *****************************
> blog : http://cmoulliard.blogspot.com
>
>
>
> On Mon, Sep 21, 2009 at 3:54 PM, Claus Ibsen <[email protected]> wrote:
>> On Mon, Sep 21, 2009 at 3:46 PM, Charles Moulliard <[email protected]>
>> wrote:
>>> It works now except that I have the following error (btw, the objects
>>> posted in the JMS queue are serializable) .
>>>
>>> CaughtExceptionType:java.io.NotSerializableException,
>>> CaughtExceptionMessage:org.apache.camel.component.jms.JmsQueueEndpoint,
>>> StackTrace:java.io.NotSerializableException:
>>> org.apache.camel.component.jms.JmsQueueEndpoint
>>> at
>>> java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1081)
>>> at
>>> java.io.ObjectOutputStream.writeArray(ObjectOutputStream.java:1251)
>>> at
>>> java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1075)
>>> at
>>> java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:302)
>>> at
>>> org.apache.camel.component.bean.BeanInvocation.writeExternal(BeanInvocation.java:104)
>>> at
>>> java.io.ObjectOutputStream.writeExternalData(ObjectOutputStream.java:1310)
>>> at
>>> java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1288)
>>> at
>>> java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1079)
>>> at
>>> java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:302)
>>> at
>>> org.apache.activemq.command.ActiveMQObjectMessage.storeContent(ActiveMQObjectMessage.java:98)
>>>
>>> Why do we have to inject two times the reference of the uri, this is
>>> not so very logic ?
>>
>> You do not need to.
>>
>>>
>>> �...@endpointinject(name = "queueReportingEndpoint")
>>> private ConsumerTemplate consumer;
>>>
>>> �...@endpointinject(name = "queueReportingEndpoint")
>>> private Endpoint endpoint;
>>>
>>
>> You can do this in a single line
>>
>> �...@endpointinject(name = "queueReportingEndpoint")
>> private ConsumerTemplate consumer;
>>
>> And then just as it then knows which endpoint to consume from as you
>> specified it in the annotation
>> Exchange e = consumer.receive();
>>
>> 2)
>> But if you want to have Endpoint and ConsumerTemplate then you can do
>>
>> �...@endpointinject()
>> private ConsumerTemplate consumer;
>>
>> �...@endpointinject(name = "queueReportingEndpoint")
>> private Endpoint endpoint;
>>
>> But then you need to tell the consumer template which endpoint to use
>> Exchange e = consumer.receive(endpoint);
>>
>>
>> Deposit 5$ to my pay pall account for support :)
>>
>>
>>
>>> Regards,
>>>
>>> Charles Moulliard
>>> Senior Enterprise Architect
>>> Apache Camel Committer
>>>
>>> *****************************
>>> blog : http://cmoulliard.blogspot.com
>>>
>>>
>>>
>>> On Mon, Sep 21, 2009 at 3:14 PM, Claus Ibsen <[email protected]> wrote:
>>>> Charles you do post your problems to soon.
>>>>
>>>> The NPE is of course because ConsumerTemplate is never initialized.
>>>>
>>>> Just add @EndpointInject to it as well
>>>>
>>>> @EndpointInject
>>>> private ConsumerTemplate consumer;
>>>>
>>>>
>>>>
>>>> On Mon, Sep 21, 2009 at 3:06 PM, Charles Moulliard <[email protected]>
>>>> wrote:
>>>>> There is something strange. I receive a NPE exception at the line
>>>>> where I create an exchange from consumer :
>>>>>
>>>>> �...@endpointinject(name = "queueReportingEndpoint")
>>>>> private Endpoint endpoint;
>>>>>
>>>>> private ConsumerTemplate consumer;
>>>>>
>>>>> public List<Map<String, Object>> collectMessages() {
>>>>>
>>>>> Log.info("Endpoint : " + endpoint.getEndpointUri());
>>>>>
>>>>> Exchange exch = consumer.receive(endpoint);
>>>>>
>>>>> If I call directly consumer.receiveBody(endpoint, List.class); I have
>>>>> the same error. I tough that the problem come from the endpoint
>>>>> injection, but I have also a NPE if I use the uri of the endpoint in
>>>>> the receiveBody method
>>>>>
>>>>> Here is the trace :
>>>>>
>>>>> Time=Mon Sep 21 15:00:00 CEST 2009, calendar=null,
>>>>> previousFireTime=Mon Sep 21 14:58:00 CEST 2009,
>>>>> CamelBeanMethodName=null}, BodyType:org.quartz.JobDetail,
>>>>> Body:JobDetail
>>>>> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F2+9-18+%3F+*+MON-FRI':
>>>>> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful:
>>>>> false isVolatile: false isDurable: false requestsRecovers: false
>>>>> 15:00:00,000 | INFO | heduler_Worker-2 | x3s
>>>>> | rg.apache.camel.processor.Logger 88 | Exchange[
>>>>> , BodyType:org.quartz.JobDetail
>>>>> , Body:JobDetail
>>>>> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F2+9-18+%3F+*+MON-FRI':
>>>>> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful:
>>>>> false isVolatile: false isDurable: false requestsRecovers: false
>>>>> , CaughtExceptionType:java.lang.NullPointerException,
>>>>> CaughtExceptionMessage:null, StackTrace:java.lang.NullPointerException
>>>>> at
>>>>> com.xpectis.x3s.core.util.ReportingConsumer.collectMessages(ReportingConsumer.java:27)
>>>>>
>>>>>
>>>>> Charles Moulliard
>>>>> Senior Enterprise Architect
>>>>> Apache Camel Committer
>>>>>
>>>>> *****************************
>>>>> blog : http://cmoulliard.blogspot.com
>>>>>
>>>>>
>>>>>
>>>>> On Mon, Sep 21, 2009 at 2:12 PM, Claus Ibsen <[email protected]>
>>>>> wrote:
>>>>>> On Mon, Sep 21, 2009 at 2:05 PM, Charles Moulliard
>>>>>> <[email protected]> wrote:
>>>>>>> @EndpointInject(uri="") only accepts as parameter an uri / name or
>>>>>>> context but not a reference to a spring bean
>>>>>>>
>>>>>>
>>>>>> Its the name attribute that is the ref, maybe we should rename it :)
>>>>>>
>>>>>>
>>>>>>
>>>>>>> Charles Moulliard
>>>>>>> Senior Enterprise Architect
>>>>>>> Apache Camel Committer
>>>>>>>
>>>>>>> *****************************
>>>>>>> blog : http://cmoulliard.blogspot.com
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>> On Mon, Sep 21, 2009 at 1:59 PM, Claus Ibsen <[email protected]>
>>>>>>> wrote:
>>>>>>>> On Mon, Sep 21, 2009 at 1:55 PM, Charles Moulliard
>>>>>>>> <[email protected]> wrote:
>>>>>>>>> Sorry for my mistake.
>>>>>>>>>
>>>>>>>>> I have used @consume because it was possible to pass as a parameter
>>>>>>>>> the name of the endpoint to consume. Is there a way to do this with a
>>>>>>>>> consumer template ?
>>>>>>>>>
>>>>>>>>
>>>>>>>> You can IoC the endpoint in the bean
>>>>>>>>
>>>>>>>> @EndpointInjected(ref = "foo")
>>>>>>>> private Endpoint foo;
>>>>>>>>
>>>>>>>> but I would assume consumer template also works like producer template
>>>>>>>> with IoC
>>>>>>>> ( if not we should add it)
>>>>>>>>
>>>>>>>> @EndpointInjected(ref = "foo")
>>>>>>>> private ConsumerTemplate consumer;
>>>>>>>>
>>>>>>>>
>>>>>>>> See more
>>>>>>>> http://camel.apache.org/bean-injection.html
>>>>>>>>
>>>>>>>>> regards,
>>>>>>>>>
>>>>>>>>> Charles Moulliard
>>>>>>>>> Senior Enterprise Architect
>>>>>>>>> Apache Camel Committer
>>>>>>>>>
>>>>>>>>> *****************************
>>>>>>>>> blog : http://cmoulliard.blogspot.com
>>>>>>>>>
>>>>>>>>>
>>>>>>>>>
>>>>>>>>> On Mon, Sep 21, 2009 at 1:50 PM, Claus Ibsen <[email protected]>
>>>>>>>>> wrote:
>>>>>>>>>> On Mon, Sep 21, 2009 at 1:46 PM, Charles Moulliard
>>>>>>>>>> <[email protected]> wrote:
>>>>>>>>>>> The POJO defined in the following route consumes immediately
>>>>>>>>>>> messages
>>>>>>>>>>> posted on a queue and in consequence is not triggered by the Quartz
>>>>>>>>>>> timer
>>>>>>>>>>>
>>>>>>>>>>> <camel:from
>>>>>>>>>>> uri="quartz://x3sReporting/clientError?cron=0+0/5+9-18+?+*+MON-FRI"/>
>>>>>>>>>>> <camel:doTry>
>>>>>>>>>>> <camel:bean
>>>>>>>>>>> ref="reportingConsumer" method="collectMessages"/>
>>>>>>>>>>> ...
>>>>>>>>>>>
>>>>>>>>>>> public class ReportingConsumer {
>>>>>>>>>>>
>>>>>>>>>>> �...@consume(ref = "queueReportingEndpoint") // = x3s:report queue
>>>>>>>>>>> public List<Map<String, Object>>
>>>>>>>>>>> collectMessages(List<Map<String,
>>>>>>>>>>> Object>> received) {
>>>>>>>>>>>
>>>>>>>>>>> List<Map<String, Object>> result = new ArrayList<Map<String,
>>>>>>>>>>> Object>>();
>>>>>>>>>>>
>>>>>>>>>>> if (received != null) {
>>>>>>>>>>>
>>>>>>>>>>> Log.info("Received exchange : " +
>>>>>>>>>>> received.size());
>>>>>>>>>>> for(Map<String, Object> model : received) {
>>>>>>>>>>>
>>>>>>>>>>> Log.info("Map received : " +
>>>>>>>>>>> model.toString());
>>>>>>>>>>> // Add model received into the
>>>>>>>>>>> result output list
>>>>>>>>>>> result.add( model );
>>>>>>>>>>> }
>>>>>>>>>>> }
>>>>>>>>>>>
>>>>>>>>>>> return result;
>>>>>>>>>>> }
>>>>>>>>>>>
>>>>>>>>>>> Question : How can I avoid that the bean consumes immediately
>>>>>>>>>>> messages
>>>>>>>>>>> from the queue and wait quartz triggering ?
>>>>>>>>>>
>>>>>>>>>> You cannot as @Consume(ref = "queueReportingEndpoint") has ABSOLUTELY
>>>>>>>>>> nothing to do with quartz.
>>>>>>>>>> It creates a new event driven consumer which listen on new messages
>>>>>>>>>> arriving on that JMS queue.
>>>>>>>>>>
>>>>>>>>>> You can remove the @Consume and then let quartz invoke it from the
>>>>>>>>>> Camel route.
>>>>>>>>>>
>>>>>>>>>> And then you can in your bean use a consumer template to read
>>>>>>>>>> messages
>>>>>>>>>> from the JMS queue.
>>>>>>>>>> Now you bean is only invoked when quartz triggers.
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>>
>>>>>>>>>>> Charles Moulliard
>>>>>>>>>>> Senior Enterprise Architect
>>>>>>>>>>> Apache Camel Committer
>>>>>>>>>>>
>>>>>>>>>>> *****************************
>>>>>>>>>>> blog : http://cmoulliard.blogspot.com
>>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>> --
>>>>>>>>>> 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
>>>>>>>>
>>>>>>>
>>>>>>
>>>>>>
>>>>>>
>>>>>> --
>>>>>> 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
>>>>
>>>
>>
>>
>>
>> --
>> 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
