Hi,
I am trying to upload the around 100 mb file from one server to different.
First I am trying to copy the file from one server to the server where my
application is running. Below are the issue I am facing.
1. When file copy is in-progress status, camel application start picking up
the file
The errorHandler allows you to modify its configuration at runtime
using JMX. This way you can change the maximum redeliveries
On Thu, Jun 20, 2013 at 8:07 PM, swwyatt steven.wy...@sungard.com wrote:
Given a redelivery policy contained within an onException, is there a way to
modify the policy
Hi
Can you be more specific with what you mean with separate process?
There is an exec to run an executable
http://camel.apache.org/exec
On Fri, Jun 21, 2013 at 1:19 AM, Sean Beck seanmckayb...@gmail.com wrote:
So I have figured out how to gather messages based on my criteria. A
process
Hi,
Can anyone suggest any performance improvement techniques for camel-activemq
We have tried connection pooling mentioned in this page
http://camel.apache.org/activemq.html
http://camel.apache.org/activemq.html
Here is my xml and route configuration
Hi Everyone.
Atlast I have figured out how to invoke a RESTFUL webservice using Camel
Framework.
It is very easy. No need of any CXF/CXFRS/RESTLET components.
Just HTTP component of Camel is enough.
Thanks,
Syed.
--
View this message in context:
On 21/06/13 08:31, SyedBhai wrote:
Hi Everyone.
Atlast I have figured out how to invoke a RESTFUL webservice using Camel
Framework.
It is very easy. No need of any CXF/CXFRS/RESTLET components.
Just HTTP component of Camel is enough.
Sure that works too. Your original question had a
Hello,
I'm upgrading from camel 2.6.0 to 2.11.0. It's a big step as 2.6.0 is pretty
old.
However some of our routes don't start anymore because of the exception:
The route looks like the following:
Should I just remove the endDoTry() or is there another possibility?
kind regards,
Christoph
After implementing the workaround for ENTESB633, i noticed it uses the jms
component as part of the xa transactions. In the camel docs it is clearly
stated that the activemq-camel component should be used for amq. Is this
also the case for xa transactions?
--
View this message in context:
activemq-camel extends the jms component. The former is just optimized
for when using ActiveMQ.
On Fri, Jun 21, 2013 at 12:13 PM, Maurice maur...@betzel.net wrote:
After implementing the workaround for ENTESB633, i noticed it uses the jms
component as part of the xa transactions. In the camel
Claus - I think this will solve the probem as he might have turned on the
tracing and the stream was getting consumed and thereafter empty.
I have one query , what is effect of spooling on performance here. I am
talking of a system where I am using the http component and the expected TPS
is
Hi Claus,
Looks like i finally would we working on getting this component up on the
cluster...Hence re initiating the thread with you.. wanted to know, How can
i configure a shared idempotent repository for a ftp component. My apologies
i do not see any such option with the configurations that
See the idempotentRepository option
http://camel.apache.org/file2
On Fri, Jun 21, 2013 at 12:31 PM, yogu13 yogesh@synechron.com wrote:
Hi Claus,
Looks like i finally would we working on getting this component up on the
cluster...Hence re initiating the thread with you.. wanted to know,
thank you so much.
that really helped me, i set the property as follows
property name=idleTimeout value=0 /
and now i not facing any exception.
thanks a lottt, i was badly struggling with this issue since long
time.
Regards,
Indrayani
--
View this message in context:
Hi
Yeah turn off the spooling. When spooling to disk it becomes slow.
Also most boxes today have plenty of memory.
http://camel.apache.org/stream-caching.html
I want to refactor and offer a better spooling strategy, so you can
define memory thresholds instead of just a fixed payload size.
On
Hi,
Even though I am not Claus, you need to set up a shared implementation of the
IdempotentRepository. The ones from Camel-Core (File and Memory) are not
shared, but you could use the implementation from the SQL, JPA or Hazelcast
component (or write your own).
In case of a cluster you may
Hello,
I have the following route:
from(startEndpoint)
.choice()
.when(fileIsComplete()).delay(COMPLETION_TIMEOUT).process(processor).to(outputEndpoint)
.otherwise().aggregate(new ObjectsAggregator()).constant(true)
.completionSize(BATCH_SIZE).completionTimeout(COMPLETION_TIMEOUT)
Nothing new there, but why use the jms component on this workaround which
connects to amq? This does not give much confidence on an issue that is
already not working as it should.
--
View this message in context:
Hi
Yeah if sftp accepts an InputStream for the private key file, then we
can use the resource loader abstraction to load it from classpath and
file systems.
See: org.apache.camel.util.ResourceHelper#resolveMandatoryResourceAsInputStream
This is what we do in other components.
This will help
Hi
Use a new route for the aggregate, and then use direct:xxx endpoint
from the choice to call that route.
On Fri, Jun 21, 2013 at 12:59 PM, cristisor cristisor...@yahoo.com wrote:
Hello,
I have the following route:
from(startEndpoint)
.choice()
On Fri, Jun 21, 2013 at 1:27 PM, Maurice maur...@betzel.net wrote:
Nothing new there, but why use the jms component on this workaround which
connects to amq? This does not give much confidence on an issue that is
already not working as it should.
What do you mean?
activemq-camel is the
I will test both components and see if there are any issues, besides that the
activemq-camel 5.8.0 component had to be modified to überhaupt play nice
with Karaf :) . And i cannot oversee any issues concerning the ENTESB633
bug, so lets find out.
--
View this message in context:
Hi,
i have a route defined as follows :
route id=route123
from uri=servlet:///servletA/
to uri=activemq:queue:inbox/
/route
currently i am calling a servlet as using following url :
http://localhost:8082/camel-example-activemq-tomcat/camel/servletA
my query is, is it possible
hi all,
i set the property as follows
property name=idleTimeout value=0 /
and now i not facing any exception.
thank you everybody for the support
--
View this message in context:
http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734530.html
Sent from the Camel -
When you say without using activemq what do you use in its place? the
direct component?
Have you debugged a little to see where the processing is slowing down? ie,
where are the bottlenecks? On the camel side? On the broker side?
On Fri, Jun 21, 2013 at 2:39 AM, kiranreddykasa
Hi
Without activemq in the sense direct tcp to tcp.
No other queue in the middle.
from(netty:tcp://10.44.71.187:7000?textline=true).threads(800,800)
.bean(MainDummyProcessor.class)
.to(netty:tcp://10.44.71.67:7004?textline=true);
-
Regards
kiran Reddy
--
View this
On Fri, Jun 21, 2013 at 2:12 PM, indrayani ind.k...@gmail.com wrote:
Hi,
i have a route defined as follows :
route id=route123
from uri=servlet:///servletA/
to uri=activemq:queue:inbox/
/route
currently i am calling a servlet as using following url :
No.
Sent from a mobile device
Am 21.06.2013 14:52 schrieb indrayani ind.k...@gmail.com:
Hi,
i have a route defined as follows :
route id=route123
from uri=servlet:///servletA/
to uri=activemq:queue:inbox/
/route
currently i am calling a servlet as using following url :
Thanks for your quick answer. Now I only have to adjust the delay.
--
View this message in context:
http://camel.465427.n5.nabble.com/Mixing-ChoiceDefinition-with-DelayDefinition-tp5734524p5734536.html
Sent from the Camel - Users mailing list archive at Nabble.com.
JMS default is to do persistent messaging. Will add quite a bit more
overhead than just straight sockets especially if you have a slow disk.
You'll have to consider your use case needs (level of message durability,
message size, throughput, etc, etc)... take a look at tuning activemq:
Thanks for the response.
The separate process is a program that puts two files together. Multiple
clients with their own SSIDs send over files, and there are 2 files that go
together for each set of data operated on by the client. As soon as the
files are received on my server the server sends a
Ya I agree jms will add little overhead,
But based on the results I got TCP is 10x faster.
Generally will there be this much difference??
-
Regards
kiran Reddy
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-Activemq-performance-suggestions-tp5734508p5734539.html
I have a camel app deployed on JBoss-6, which is using HornetQ as the
JMS implementation.
There is a route which listens to JMS topic traffic between some 3rd
party MDBs, which,
I believe use durable, transacted topics, but since the camel route is
just listening (consuming)
I have the most basic
I've created the issue here:
https://issues.apache.org/jira/browse/CAMEL-6477
Stephan, I'd be happy to submit a patch unless you or someone else should
work on it... can you point me to where camel actually calls jsch wrt the
keyfile logic?
--
View this message in context:
Sean,
I presented at CamelOne last week on how to handle exactly this kind of
scenarios with Camel and claimcheck. The code and slides are available
on github [1]. Please take a look and let me know if you have any questions.
Cheers,
Hadrian
[1] https://github.com/hzbarcea/camelone
On
Thanks for the response! I'll look now and let you know
On Fri, Jun 21, 2013 at 12:24 PM, Hadrian Zbarcea hzbar...@gmail.comwrote:
Sean,
I presented at CamelOne last week on how to handle exactly this kind of
scenarios with Camel and claimcheck. The code and slides are available on
github
Everything installed fine for camelone but I ran mvn camel:run and it seems
to have gotten stuck after first [INFO]
On Fri, Jun 21, 2013 at 12:27 PM, Sean Beck seanmckayb...@gmail.com wrote:
Thanks for the response! I'll look now and let you know
On Fri, Jun 21, 2013 at 12:24 PM, Hadrian
from(jms:queue.name).aggregate(new AggregationStrategy() {
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
// code here
}
}).completionSize(2).to(exec://FILEPATH?args=);
As I look/ask around more I think this is closer to what I want. Someone
said to use a
Isn't that exactly what you expect? :) The camel:run plugin makes it so
that you could run your route continuously (until you press ^C). If you
want to just send a few messages a unit test would be more appropriate.
Please take a look at the routes to better understand how the code
works.
Yes, you are on the right track. JMS queues work too, as long as you
have a way to correlate your messages (and there are many, many ways to
achieve that). Conventions on the queue names works.
Aggregation does have to happen, you are correct. The demo I mentioned
looks at business processes
In general: http://camel.apache.org/scripting-languages.html
In detail:
http://camel.apache.org/beanshell.html
http://camel.apache.org/javascript.html
http://camel.apache.org/groovy.html
http://camel.apache.org/python.html
http://camel.apache.org/php.html
http://camel.apache.org/ruby.html
Hi,
This ResourceHelper looks interesting. I will look into this and attach a patch
to the JIra task next week.
Best regards
Stephan
41 matches
Mail list logo
