Hi,
the input is:
<-this kind of tag doesn't
work.
<---this works.
The splitting route:
As I said; the easiest thing is to just use Fuse Fabric as we've lots of
documentation and out of the box examples that just work. However if you
want to use the spring watcher directly try this:
Try putting a spring camel XML file inside the spring folder (not /sping)
within the git repo?
e.g.
Hi all,
Could you indicate me the best way to launch camel from java class and
consume from a seda queue from the same class, in the same or different
thread?
Thanks a lot,
Matteo.
Greetings,
I have a route that needs to call a database, read some records, format
them and put them into ActiveMQ. Naturally the best way to do this would be
to wrap the whole thing in a transacted route. However, I do not want to
use SpringXML as a route builder interface at all. I don't think i
When you start the camel route in the main, you need to add a sleep to block
the main thread from exit.
BTW, you can use other tools that camel provides to running the camel route as
Claus just showed you.
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blog
Also, to make sure it is not a compatibility issue, I took
https://oss.sonatype.org/content/repositories/public/io/hawt/sample/1.2-M27/sample-1.2-M27.war,
and inserted the following JAR into its WEB-INF/lib folder:
https://oss.sonatype.org/content/repositories/public/io/hawt/hawtio-watcher-spring
Here is what i did. I took the jar file from here:
http://repo1.maven.org/maven2/io/hawt/hawtio-watcher-spring-context/1.2-M10/hawtio-watcher-spring-context-1.2-M10.jar
then I added it to the WB-INF/lib folder of the hawtio sample war file. I
deployed and created new routes in wiki/camel-spring.xm
I'm trying to use Camel embedded into an application (Spring configured) to
push files from a local directory to an instance of RabbitMQ. It's been
working well so far, except in the case where RabbitMQ is not available for
some reason (network outage, maintenance, etc.), and our application i
Hey guys,
Thanks a lot for your help. So by reading the file2 documentation
instead of the file documentation, I was able to solve my problem by
adding
doneFileName=${file:name.noext}.done
to the uri for the file being written and also to the uri of the route
that was attempting the subsequent r
Hi
Yeah check this page
http://camel.apache.org/running-camel-standalone.html
And the cookbook example it refers to.
On Tue, Nov 5, 2013 at 11:19 PM, pmp.martins
wrote:
>
> I have code a loadbalancer that generates a report every 10 seconds and
> sends it to a MINA server on localhost:9991 or t
I have code a loadbalancer that generates a report every 10 seconds and
sends it to a MINA server on localhost:9991 or to a MINA server on
localhost:9992 should the first one fail. Once the MINA servers receive the
report, they change it and send it back to the loadbalancer, which then
print the b
I worked around this by removing the idempotent configuration and instead
writing a GenericFileFilter which basically copies the idempotent repo's
behavior. This is working great.
--
View this message in context:
http://camel.465427.n5.nabble.com/inProgressRepository-Not-clearing-for-items-in-
In general, you should use the PooledConnectionFactory. The connections are
created upfront which saves time. The connections are also reused which is
more resource friendly.
Best,
Christian
-
Software Integration Specialist
Apache Member
V.P. Apache Camel | Apache Camel PMC Mem
Have a look at the following links:
http://forum.spring.io/forum/spring-projects/integration/118876-spring-integration-2-1-request-reply-benchmark-tests-showed-very-poor-performance
http://camel.465427.n5.nabble.com/fyi-SI-td5716049.html
Best,
Christian
-
Software Integration Spe
I'm afraid this is not supported yet. But it looks easy, as you already
mentioned, and could be added easily. Do you consider to provide a patch
[1]?
[1] http://camel.apache.org/contributing.html
Best,
Christian
-
Software Integration Specialist
Apache Member
V.P. Apache Camel
Check you don't have a library/version miss match. It looks like you also
use Camel 2.7.0...
CamelNamespaceHandler.java:169)[:2.7.0]
Best,
Christian
-
Software Integration Specialist
Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incub
That's the old file component, have a look at file2.
http://camel.apache.org/file2.html
> On 05 Nov 2013, at 20:36, Ben Hood <0x6e6...@gmail.com> wrote:
>
> Hey Claus,
>
> Having to acquire a lock on the file sounds like a good way to implement the
> "don't start attempting to read an empty fil
Hey Claus,
Having to acquire a lock on the file sounds like a good way to implement the
"don't start attempting to read an empty file" semantics I'm looking for.
Having said that, the documentation on read locks is somewhat misleading. It
notes a boolean URI parameter called consumer.exclusiveR
Hi
See this EIP
http://camel.apache.org/composed-message-processor.html
about _only using a splitter_
On Tue, Nov 5, 2013 at 4:54 PM, Bob Jolliffe wrote:
> Hi
>
> I have a route which takes a database query result set, splits it by row,
> then proceses each row using another route with seda en
Can you show some of the route code you do for the splitting?
On Tue, Nov 5, 2013 at 4:05 PM, Cecilio Alvarez
wrote:
> Hi,
>
> in camel 2.12.1 when split a message this kind of xml tag doesn't work,
> meanwhile in camel 2.11.0 works fine:
>
>
>
>
> org.xml.sax.SAXParseException; XML documents st
Hi
I have a route which takes a database query result set, splits it by row,
then proceses each row using another route with seda endpoint. Something
like:
Get updates from dhis db and post to
registry
${in.body}
Is there I can cause th
Aggregator has a CamelAggregatedSize, maybe try Simple[1] to set a header with
the sum.
[1] http://camel.apache.org/simple.html
> On 05 Nov 2013, at 15:48, Olaf wrote:
>
> Hello,
>
> thanks! CamelSplitSize is useful. I'd add then
>
>.to("remote")
>.choice()
>
In the previous post I had 2 questions:
1. how to do this in java dsl
2. why are the mina servers sending replies.
I will attack problem 1 eventually, but I just want to state that the
solution to problem 2 is here:
http://camel.465427.n5.nabble.com/Load-balancing-using-Mina-example-with-Java-DSL-
If you are talking about how to not pickup new files in a Camel from
route, then take a look at the various read lock documentation on the
file component.
On Tue, Nov 5, 2013 at 2:39 PM, Ben Hood <0x6e6...@gmail.com> wrote:
> Hi,
>
> In my first attempt to use Camel I’ve run into a intra-route tim
Hi,
in camel 2.12.1 when split a message this kind of xml tag doesn't work,
meanwhile in camel 2.11.0 works fine:
org.xml.sax.SAXParseException; XML documents structures must start and end
within the same entity.
If I add:
works fine. Is suppose to be the expected behaviour?
Thanks in adva
I have tested several lpr uri schemas but I cannot create an endpoint. I get
the following message.
Reason: javax.print.PrintException: No printer found with name:
\\10.250.10.149:9001\hp9000. Please verify that the host and printer are
registered and reachable from this machine.
The uri is: lpr:
Thanks. I've submitted a bug:
https://issues.apache.org/jira/browse/CAMEL-6936
In the meantime, do you have any alternative recommendations for my
requirements? Basically, I want to consume files from an FTP server only if
they are new or modified. I guess I would need to roll my own filter for
Hi,
We are using camel 2.12.0 http4 component to proxy http requests to a web
application. We ran into an issue with the host header being removed for
every proxied request due to this line of code in http4's HttpProducer.java
exchange.getIn().getHeaders().remove("host"); line 106
we found this
Thank you! That's what I am looking for!
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-http4-adds-request-headers-to-response-headers-by-default-tp5742600p5742656.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hello,
thanks! CamelSplitSize is useful. I'd add then
.to("remote")
.choice()
.when(property("CamelSplitComplete").isEqualTo("true"))
.log("splitted ${property.CamelSplitSize} records")
.otherwise()
Hi,
In my first attempt to use Camel I’ve run into a intra-route timing issue that
I’ve only solved with a hack, so I was wondering whether there are any best
practices of dealing with timing issues when dealing with multiple processing
steps in a batch file pipeline.
Basically I am trying to
Thanks!
--
View this message in context:
http://camel.465427.n5.nabble.com/Migrate-Apache-Camel-Endpoints-tp5741899p5742652.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi
I think your split size is actually , try use the header from the
split, CamelSplitSize.
Taariq
On Tue, Nov 5, 2013 at 1:57 PM, Olaf wrote:
> Hello,
>
> is there an easy way to count and sum all processed lines by an aggregator?
> Suppose, my file has lines, the route split it int
After much effort, I have found a way to implement this basing myself on the
loadbalancer example provided by apache.
I have uploadded the eclipse project to my github account, you can check it
working here:
-
https://github.com/Fl4m3Ph03n1x/stackoverflow/tree/master/loadbalancer-failover-spring
Hello,
is there an easy way to count and sum all processed lines by an aggregator?
Suppose, my file has lines, the route split it into 100 lines chunks
and send them to a remote system. The goal is, to gather statistics of all
sent lines. In the example below, .log() would always print the ag
Hi
I am using the CXFRS Endpoint.
I am using the following URI format:
"cxfrs://bean://rsCustodyClient?throwExceptionOnFailure=true"
My custody client bean looks like:
http://localhost/service";
serviceClass="com.mycompany.rs.client.CustodyTradeResource"
loggingFeatureEnabled="true" /
Hi
While using camel-netty we have noticed that when remote sever is down netty
component is throwing
org.apache.camel.CamelException.
It should be throwing java.net.ConnectException right??
So that it will be easy for error handling.
-
Regards
kiran Reddy
--
View this message in cont
It will be fired according to the defaults for the timer component which is
evry 1000 milisecond.
See the documentation[1].
[1] http://camel.apache.org/timer.html
// Pontus
On Mon, Nov 4, 2013 at 7:07 PM, John D. Ament wrote:
> I'm using Camel 2.10.7. We just noticed in our code we have a tim
hi,
thank you very much.
I use different port,but it still doesn't work.
Finally I specify the bus option per CXF endpoint,This problem solved.
Why don't specify this option, it wouldn't work.
Changed Spring configuration file like this:
http://www.springframework.org/schema/beans";
Thank you for your reply!
I am afraid but it seems not working with even 2.13-SNAPSHOT. I've even
changed the exception to java.lang.Exception and still is not catching these
exceptions.
The exception should be caught when there is no connection to the database.
That's how it works on Camel 2.7.
Hi
Yeah sounds like a bug. Feel free to log a JIRA ticket
On Mon, Nov 4, 2013 at 11:05 PM, skelly wrote:
> I'm attempting to consume messages from an FTP server using an idempotent
> repository to ensure that I do not re-download a file unless it has been
> modified.
>
> Here is my (quite simple
Then next release :)
See CAMEL-6795
Its now default as
private transient String spoolDirectoryName =
"${java.io.tmpdir}/camel/camel-tmp-#uuid#";
On Tue, Nov 5, 2013 at 1:27 AM, pmcneil wrote:
>
> Nope, this is in 1.12.1 :-)
>
> and yes I can configure it, but what if something else expects
The JiBX dataformat does not seem to allow setting the binding name on the
marshaller/unmarshaller. Normally, you'd have the option of calling
BindingDirectory.getFactory(bindingName, class), but this doesn't seem to be
available in marshal().jibx().
Is there another way to do this?
--
View thi
Hi,
Because your two route are using same port , you need let the CXF endpoint
share the same Bus to avoid shutting down the Jetty engine when you remove the
route1.
http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:cxf="http://camel.ap
44 matches
Mail list logo