Hi,
This ResourceHelper looks interesting. I will look into this and attach a patch
to the JIra task next week.
Best regards
Stephan
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
http://c
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 i
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. Basi
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 G
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 wrote:
> Thanks for the response! I'll look now and let you know
>
>
> On Fri, Jun 21, 2013 at 12:24 PM, Hadrian Zbarcea wrote:
>
>> Se
Thanks for the response! I'll look now and let you know
On Fri, Jun 21, 2013 at 12:24 PM, Hadrian Zbarcea wrote:
> 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 ta
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 06/2
Could I create my own AggregationStrategy class that stores all the
messages and handles them appropriately? Or is there an easier way?
On Fri, Jun 21, 2013 at 9:19 AM, Sean Beck wrote:
> Thanks for the response.
>
> The separate process is a program that puts two files together. Multiple
> cli
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:
http://camel.4654
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
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
S
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 m
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:
http://activ
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.
On Fri, Jun 21, 2013 at 2:12 PM, indrayani wrote:
> Hi,
> i have a route defined as follows :
>
>
>
>
>
>
> 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 to use
No.
Sent from a mobile device
Am 21.06.2013 14:52 schrieb "indrayani" :
> Hi,
> i have a route defined as follows :
>
>
>
>
>
>
> currently i am calling a servlet as using following url :
>
> http://localhost:8082/camel-example-activemq-tomcat/camel/servletA
>
> my query is,
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 t
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 wrote:
> Hi,
>
hi all,
i set the property as follows
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 - Users mailing list archive at Nabble.c
Hi,
i have a route defined as follows :
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 to use the route id in the servlet url ?
that is insted of using ' /camel-examp
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:
http://camel.46
On Fri, Jun 21, 2013 at 1:27 PM, Maurice 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 preferred component
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 wrote:
> Hello,
>
> I have the following route:
> from(startEndpoint)
> .choice()
> .when(fileIsComplete()).delay(COMPLETION_TIMEOUT).process(p
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:
http://camel.465427.n5.nabble.com/Camel-JMS-or-activeMQ-component-for-xa-transacti
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 wit
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)
.process(process
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 also
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 Th
thank you so much.
that really helped me, i set the property as follows
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:
http://camel.465427.n5.nabble.com/Activemq-consu
See the idempotentRepository option
http://camel.apache.org/file2
On Fri, Jun 21, 2013 at 12:31 PM, yogu13 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, How can
> i configure a
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 the
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 1000
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 wrote:
> 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
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:
http
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
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 JAX
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:
http://camel.465427.n5.nabble.com/RestF
38 matches
Mail list logo
