Maybe try the zip-file data format when working with files
http://camel.apache.org/zip-file-dataformat.html
On Thu, Sep 17, 2015 at 5:30 PM, ywang9009 wrote:
> Claus, could you elaborate on the splitter/streaming approach? I am running
> into the same issue - gzip unmarshaling is done in memory a
That is something you would need to implement.
Or maybe if possible design the solution so you can update a column or
something in the database when you have processed the data so you do
not need to rely on timestamps and state to know where "you were".
On Fri, Sep 18, 2015 at 1:14 AM, Cleocleo
See this FAQ about producer template and also its javadoc
http://camel.apache.org/why-does-camel-use-too-many-threads-with-producertemplate.html
On Fri, Sep 18, 2015 at 6:48 AM, jcraw62 wrote:
> Need help getting Camel ActiveMQComponent working in Tomcat web app
>
> I’m sure I’ve gone about this
Hi all,
I'm trying to assign the result of a XQuery to a header, using Blueprint XML
In the documentation[1] I read:
setHeader("myHeader").xquery("resource:classpath:myxquery.txt", String.class)
The closest I got to translating the XQuery part to blueprint is:
resource:classpath:mapping/Systeem
And you have also, something alike this:
xxx
On Fri, Sep 18, 2015 at 9:29 AM, Mathieu De Zutter wrote:
> Hi all,
>
> I'm trying to assign the result of a XQuery to a header, using Blueprint XML
>
> In the documentation[1] I read:
> setHeader("myHeader").xquery("resource:classpath:myxquery.
Thanks Claus. I already figured setHeader out, but didn't mention it.
What I have now:
resource:classpath:/mapping/SysteemMapping.xq
resultType is not a valid attribute for , type is.
I still have the same error:
>>> SetHeader[MOWESB_SysteemMapping,
>>> xquery{resource:classpath:/mappi
Hi,
'
Is it possible to run curl command in camel routes?
--
View this message in context:
http://camel.465427.n5.nabble.com/curl-tp5771624.html
Sent from the Camel - Users mailing list archive at Nabble.com.
You can use the exec component
http://camel.apache.org/exec
On Fri, Sep 18, 2015 at 10:11 AM, Suganya wrote:
> Hi,
> '
> Is it possible to run curl command in camel routes?
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/curl-tp5771624.html
> Sent from the Camel
Either use the transactionMangager configuration parameter:
http://camel.apache.org/jms.html ( notation is #springBeanId to look it up
in the spring registry).
Or configure a transactionpolicy per route, and have the policy refer the
txMgr.
2015-09-17 15:02 GMT+02:00 kov :
> Apologies if this is
Hi All,
could you please help me to resolve the problem I am facing when forwarding
message from one queue to another , please see the spring xml.
thanks in advance
prajath
http://camel.apache.org/schema/spring";>
Claus, I am using gzip data format:
I just want to unzip the file and another process would read the file with
streaming. I wasn't sure how "ZipSplitter" could help in my case. Would you
be able to give me some example, ideally in blueprint DSL? I ended up
writi
This is one of the 2 shortcoming I discovered with Fuse/Karaf
I have been using Fuse for only 1 year. What I have encountered is it lacks
the ability to do unit testing because of inter-bundle dependencies. The
concept is great, or better than the monlithic WAR/EAR deployment. Maybe
someone else h
Hi Mark,
Thank you for you reaction.
I added the missing slashes :
from("mqtt://test?host=tcp://127.0.0.1:1883&clientId=3&subscribeTopicNames=foo")
.to("file:src/data/degrees.txt");
Unfortuantely it still says :
route1 shutdown complete, was consuming from:
Endpoint[mqtt://test?host=t
Hello friends
I have implemented a idempotent consumer which filter's out duplicates.
Implemented it using MemoryIdempotentRepository implementation.
However, I feel that if the server runs over a long period of time, it must
eventually run out of memory after storing all the filter keys for a
Hi Reji,
I would suggest you use a local cache implementation with an entry TTL or
FIFO eviction support with a maximum limit on entry count.
I find myself using Guava caches quite often when I require a lightweight
cache [1] like what you describe.
Beware that the content of the repository will
Hey Raul
Thanks for that.
I was checking out your way of doing it on
http://camel.apache.org/idempotent-consumer.html ..
Couldn't find a way to use cache though.
Can you paste a code snippet of the implementation if you have any. That
would be a big help for me to proceed!
Cheers
Reji
Claus,
thank you for the prompt reply. So now I understand ProducerTemplate should
be instantiated via Spring. I've configured:
and still I do not get injection when I code:
@Produce(uri = "activemq:start")
protected ProducerTemplate template;
public void sendToQueue(
Ah, by the way, our MemoryIdempotentRepository has a size property. So you
can set the max size of the cache without having to resort to another
implementation.
Try that first... We do not support time-based expiry or TTL though. If
you're looking for that, you can implement IdempotentRepository a
After further findings, it turns out that the route policy is respected. The
reason I thought it wasn't is because the route is not stopped on the
non-master servers until the first time the ftp consumer actually finds a
qualifying file to download. I was seeing logging from my filter code
running
d and consuming from:
Endpoint[file://C:/applications/data?fileName=%24%7Bdate%3Anow%3AMMdd%7D%2FdataFile.csv]
What I expected is:
Route: route4 started and consuming from:
Endpoint[file://C:/applications/data?fileName=20150918/dataFile.csv]
Any idea? cheers
--
View this message in context:
ht
20 matches
Mail list logo
