Hi All,
I have code that cause infinite loop in redelivery message if I am using
routing slip.
onException(Exception.class).handled(true).maximumRedeliveries(1).useOriginalMessage()
.convertBodyTo(String.class).to("file://D:/inbox/error");
from("activemq://MY.QUEUE").transacted("PROPA
What version of Camel are you using?
And what is the message broker? ActiveMQ?
On Fri, Apr 27, 2012 at 9:34 AM, agustino wrote:
> Hi All,
>
> I have code that cause infinite loop in redelivery message if I am using
> routing slip.
>
> onException(Exception.class).handled(true).maximumRedeliverie
Hi
I am doing a simple route using camel
Now If I keep a file test.txt, It will transfer to output folders, But I
want this to happen every 10 seconds. Every time it writes, It should not
write a new file. But it should overwrite the existing file.
Because the source will be updated by one
See this page: http://camel.apache.org/ftp2.html
==> FTP Consumer does not support concurrency
The FTP consumer (with the same endpoint) does not support concurrency
(the backing FTP client is not thread safe).
You can use multiple FTP consumers to poll from different endpoints.
It is only a singl
On Fri, Apr 27, 2012 at 10:43 AM, Gnanaguru S
wrote:
>
> Hi
>
> I am doing a simple route using camel
>
>
>
>
> Now If I keep a file test.txt, It will transfer to output folders, But I
> want this to happen every 10 seconds. Every time it writes, It should not
> write a new file. But it should o
Hi
Not sure if I get your question, but to write files there is an option
"fileExist". This option defaults to "Override". Other options would
be "Append", "Fail" and "Ignore".
But since the default seems to be what you want, I don't really
understand the problem :-)
Stefan
On Fri, Apr 27, 201
On Fri, Apr 27, 2012 at 10:43 AM, Gnanaguru S
wrote:
>
> Hi
>
> I am doing a simple route using camel
>
>
>
>
> Now If I keep a file test.txt, It will transfer to output folders, But I
> want this to happen every 10 seconds. Every time it writes, It should not
> write a new file. But it should o
Thanks Stefan and Claus for the clue.
Great. It worked for the following route/.
Camel is Great always. I could have been writing 200 lines of code for this
else.
Regards
Guru
--
View this message in context:
http://camel.465427.n5.nabble.com/File-Overwrite-using-camel-tp5669708p566985
And will all this file operation work between a queue ?
LIke this
Regards
Guru
--
View this message in context:
http://camel.465427.n5.nabble.com/File-Overwrite-using-camel-tp5669708p5669871.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi
IMHO for each single step of progress you're trying to make you're asking
again and again before trying to investigate a bit by *yourself*!
So I propose you to:
- Look at the Camel source and it's own unit-tests to see if there's
something out there coverning your use case
- Search the User-Fo
Explicitly converting to a String before each WireTap worked
Thank you so much for the assistance. Much appreciated!
JM
--
View this message in context:
http://camel.465427.n5.nabble.com/Http-Route-with-WireTap-Question-Issue-tp5666526p5669959.html
Sent from the Camel - Users mailing li
Hi
I logged a ticket to not forget about this
https://issues.apache.org/jira/browse/CAMEL-5231
--
Claus Ibsen
-
CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog:
@Guru,
Here is my route.
from("direct:start")
.to("https://maps.googleapis.com/maps/api/place/search/json?location=xx.446788,-yy.950559&radius=500&types=food&sensor=false&key=some_key_";)
.unmarshal().json(JsonLi
I know this is old, but I thought to give an update anyway since I was
finally able to give it a look.
The following does now work on *Camel version 2.9.2*.
http://localhost:7001/gateway/support/loadArtifact/removeSOAP"/>
The URL shown returns an XSLT which Camel is then able to utilize on the
ro
On Fri, Apr 27, 2012 at 2:27 PM, mccabejj wrote:
> I know this is old, but I thought to give an update anyway since I was
> finally able to give it a look.
>
> The following does now work on *Camel version 2.9.2*.
> uri="xslt:http://localhost:7001/gateway/support/loadArtifact/removeSOAP"/>
>
> Th
Hi,
I'm not sure if this is suitable for you in your use case, but in this
cases where namespaces doesn't work I don't refer to namespaces in my
xpath like:
.split().xpath("/*[local-name() = 'dxf']/*[local-name() =
'organisationUnits']/*[local-name() = 'organisationUnit']")
regards, Marco
Hi Claus,
Thanks for the promptness!
> So you decouple a servlet request by submitting a job to a quartz
> scheduler. The scheduler will trigger the job
> sometime in the future, and the job is to send a message to a queue?
> Why do you want to do that?
We want to integrate our calendar/proce
I have the following route:
context.addRoutes(new RouteBuilder {
// Read the file(s) from the directory
"file:perf?delete=true" ==> {
// Split the file up at each line
split(_.getIn().getBody(classOf[String]).split("\n")) {
// The further split up the processing across
On Fri, Apr 27, 2012 at 3:32 PM, Reynald wrote:
> Hi Claus,
>
> Thanks for the promptness!
>
>> So you decouple a servlet request by submitting a job to a quartz
>> scheduler. The scheduler will trigger the job
>> sometime in the future, and the job is to send a message to a queue?
>> Why do yo
by the way: fileExist=Override is a producer option. so you should not
use it on the consumer (from)
stefan
On Fri, Apr 27, 2012 at 12:30, Babak Vahdat wrote:
> Hi
>
> IMHO for each single step of progress you're trying to make you're asking
> again and again before trying to investigate a bit
Hi Claus,
Thanks again for your help. Please see below/
// Works with this code
//I just add the destination header to the In Message. Let camel handle the
next steps
public void publish(Exchange exchange){
Publishable publishable=
exchange.getIn().getBody(Publishable.c
Yes thanks Marco. I'd also figured this is the best workaround for
the moment. It makes for ugly xpath expressions and fortunately we
don't have much likliehood of namespace clashes, but it does work :-)
On 27 April 2012 14:16, Marco Westermann wrote:
> Hi,
>
> I'm not sure if this is suitable
What Camel version and OS are you using?
On Fri, Apr 27, 2012 at 3:32 PM, rdifrango wrote:
> I have the following route:
>
> context.addRoutes(new RouteBuilder {
> // Read the file(s) from the directory
> "file:perf?delete=true" ==> {
> // Split the file up at each line
> split(_.
Hi
Can you try with 2.10 SNAPSHOT as camel-netty have been improved in
that release.
On Fri, Apr 27, 2012 at 2:17 PM, andlu702 wrote:
> I found dead post on this forum which seem quite similar to the problem I'm
> experiencing, but I decided to create a new thread instead of waking up a
> zombi
Thanks for the reseponse.
Is it possible to use a different version of camel-netty than that of
camel-core?
If it forces me to upgrade the camel-core version then it's probably not a
realistic solution in this project.
Since I have control over the producer I made a workaround for now and that
i
Camel version 2.9.2 on a Windows 7 Machine.
--
View this message in context:
http://camel.465427.n5.nabble.com/File-Processor-Not-deleting-the-files-tp5670301p5670530.html
Sent from the Camel - Users mailing list archive at Nabble.com.
On Fri, Apr 27, 2012 at 5:01 PM, rdifrango wrote:
> Camel version 2.9.2 on a Windows 7 Machine.
>
Okay be careful on Windows OS to ensure you always closes file handles
and streams when you acces the files.
For example if you use a InputStream then make sure you close it etc.
> --
> View this m
I'm not using any streams directly in my code. The complete code listing is
as follows:
// Build the connection pool
val ds = new BasicDataSource
ds.setDriverClassName("oracle.jdbc.OracleDriver")
ds.setUrl("jdbc:oracle:thin:@localhost:1521:xe")
ds.setUsername("**")
ds.setPassword("*
I guess this is implicitly touching the stream:
split(_.getIn().getBody(classOf[String]).split("\n"))
Could be the root?
--
View this message in context:
http://camel.465427.n5.nabble.com/File-Processor-Not-deleting-the-files-tp5670301p5670589.html
Sent from the Camel - Users mailing list archi
Hi All,
I am trying to aggregate large number of xml files into files of 5
records.
I am getting java.lang.OutOfMemoryError - Java heap space error.
I am trying to see if there are any leaks but to my eyes i do not see any.
Appreciate your thoughts on this.
Aggreation logic:
public class G
Yeah use the tokenize expression
In Java it would be
.split().tokenize("\n").streaming()
On Fri, Apr 27, 2012 at 5:13 PM, rdifrango wrote:
> I guess this is implicitly touching the stream:
>
> split(_.getIn().getBody(classOf[String]).split("\n"))
>
> Could be the root?
>
> --
> View this messa
Yeah, in the Scala DSL, it doesn't seem to support that. Is that a bug or
feature request?
--
View this message in context:
http://camel.465427.n5.nabble.com/File-Processor-Not-deleting-the-files-tp5670301p5670621.html
Sent from the Camel - Users mailing list archive at Nabble.com.
On Fri, Apr 27, 2012 at 5:30 PM, rdifrango wrote:
> Yeah, in the Scala DSL, it doesn't seem to support that. Is that a bug or
> feature request?
>
Fell free to log a JIRA. And as we love contributions you are welcome
to work on a patch to get that into the Scala DSL.
http://camel.apache.org/cont
Thanks Everybody.
Sorry Baba. I am miserably sorry. And Thanks for bearing me and answering my
questions in a apt way.
And cool this code worked great. As I expected.
route>
And Stefan, Let me try it out in producer. But this worked fine.
R
This is the error trace I see in my logs ...
org.apache.camel.CamelExchangeException: Error occurred during aggregation.
Exchange[null]. Caused by: [java.lang.OutOfMemoryError - Java heap space]
at
org.apache.camel.processor.aggregate.AggregateProcessor.doAggregation(AggregateProcessor.jav
First off thanks for your reply and I am using a vanilla install of
apache-servicemix-4.4.1-fuse-03-06. What didn't happen was in the original
email in the 'Spring config' below you should have seen my configuration of
the JettyHttpComponent with jettyHttpBinding.
Spring config:
Can we give multiple routes consuming from same ftp point.
If yes, does the camel create lock on the file when it reads the file.
The source from which it reads the files is unix server.
--
View this message in context:
http://camel.465427.n5.nabble.com/Does-camel-create-locks-on-UNIX-when-we-re
After running Eclipse Memory analyser, I see the below in the analysis data
...
One instance of "char[]" loaded by "" occupies
63,586,312 (87.23%) bytes
Please can someone help me is fixing this.
Thanks & regards,
Ebe
--
View this message in context:
http://camel.465427.n5.nabble.com/Java-hea
I found a workaround for this issue... although I think there's something
missing in the bundle's classloader/classpath.
Here is what I did in my camel-context.xml:
1. added xmlns:context="http://www.springframework.org/schema/context"; and
xmlns:util="http://www.springframework.org/schema/util";
Thanks everybody for help so far. The scenario I described previously was
implemented just by throwing the exceptions from corresponding validator
Java beans at step 2 and 3. It seems that Camel wraps that exception and
sends it to the web service client without any additional code.
There is one do
Thanks Christian. still same behavior after mimicing from your link. I am
going bananas over this. Running out of clues. Anything else that anyone can
think of? I am up against a wall here.
Thanks,
--
View this message in context:
http://camel.465427.n5.nabble.com/Transacted-test-case-with-Activ
Is it possible to map a queue uri to a physical JNDI queue? For example,
given this:
How can I map "jms:queue:myQueue" to the actual JNDI-provided queue resource
(e.g. jms/myQueue)? The reason being that our queue names vary from
environment to environment.
Thanks in advance.
--
View this mess
Hi
Use a custom destinationResolver. See details at
http://camel.apache.org/jms
On Fri, Apr 27, 2012 at 8:09 PM, PhilBurress wrote:
> Is it possible to map a queue uri to a physical JNDI queue? For example,
> given this:
>
>
>
> How can I map "jms:queue:myQueue" to the actual JNDI-provided queu
Try to implement a few routes, one that picks up a file from a directory and
one that sends a request to an external webservice.
I have the following routes defined in java dsl
from("file://in").id("file2jms").to("jms:ingest");
from("jms:ingest").id("ingestJms2Cxf").process(new
CreateAssetsProce
Tried 2.10-SNAPSHOT and it works like a charm.
But as I thought I had to update all other camel dependencies to
2.10-SNAPSHOT as well.
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-netty-deadlock-when-using-split-in-route-tp5670114p5671366.html
Sent from the Camel - Us
Hi,
I have an scenario where I need to aggregate small files containing XML data
(Records) into large ones containing 5 xml data (Records).
But ended up in Java heap memory issue.
Is there a way to stream the records into a file till i reach 5 records
and then move on to create another
What are your JVM settings regarding to the memory?
How large is the payload of one exchange?
Best,
Christian
On Fri, Apr 27, 2012 at 7:33 PM, ebinsingh <
ebenezer.si...@verizonwireless.com> wrote:
> After running Eclipse Memory analyser, I see the below in the analysis data
> ...
>
> One instan
I have set it as
-Xms1024m -Xmx1024m
--
View this message in context:
http://camel.465427.n5.nabble.com/Java-heap-space-issue-with-Aggregation-tp5670608p5671375.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Is it possible to provide a unit test which make its easier for us to
reproduce the issue?
Best,
Christian
On Fri, Apr 27, 2012 at 7:35 PM, javaxmlsoapdev wrote:
> Thanks Christian. still same behavior after mimicing from your link. I am
> going bananas over this. Running out of clues. Anything
It was my stupid mistake.
I didn't have "transacted=true" on
After carefully comparing with Christian's file, found it out. Again Thanks
much Christian.
--
View this message in context:
http://camel.465427.n5.nabble.com/Transacted-test-case-with-ActiveMQ-not-working-tp5666012p5671388.html
Sen
The DirectProducer is used, if you send an exchange to "direct:xxx".
Your CreateAssetsProcessor use the producer template and send an exchange
to the direct endpoint. Does you have a consumer listing on this endpoint?
And you should create the producer template from the incoming exchange:
exchange
You can use the file producer to write the content into a file and use the
"fileExist=Append" option.
Use the Aggregator "only" to determine when do you aggregate all exchanges.
Best,
Christian
On Fri, Apr 27, 2012 at 10:07 PM, ebinsingh <
ebenezer.si...@verizonwireless.com> wrote:
> Hi,
>
> I h
How large is the payload of one exchange?
Can you increase your memory, e.G. -Xms2048m -Xmx4094m?
When I remember right, 4GB is the maximum for 32 bit OS...
Best,
Christian
On Fri, Apr 27, 2012 at 10:09 PM, ebinsingh <
ebenezer.si...@verizonwireless.com> wrote:
> I have set it as
>
> -Xms1024m
Good to know you could figure it out.
Happy Camel ride,
Christian
On Fri, Apr 27, 2012 at 10:13 PM, javaxmlsoapdev
wrote:
> It was my stupid mistake.
>
> I didn't have "transacted=true" on class="org.apache.activemq.camel.component.ActiveMQComponent">
>
> After carefully comparing with Christia
Hi,
If you check the Java doc of the JettyHttpBinding, you will find it is
just used for JettyHttpProducer.
Your test case just showed it.
But for your real use case, you need to extends the DefaultHttpBinding
which will be used in the JettyHttpConsumer.
Please update the HttpBinding attribut
Just one comments for why you got the NPE from the out message of the
exchange.
As you are using a low level send API of the ProducerTemplate, you need
to check if the Exchange is failed before you try to access the response
message from the exchange.
On 4/28/12 2:22 AM, Danny wrote:
Try t
Willem,
Is there a higher level way to achieve the call?
On Apr 27, 2012 10:04 PM, "Willem.Jiang [via Camel]" <
ml-node+s465427n567193...@n5.nabble.com> wrote:
> Just one comments for why you got the NPE from the out message of the
> exchange.
>
> As you are using a low level send API of the Produ
You can use ProducerTemplate.requestBody(...) to send the request.
And you can get the exception automatically.
On Sat Apr 28 10:27:28 2012, Danny wrote:
Willem,
Is there a higher level way to achieve the call?
On Apr 27, 2012 10:04 PM, "Willem.Jiang [via Camel]"<
ml-node+s465427n567193...@n5.na
The exchange property of the Exchange.BATCH_SIZE will be used when the
aggregation call the isCompeleted(), So please don't change it dynamically.
On 4/27/12 11:25 PM, ebinsingh wrote:
Hi All,
I am trying to aggregate large number of xml files into files of 5
records.
I am getting java.lan
On Fri, Apr 27, 2012 at 10:06 PM, andlu702 wrote:
> Tried 2.10-SNAPSHOT and it works like a charm.
>
> But as I thought I had to update all other camel dependencies to
> 2.10-SNAPSHOT as well.
>
Yeah would would need to upgrade. But I think 2.9 SNAPSHOT may also be fixed.
> --
> View this messag
On Sat, Apr 28, 2012 at 5:18 AM, Willem Jiang wrote:
> The exchange property of the Exchange.BATCH_SIZE will be used when the
> aggregation call the isCompeleted(), So please don't change it dynamically.
>
Yes I told him to not create a new DefaultExchange all the time. But
only mutate the existi
61 matches
Mail list logo
