I am sorry to bring this back from the dead. However I was just trying out
the unmarshal().xstream("ISO-8859-1") method introduced because of this
thread. Unfortunately it still does not solve the problem (as of Camel
2.5.0)
>From non-camel routes, we have been publishing JMS messages and serial
I am using Camel 2.3.0 - I have a file endpoint that is configured with
delete=true and moveFailed=error. Yet when an error occurs, it does not
move it to a failed directory, and instead keeps re-trying the exchange.
Here is a route that shows my setup:
public void configure() throws Exception
Thank you for the replies - that is exactly what I wanted. I hadn't dug
enough through the Split() documentation to see the parallel processing
part.
I added the .executorService() part so I could cap the number of threads.
Thank you!
Jonathan
--
View this message in context:
http://old.nabb
Hello,
I am trying to get my head around how to construct a specific route in camel
2.3. I am creating a process that listens on a "trigger" directory for a
new file which starts the process.
Once it receives the "go" message. It will then look at a directory and
start processing all of the fi
Hi Jonathan,
>
> I just added a unit test[1] which is based on your test case, it looks
> like current camel 2.3 don't have the issue that you met.
>
> Can you have a look at my test and verify your case against the latest
> Camel 2.3-SNAPSHOT ?
>
> [1] http://s
t; RouteBuilder to see if that helps.
>
>
>
>
> On Fri, Apr 30, 2010 at 8:36 PM, jonathanq wrote:
>>
>> I am having serious issues with Camel 2.2.0 and Spring 3.0.2.RELEASE.
>>
>> I am creating my route in spring as a bean an
I am having serious issues with Camel 2.2.0 and Spring 3.0.2.RELEASE.
I am creating my route in spring as a bean and then injecting it into the
camelContext using the following:
The actual route definition is:
public void configure() throws Exception {
from(ge
> [1] https://issues.apache.org/activemq/browse/CAMEL-2407
>
> Willem
>
> jonathanq wrote:
>> I should also mention - this is Camel 2.0.0
>>
>>
>> jonathanq wrote:
>>> I am trying to unmarshal an xml message from JMS that was originally
>>
I should also mention - this is Camel 2.0.0
jonathanq wrote:
>
> I am trying to unmarshal an xml message from JMS that was originally
> marshaled using Xstream.
>
> When I create the message I am doing this:
>
> XStream xstream = new XStream(new DomDriver("ISO-8859
I am trying to unmarshal an xml message from JMS that was originally
marshaled using Xstream.
When I create the message I am doing this:
XStream xstream = new XStream(new DomDriver("ISO-8859-1"));
template.sendBody(xstream.toXml(myObject));
On the consuming process I have this in my route:
fr
ded a GenericFile
object to get the name to read. Not sure why I didn't think of doing that
earlier.
Jonathan
jonathanq wrote:
>
> Claus,
>
> I figured out why my custom Route Policy wasn't working for me.
>
> It seems that there is an issue when I use preMove on the Fi
ull.
This isn't an issue from my code, I can change the type and everything will
work. But it seems very strange that it changes types when "preMove" is set
on the endpoint.
Is that expected behavior?
Jonathan
Claus Ibsen-2 wrote:
>
> On Thu, Dec 31, 2009 at 5:39 PM,
application. But that will help with future applications as we do end up
writing a lot of file based camel processes.
Thanks for all the help!
Jonathan
Claus Ibsen-2 wrote:
>
> On Thu, Dec 31, 2009 at 12:33 AM, jonathanq wrote:
>>
>> I took a good look at the Route Pol
t actually rely
on threads(5) to spawn 5 threads..it will just spawn UP TO 5 threads
depending on the system load?
Jonathan
Claus Ibsen-2 wrote:
>
> Hi
>
> See also route policy to throttle the file consumer to a pace of 5
> concurrent files
> http://camel.apache.org/routepolic
I am trying to write a process that will use a file endpoint (camel 2.1.0) to
read from a directory.
I need the process to read a file from the directory and then do some
processing on the contents (namely hitting a REST service for each record in
the file). We have been asked to limit the numbe
re
> transactional. Of course, you have to do all the additional Spring
> configuration to make the 'queue' component transactional as well.
>
> Regards,
> Fintan
>
>
>
> Claus Ibsen-2 wrote:
>>
>> Hi
>>
>> Try using a 2nd JMS c
I am having an issue with JMS queues and transactions.
I have the following route:
from("queue:incomingqueue")
.process(getSomeTranslationProcessor())
.process(getMyPersistanceProcessor())
.process(getSomeOtherTransformerProcessor())
.to("queue:outgoingqueue");
Claus Ibsen-2 wrote:
>
>
> Yeah stop() is the right way to do so. Its also easy to understand
> what it does :)
>
> The message filter is another way (a more classic EIP solution)
> http://camel.apache.org/message-filter.html
>
>
I had wondered about the filter - but I didn't know what hap
I think I found the solution in the documentation (that's what I get for
finally posting a question - never fails I will find the answer 10 minutes
later).
This is waht I have now:
from("direct:incoming")
.choice()
.when(header("status").isEqualTo("1"))
I apologize if this is a simple question - but I just need to be sure!
I am developing this route that handles multiple message types and uses a
"when()" predicate to send the message to the appropriate processor based on
a header value. In the "Otherwise" case I want to send it to an unknown
fo
20 matches
Mail list logo
