Re: ConsumerTemplate not finishing?
Hi
Ah I took a look at your code and of course you have a catch-22 situation.
You consume a file and want it as a File instance (which is just a
handle for a file). and then you want that file deleted.
This means your file handle would point to a deleted file.
What you could do is to return the file as a String which means the
content of the file is read into memory.
Then Camel could delete the file.
On Fri, Aug 20, 2010 at 4:15 PM, Andreas Asmuss andreasasm...@gmail.com wrote:
Hi
I have a route where I call this bean. The consumer gets the file and
everything is OK except the file is not deleted. There is also a .camelLock
file which is left behind at every run. So isn't the consumer finishing up,
or what could be wrong?
public class CustomEnricher {
public void enrich(Message m, @XPath(/root/rsp/text()) String path,
CamelContext ctx) {
ConsumerTemplate consumer = ctx.createConsumerTemplate();
File file =
consumer.receiveBody(file:data?delete=truefileName= + path,
File.class);
m.setHeader(newFileName, file.getName());
m.setBody(file);
}
}
--
View this message in context:
http://camel.465427.n5.nabble.com/ConsumerTemplate-not-finishing-tp2642233p2642233.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
Re: Camel-QuickFIX jar issues
Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel-QuickFIX jar issues
Charles, What is the status of the camel-quickfix component? Is it fit for production? Is it being used in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: PoolSize on from()
Hi, I think one way of doing this is to increase the maxPoolSize for the configured ThreadPoolProfile. For example: getContext().getExecutorServiceStrategy().getDefaultThreadPoolProfile().setMaxPoolSize(30); Regards, /Daniel 2010/9/8 Ron Smith ronsmit...@gmail.com I have my RouteBuilder doing this: from(tibco) .threads(readerThreads) .to(direct:localqueue); from(direct:localqueue) .threads(processThreads) .bean(MyParser.class, parseMessage) .bean(MyPersistor.class, persistRecord); If I set processThread 20, I get the following exception: org.apache.camel.FailedToCreateRouteException: Failed to create route route2 at: Threads[[Bean[com.sabre.clr.subscriber.metrics.MetricsParser], Bean[com.sabre.clr.subscriber.metrics.MetricsPersistor]]] in route: Route[[From[direct://metrics]] - [Threads[[Bean[com.sabre.c... because of MaxPoolSize must be = corePoolSize, was 20 = 25 I have found some docs and examples for setting a poolsize on a toAsync() method call but nothing about setting the poolsize on a from() method call. How do I fix this? Also, it needs to be done in real code, not in some XML file.
Re: Camel-QuickFIX jar issues
I have used it to create a product for a client but due to lack of client interested to buy the product, the project has not been moved into production. On Wed, Sep 8, 2010 at 9:18 AM, Bengt Rodehav be...@rodehav.com wrote: Charles, What is the status of the camel-quickfix component? Is it fit for production? Is it being used in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel-QuickFIX jar issues
OK - I had a similar situation last year when doing my own camel/fix component. I certified the application but never got it into production. Would you say that the camel-quickfix component is fit for production even if it's not yet in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com I have used it to create a product for a client but due to lack of client interested to buy the product, the project has not been moved into production. On Wed, Sep 8, 2010 at 9:18 AM, Bengt Rodehav be...@rodehav.com wrote: Charles, What is the status of the camel-quickfix component? Is it fit for production? Is it being used in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel-QuickFIX jar issues
camel is ready for production, so you can use it for your project. Some improvements could be made on the component camel-quickfix/j but I'm really sure that we should not modify how camel is connected to quickfix/j. On Wed, Sep 8, 2010 at 10:21 AM, Bengt Rodehav be...@rodehav.com wrote: OK - I had a similar situation last year when doing my own camel/fix component. I certified the application but never got it into production. Would you say that the camel-quickfix component is fit for production even if it's not yet in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com I have used it to create a product for a client but due to lack of client interested to buy the product, the project has not been moved into production. On Wed, Sep 8, 2010 at 9:18 AM, Bengt Rodehav be...@rodehav.com wrote: Charles, What is the status of the camel-quickfix component? Is it fit for production? Is it being used in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to change directory while using sftp component
Which version of Camel are you using? Try using the 2.5 versions as we have changed how the FTP component scan for files. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-change-directory-while-using-sftp-component-tp2806817p2807611.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel-QuickFIX jar issues
Sounds very good - I'll take a look at it in the near future. Thanks, /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com camel is ready for production, so you can use it for your project. Some improvements could be made on the component camel-quickfix/j but I'm really sure that we should not modify how camel is connected to quickfix/j. On Wed, Sep 8, 2010 at 10:21 AM, Bengt Rodehav be...@rodehav.com wrote: OK - I had a similar situation last year when doing my own camel/fix component. I certified the application but never got it into production. Would you say that the camel-quickfix component is fit for production even if it's not yet in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com I have used it to create a product for a client but due to lack of client interested to buy the product, the project has not been moved into production. On Wed, Sep 8, 2010 at 9:18 AM, Bengt Rodehav be...@rodehav.com wrote: Charles, What is the status of the camel-quickfix component? Is it fit for production? Is it being used in production? /Bengt 2010/9/8 Charles Moulliard cmoulli...@gmail.com Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
Network of Brokers, Consumers not getting messages from queue
Hi,
I have followed the article on activemq website on how to set up network of
brokers.
My brokers are able to talk to themselves using the
DiscoveryNetworkConnector.
Below is the output of my activemq log:
Network connection between vm://default#16 and
tcp:///broker2ip:61616(default) has been established.
However, I cant receive messages send from borker1 (tcp://localhost:61616)
to broker2ip (which the consumer is conencted).
Why is that?
Here is my producer client config
bean id=jmsConnectionFactory
class=org.apache.activemq.ActiveMQConnectionFactory
property name=alwaysSessionAsync value=false/
property name=alwaysSyncSend value=true/
property
name=brokerURLvalue${local-broker-url}/value/property
property name=clientID value=/
property name=closeTimeout value=15000/
property name=copyMessageOnSend value=true/
property name=disableTimeStampsByDefault value=false/
property name=dispatchAsync value=false/
property name=objectMessageSerializationDefered
value=false/
property name=optimizeAcknowledge value=false/
property name=optimizedMessageDispatch value=true/
property name=password value=/
property name=producerWindowSize value=0/
property name=statsEnabled value=false/
property name=useAsyncSend value=false/
property name=useCompression value=false/
property name=useRetroactiveConsumer value=false/
property name=userName value=/
property name=watchTopicAdvisories value=true/
property name=sendTimeout value=0/
/bean
bean id=jmsConfig
class=org.apache.camel.component.jms.JmsConfiguration
property name=connectionFactory ref=jmsConnectionFactory/
property name=concurrentConsumers
value=${jms-concurrent-consumers}/
property name=requestTimeout value=${jms-request-timeout}/
property name=timeToLive value=${jms-request-timeout}/
property name=deliveryPersistent value=true/
property name=explicitQosEnabled value=true/
property name=priority value=${jms-message-priority}/
property name=acceptMessagesWhileStopping value=false/
/bean
bean id=jms class=org.apache.camel.component.jms.JmsComponent
property name=configuration ref=jmsConfig/
/bean
and this is how I create my endpoint in camelcontext
endpoint id=jmsEndpoint
uri=jms:queue:${queue}?exchangePattern=InOutreplyTo=queue:${queue}Response/
and here is my consumer client config
bean id=jmsConnectionFactory
class=org.apache.activemq.ActiveMQConnectionFactory
property name=alwaysSessionAsync value=false/
property name=alwaysSyncSend value=true/
property
name=brokerURLvalue${local-broker-url}/value/property
property name=clientID value=/
property name=closeTimeout value=15000/
property name=copyMessageOnSend value=true/
property name=disableTimeStampsByDefault value=false/
property name=dispatchAsync value=false/
property name=objectMessageSerializationDefered
value=false/
property name=optimizeAcknowledge value=false/
property name=optimizedMessageDispatch value=true/
property name=password value=/
property name=producerWindowSize value=0/
property name=statsEnabled value=false/
property name=useAsyncSend value=false/
property name=useCompression value=false/
property name=useRetroactiveConsumer value=false/
property name=userName value=/
property name=watchTopicAdvisories value=true/
property name=sendTimeout value=0/
/bean
bean id=jmsConfig
class=org.apache.camel.component.jms.JmsConfiguration
property name=connectionFactory ref=jmsConnectionFactory/
property name=concurrentConsumers
value=${jms-concurrent-consumers}/
property name=requestTimeout value=${jms-request-timeout}/
property name=timeToLive value=${jms-request-timeout}/
property name=deliveryPersistent value=true/
property name=explicitQosEnabled value=true/
property name=priority value=${jms-message-priority}/
property name=acceptMessagesWhileStopping value=false/
/bean
bean id=jms class=org.apache.camel.component.jms.JmsComponent
property name=configuration ref=jmsConfig/
/bean
and this is how I create my endpoint in camelcontext
endpoint id=jmsEndpoint
Re: Network of Brokers, Consumers not getting messages from queue
Hi,
Can you please post your message into the Activemq forum as this question is
not relevant for camel
remar k : Check using ant script of activemq (that you will find in the
example directory) that you can produce messages on one br1 and consume them
on another broker br2.
Regards,
Charles
On Wed, Sep 8, 2010 at 2:25 PM, Naira Kobo lekkie.ay...@gmail.com wrote:
Hi,
I have followed the article on activemq website on how to set up network of
brokers.
My brokers are able to talk to themselves using the
DiscoveryNetworkConnector.
Below is the output of my activemq log:
Network connection between vm://default#16 and
tcp:///broker2ip:61616(default) has been established.
However, I cant receive messages send from borker1 (tcp://localhost:61616)
to broker2ip (which the consumer is conencted).
Why is that?
Here is my producer client config
bean id=jmsConnectionFactory
class=org.apache.activemq.ActiveMQConnectionFactory
property name=alwaysSessionAsync value=false/
property name=alwaysSyncSend value=true/
property
name=brokerURLvalue${local-broker-url}/value/property
property name=clientID value=/
property name=closeTimeout value=15000/
property name=copyMessageOnSend value=true/
property name=disableTimeStampsByDefault value=false/
property name=dispatchAsync value=false/
property name=objectMessageSerializationDefered
value=false/
property name=optimizeAcknowledge value=false/
property name=optimizedMessageDispatch value=true/
property name=password value=/
property name=producerWindowSize value=0/
property name=statsEnabled value=false/
property name=useAsyncSend value=false/
property name=useCompression value=false/
property name=useRetroactiveConsumer value=false/
property name=userName value=/
property name=watchTopicAdvisories value=true/
property name=sendTimeout value=0/
/bean
bean id=jmsConfig
class=org.apache.camel.component.jms.JmsConfiguration
property name=connectionFactory ref=jmsConnectionFactory/
property name=concurrentConsumers
value=${jms-concurrent-consumers}/
property name=requestTimeout value=${jms-request-timeout}/
property name=timeToLive value=${jms-request-timeout}/
property name=deliveryPersistent value=true/
property name=explicitQosEnabled value=true/
property name=priority value=${jms-message-priority}/
property name=acceptMessagesWhileStopping value=false/
/bean
bean id=jms class=org.apache.camel.component.jms.JmsComponent
property name=configuration ref=jmsConfig/
/bean
and this is how I create my endpoint in camelcontext
endpoint id=jmsEndpoint
uri=jms:queue:${queue}?exchangePattern=InOutreplyTo=queue:${queue}Response/
and here is my consumer client config
bean id=jmsConnectionFactory
class=org.apache.activemq.ActiveMQConnectionFactory
property name=alwaysSessionAsync value=false/
property name=alwaysSyncSend value=true/
property
name=brokerURLvalue${local-broker-url}/value/property
property name=clientID value=/
property name=closeTimeout value=15000/
property name=copyMessageOnSend value=true/
property name=disableTimeStampsByDefault value=false/
property name=dispatchAsync value=false/
property name=objectMessageSerializationDefered
value=false/
property name=optimizeAcknowledge value=false/
property name=optimizedMessageDispatch value=true/
property name=password value=/
property name=producerWindowSize value=0/
property name=statsEnabled value=false/
property name=useAsyncSend value=false/
property name=useCompression value=false/
property name=useRetroactiveConsumer value=false/
property name=userName value=/
property name=watchTopicAdvisories value=true/
property name=sendTimeout value=0/
/bean
bean id=jmsConfig
class=org.apache.camel.component.jms.JmsConfiguration
property name=connectionFactory ref=jmsConnectionFactory/
property name=concurrentConsumers
value=${jms-concurrent-consumers}/
property name=requestTimeout value=${jms-request-timeout}/
property name=timeToLive value=${jms-request-timeout}/
property name=deliveryPersistent value=true/
property name=explicitQosEnabled value=true/
property
Can we use camel-ftp component as a ftp server
Hi, Can we use camel-ftp component as a ftp server ? Regards, Charles Moulliard Senior Enterprise Architect (J2EE, .NET, SOA) Apache Camel - Karaf - ServiceMix Committer ~~~ Blog : http://cmoulliard.blogspot.com | Twitter : http://twitter.com/cmoulliard Linkedin : http://www.linkedin.com/in/charlesmoulliard | Skype: cmoulliard
Re: Can we use camel-ftp component as a ftp server
Hi, Not sure why this would be compelling...? Is there some wrinkle that we could add here. Hmm, maybe a facade to fool a client into thinking it is talking to a FTP Server but in reality is a Camel Endpoint looking into a directory structure... ;). Interesting...Should be pretty straightforward to implement, I think. The value is debatable. Cheers, Ashwin... - - Ashwin Karpe Apache Camel Committer Sr Principal Consultant FUSESource (a Progress Software Corporation subsidiary) http://fusesource.com http://fusesource.com Blog: http://opensourceknowledge.blogspot.com http://opensourceknowledge.blogspot.com - -- View this message in context: http://camel.465427.n5.nabble.com/Can-we-use-camel-ftp-component-as-a-ftp-server-tp2807922p2807982.html Sent from the Camel - Users mailing list archive at Nabble.com.
ActiveMQ Component: connection pooling
hi, on http://camel.apache.org/activemq.html section 'Using connection pooling' the following bean definitions are displayed: bean id=jmsConfig class=org.apache.camel.component.jms.JmsConfiguration ... /beans bean id=activemq class=org.apache.activemq.camel.component.ActiveMQComponent property name=configuration ref=jmsConfig/ /bean i followed the example but spring throws this exception: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'activemq' defined ... java.lang.IllegalArgumentException: Cannot convert value of type [org.apache.camel.component.jms.JmsConfiguration] to required type [org.apache.activemq.camel.component.ActiveMQConfiguration] for property 'configuration': no matching editors or conversion strategy found question: am i missing something? activemq-core-5.4.0.jar camel-core-2.2.0.jar camel-spring-2.2.0.jar camel-jms-2.2.0.jar my spring.xml starts with ?xml version=1.0 encoding=UTF-8? beans xmlns=http://www.springframework.org/schema/beans; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation= http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd; ... thanks, patrick
InterceptionStrategy: target vs nextTarget (camel 2.3.0)
I'm implementing a global InterceptStrategy that is supposed to wrap only
some of the processors (in particular I'm interested in the processors that
implement particular interface).
When debugging my strategy, I noticed that in most cases the *target *object
does not contain the actual object I'm interested in (e.g. more often I get
TraceInterceptor that wraps the real object),while *nextTarget *contains the
processor that I actually want to wrap.
From the docs I can see the following:
* @param targetthe processor to be wrapped
* @param nextTargetthe next processor to be routed to
Could someone clarify the meaning of nextTarget?
In my implementation I had to do the following (based on the source of some
interception strategies):
// prefer next target over target as next target is the real target
Processor interceptedProcessor = nextTarget != null ? nextTarget :
target;
// Intercept Dharma Process
if(com.my.company.Event.class.isAssignableFrom(interceptedProcessor.getClass()))
{
// Wrap the interceptedProcessor here, and return it
}
return target;
Does this code make sense, or am I doing something weird here? The code
seems to perform what I need, though, it seems to me that the intention of
this interface is to wrap the target and not the nextTarget.
Thank you for your help.
Ilya
JAXB Unmarshalling - DataFormat error ... suggestions?
I am trying to get basic unmarshalling to work. The samples show this (and I am trying it verbatim, but changed the package ref), but I get the following error. camelContext id=camel xmlns=http://camel.apache.org/schema/spring; dataFormats jaxb id=myJaxb prettyPrint=true contextPath=org.apache.camel.example/ /dataFormats route from uri=direct:start/ marshal ref=myJaxb/ to uri=direct:marshalled/ /route route from uri=direct:marshalled/ unmarshal ref=myJaxb/ to uri=mock:result/ /route /camelContext Failed to create route route1 at: Marshal[ref:myJaxb] in route: Route[[From[direct:start]] - [Marshal[ref:myJaxb], To[direc... because of dataFormat must be specified Are the docs out of date? What am I missing? My Spring config points to these XSDs: xsi:schemaLocation= http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd Thanks in advance for any help! -- View this message in context: http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-tp2814620p2814620.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel 2.2.0 Unmarshalling Problem
I may be having the same problem ... http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-td2814620.html#a2814620 -- View this message in context: http://camel.465427.n5.nabble.com/Camel-2-2-0-Unmarshalling-Problem-tp2808344p2814767.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: PoolSize on from()
Thanks, that did the trick. On Wed, Sep 8, 2010 at 2:19 AM, Daniel Bevenius daniel.beven...@gmail.comwrote: Hi, I think one way of doing this is to increase the maxPoolSize for the configured ThreadPoolProfile. For example: getContext().getExecutorServiceStrategy().getDefaultThreadPoolProfile().setMaxPoolSize(30); Regards, /Daniel 2010/9/8 Ron Smith ronsmit...@gmail.com I have my RouteBuilder doing this: from(tibco) .threads(readerThreads) .to(direct:localqueue); from(direct:localqueue) .threads(processThreads) .bean(MyParser.class, parseMessage) .bean(MyPersistor.class, persistRecord); If I set processThread 20, I get the following exception: org.apache.camel.FailedToCreateRouteException: Failed to create route route2 at: Threads[[Bean[com.sabre.clr.subscriber.metrics.MetricsParser], Bean[com.sabre.clr.subscriber.metrics.MetricsPersistor]]] in route: Route[[From[direct://metrics]] - [Threads[[Bean[com.sabre.c... because of MaxPoolSize must be = corePoolSize, was 20 = 25 I have found some docs and examples for setting a poolsize on a toAsync() method call but nothing about setting the poolsize on a from() method call. How do I fix this? Also, it needs to be done in real code, not in some XML file.
Re: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions?
Thanks for the response. I am hoping to get this to work from Spring config xml. So my JAXB Context is configured like this: dataFormats jaxb id=myJaxb prettyPrint=true contextPath=com.mycompany.connector.jms/ /dataFormats I tried specifying both the package and the package and class name. Both get the error. I found a different way to achieve unmarshalling, which I am going to post next, but this is concerning as I should be able to get JAXB to work. -- View this message in context: http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-tp2814620p2817298.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel 2.2.0 Unmarshalling Problem
What JDK are you using 1.5 or 1.6? On 8 September 2010 21:24, dresden isaacv...@gmail.com wrote: I may be having the same problem ... http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-td2814620.html#a2814620 -- View this message in context: http://camel.465427.n5.nabble.com/Camel-2-2-0-Unmarshalling-Problem-tp2808344p2814767.html Sent from the Camel - Users mailing list archive at Nabble.com.
RE: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions?
And all of your jaxb classes are in this package com.mycompany.connector.jms? -Original Message- From: dresden [mailto:isaacv...@gmail.com] Sent: Wednesday, September 08, 2010 2:10 PM To: users@camel.apache.org Subject: Re: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions? Thanks for the response. I am hoping to get this to work from Spring config xml. So my JAXB Context is configured like this: dataFormats jaxb id=myJaxb prettyPrint=true contextPath=com.mycompany.connector.jms/ /dataFormats I tried specifying both the package and the package and class name. Both get the error. I found a different way to achieve unmarshalling, which I am going to post next, but this is concerning as I should be able to get JAXB to work. -- View this message in context: http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-su ggestions-tp2814620p2817298.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions?
I was able to achieve unmarshalling using a different approach. I found the suggestion here: http://stackoverflow.com/questions/2631662/using-apache-camel-how-do-i-unmarshal-my-deserialized-object-that-comes-in-throug My Spring config looks like this: route from uri=amq2:queue:eat / to uri=xslt:file:src/com/mycompany/connector/resources/test.xslt / convertBodyTo type=com.mycompany.connector.bean.TestBean / bean ref=consumer / to uri=amq2:queue:eaten / /route Currently this method is working. My TestBean class is annotated with JAXB (XmlRootElement). The consumer bean receives a POJO, not an XML message or String. However, if anyone has an example of using an explicit Jaxb DataFormat from a Spring configuration, that would be great. -- View this message in context: http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-tp2814620p2817914.html Sent from the Camel - Users mailing list archive at Nabble.com.
RE: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions?
Well based on this example and the jaxb contextPath you gave earlier, it appears they aren't the same package. If jaxb can't find annotated classes or an ObjectFactory in the contetPath then you will get the error you were seeing. -Original Message- From: dresden [mailto:isaacv...@gmail.com] Sent: Wednesday, September 08, 2010 2:19 PM To: users@camel.apache.org Subject: Re: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions? I was able to achieve unmarshalling using a different approach. I found the suggestion here: http://stackoverflow.com/questions/2631662/using-apache-camel-how-do-i-u nmarshal-my-deserialized-object-that-comes-in-throug My Spring config looks like this: route from uri=amq2:queue:eat / to uri=xslt:file:src/com/mycompany/connector/resources/test.xslt / convertBodyTo type=com.mycompany.connector.bean.TestBean / bean ref=consumer / to uri=amq2:queue:eaten / /route Currently this method is working. My TestBean class is annotated with JAXB (XmlRootElement). The consumer bean receives a POJO, not an XML message or String. However, if anyone has an example of using an explicit Jaxb DataFormat from a Spring configuration, that would be great. -- View this message in context: http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-su ggestions-tp2814620p2817914.html Sent from the Camel - Users mailing list archive at Nabble.com.
RE: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions?
Yes. I have an annotated class in that package that I want to unmarshall
into.
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
@XmlRootElement(name=test)
public class TestBean {
...
Now, it is not an ObjectFactory, but it is annotated. Am I using the Jaxb
bean correctly?
route
from uri=amq2:queue:take /
unmarshal
jaxb id=myJaxb prettyPrint=true
contextPath=com.mycompany.connector.jms /
/unmarshal
bean ref=consumer /
to uri=amq2:queue:taken /
/route
--
View this message in context:
http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-tp2814620p2818518.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Solution?? JAXB Unmarshalling - DataFormat error ... suggestions?
JDK 1.5 or 1.6 ?
On 8 September 2010 22:24, dresden isaacv...@gmail.com wrote:
Yes. I have an annotated class in that package that I want to unmarshall
into.
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
@XmlRootElement(name=test)
public class TestBean {
...
Now, it is not an ObjectFactory, but it is annotated. Am I using the Jaxb
bean correctly?
route
from uri=amq2:queue:take /
unmarshal
jaxb id=myJaxb prettyPrint=true
contextPath=com.mycompany.connector.jms /
/unmarshal
bean ref=consumer /
to uri=amq2:queue:taken /
/route
--
View this message in context:
http://camel.465427.n5.nabble.com/JAXB-Unmarshalling-DataFormat-error-suggestions-tp2814620p2818518.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel 2.2.0 Unmarshalling Problem
1.6 Apple's distro. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-2-2-0-Unmarshalling-Problem-tp2808344p2819013.html Sent from the Camel - Users mailing list archive at Nabble.com.
Questions on the SOAP DataFormat
Hi, I have a couple of questions on the SOAP DataFormat[1]: 1.) The documentation says this DataFormat provides the basic features of Apache CXF without need for the CXF Stack. Does that mean it internally uses the JAX-WS Reference Implementation which is in the JDK by default? 2.) The section on the Webservice Client[2] shows a code snippet on making a SOAP call and also a potential route for doing the same. Are *both* simultaneously needed to make the SOAP call, or just one or the other will do? I think you need both, but just wish to confirm. Thanks, Glen [1] https://cwiki.apache.org/confluence/display/CAMEL/SOAP [2] https://cwiki.apache.org/confluence/display/CAMEL/SOAP#SOAP-Webserviceclient
Using the SOAP DataFormat with JMS queues
Hello, another question on the SOAP DataFormat text. In the Using the Java DSL section[1], the example given is as follows: SoapJaxbDataFormat soap = new SoapJaxbDataFormat(com.example.customerservice, new ServiceInterfaceStrategy(CustomerService.class)); from(direct:start) .marshal(soap) .to(jms:myQueue); I'm not sure what the above route is doing. Is it: 1.) Making a SOAP over JMS call (i.e., jms:myQueue will need to be a web service provider that will return a response) or 2.) Just marshalling the Java object holding the SOAP call data into an XML SOAP Envelope and placing the latter on a queue (for perhaps a later feed to the actual web service call, but it does not have to be). Thanks, Glen [1] https://cwiki.apache.org/confluence/display/CAMEL/SOAP#SOAP-UsingtheJavaDSL
Re: Questions on the SOAP DataFormat
I updated the docs, thanks. Willem Jiang wrote: On 9/9/10 8:00 AM, Glen Mazza wrote: Hi, I have a couple of questions on the SOAP DataFormat[1]: 1.) The documentation says this DataFormat provides the basic features of Apache CXF without need for the CXF Stack. Does that mean it internally uses the JAX-WS Reference Implementation which is in the JDK by default? No, it just uses the JAXB to do the marshal and unmarshal work. 2.) The section on the Webservice Client[2] shows a code snippet on making a SOAP call and also a potential route for doing the same. Are *both* simultaneously needed to make the SOAP call, or just one or the other will do? I think you need both, but just wish to confirm. Yeah, you need these two part code to perform the invocation. Thanks, Glen [1] https://cwiki.apache.org/confluence/display/CAMEL/SOAP [2] https://cwiki.apache.org/confluence/display/CAMEL/SOAP#SOAP-Webserviceclient Willem
Re: Using the SOAP DataFormat with JMS queues
Hi Glen, I think it's 2, the dataformat just marshal the request into a soap envelop and store it into a jms queue. Willem On 9/9/10 8:54 AM, Glen Mazza wrote: Hello, another question on the SOAP DataFormat text. In the Using the Java DSL section[1], the example given is as follows: SoapJaxbDataFormat soap = new SoapJaxbDataFormat(com.example.customerservice, new ServiceInterfaceStrategy(CustomerService.class)); from(direct:start) .marshal(soap) .to(jms:myQueue); I'm not sure what the above route is doing. Is it: 1.) Making a SOAP over JMS call (i.e., jms:myQueue will need to be a web service provider that will return a response) or 2.) Just marshalling the Java object holding the SOAP call data into an XML SOAP Envelope and placing the latter on a queue (for perhaps a later feed to the actual web service call, but it does not have to be). Thanks, Glen [1] https://cwiki.apache.org/confluence/display/CAMEL/SOAP#SOAP-UsingtheJavaDSL
Re: Camel-QuickFIX jar issues
Steve has not been involved, although he has made an offer around april to contribute significant improvements to the camel-quickfix component. He provided some hints about what he would change. I did write Steve a week or so ago, but did not get an answer yet. That said if there are any concrete requirements I may have some cycles to spend on it. I worked in the financial industry myself in a previous life and I am somewhat familiar with fix. Hadrian On Sep 8, 2010, at 3:09 AM, Charles Moulliard wrote: Steve Bate has not been involved in this component but Anton and my self. On Tue, Sep 7, 2010 at 5:40 PM, Bengt Rodehav be...@rodehav.com wrote: That sounds very good. I will have a look at it. When I looked at it the last time (1-1,5 years ago) it had a lot of problems which caused me to create my own Camel integration to QuickFix/J. Do you know if it has improved since then? I was really glad a while back when I heard that Steve Bate (from QuickFix/J) was getting involved to provide a solid QuickFix/J integration to Camel. But, like Vid (who created this thread), I'm wondering what happened. Is he involved and what has been done? /Bengt 2010/9/7 Charles Moulliard cmoulli...@gmail.com Hi, The quickfix-all jars file 1.5.0 have been published in this repository ( http://repo.fusesource.com/maven2-all/org/quickfixj/quickfixj-all/1.5.0/ ). The pom of the project camel-quickfix has been updated so you can use this component with camel version 2.5-SNAPSHOT. Regards, Charles -- View this message in context: http://camel.465427.n5.nabble.com/Camel-QuickFIX-jar-issues-tp2652022p2806238.html Sent from the Camel - Users mailing list archive at Nabble.com.
