I have a requirement to route exchanges sequentially to a POJO processors.
I am trying something like the following:
.from("direct:start")
.to("xslt:xslt/transform.xsl")
.to("seda:In");
from("seda:In?concurrentConsumers=1").to("bean:rsProcessor");
The bean processor is sending the body payload
On Thu, May 24, 2012 at 9:42 AM, ppou wrote:
> I have a requirement to route exchanges sequentially to a POJO processors.
>
> I am trying something like the following:
>
> .from("direct:start")
> .to("xslt:xslt/transform.xsl")
> .to("seda:In");
>
> from("seda:In?concurrentConsumers=1").to("bean:rs
the bean opens a socket to connect to an external service and waits for a
response, however in the current implementation when another Exchange
reaches the bean it also sends the body to the service using the same
connector. This creates conflicts.
I was wishing to limit the number of exchanges t
Thank you. I have one more question. What is the difference between
zip the body and a zip file as the body of a message?
On Thu, May 24, 2012 at 1:18 AM, Claus Ibsen wrote:
> On Wed, May 23, 2012 at 10:43 PM, Tyler Durvik wrote:
>> I am receiving data message from client and the body of the
Hi,
I am using a splitter to handle a big CSV file (streaming mode). First, I
need to analyse the first line (header) to know the structure of the file.
I need to share the header structure to each line but the problem is that
the splitter is using one new exchange for each, so I can't use proper
I changed the route up slightly:
**
POST
http://localhost/s/restservice?httpClientAPI=true";
pattern="InOut"/>
Exception received:
org.apache.camel.component.cxf.CxfOperationException: JAXRS operation failed
invoking file://\\localhost\FT
Hello All,
Im new to Apache Camel. Im planning to camel-ftp to do the SFTP of a file
from one machine to the local machine. Following is the program, i've
created.
package com.apache.test;
import org.apache.camel.builder.RouteBuilder;
public class SFTPTransfer extends RouteBuilder {
@
Hi
Welcome to the community.
I suggest you spend some time googling that error report from slf4j.
There is plenty of details what it means, and how to resolve that.
Its not a Camel problem. You need to add more JARs to your classpath.
On Thu, May 24, 2012 at 2:52 PM, aprakash wrote:
> Hello Al
Fellow Camel riders,
First a little background about what I'm trying to do:
We want to introduce "auditing" (looks similar to BAM) to our camel
infrastructure. The idea would be that we want to be able to see
exactly what the exchange looks like at certain points in the route.
So, my thinking wa
Hi
On 24/05/12 13:55, mjelwood wrote:
I changed the route up slightly:
**
POST
http://localhost/s/restservice?httpClientAPI=true";
pattern="InOut"/>
Exception received:
org.apache.camel.component.cxf.CxfOperationException: JAXRS
Hi James,
I had a similar need not long ago and two things are needed. One is a
wiretap, to do the logging while processing goes uninterrupted on the
main flow.
The second is directly related to your question. I ended up using just
the in Message, thus losing the properties, but that was goo
can you pass first the File body to a processor bean, that would add the
CSV header (or fields name list) to the message Header
then it will be available in all splits after the splitter ?
On Thu, May 24, 2012 at 2:53 PM, greg_le_bonniec <
gregory.lebonn...@zenika.com> wrote:
> Hi,
>
> I am usin
Heck, I'm just glad to know that I'm not way off base! I'm a bit new
to camel (at least in the "real world"), so I'm glad I'm not doing
something completely crazy. :) Thanks for the sanity check, Hadrian.
On Thu, May 24, 2012 at 11:10 AM, Hadrian Zbarcea wrote:
> Hi James,
>
> I had a similar n
I'm in the process of updating our infrastructure dependencies to Camel 2.9.2
in large part to be able to see what is going on inside of our SEDA queues.
With the addition of the ManagedResource tagging and support, I'm seeing
significantly more information via JMX. However, at least via JBoss
JM
Some additional information. I'm not seeing any difference using the
jconsole tool or using a VM endpoint instead of SEDA.
Any help appreciated.
Craig
--
View this message in context:
http://camel.465427.n5.nabble.com/SEDA-Queue-not-showing-contents-via-JMX-tp5713504p5713513.html
Sent from th
Same problem in 2.9.2.
Check
org.apache.camel.management.MBeanInfoAssembler.getMBeanInfo(Object, Object,
String)
Use attributes from wrapper and from custom object too.
Solution could be a proxy on wrapper that forward custom method call to
custom object.
My workaround, but lost wrapper jmx att
+1 for waiting until Spring 3.1 is the default version (2.11. or 3.0.) and
it supports Quartz 2.x
Best,
Christian
Sent from a mobile device
Am 24.05.2012 08:25 schrieb "Claus Ibsen" :
> Maybe in Camel 2.11 we can upgrade to quartz 2.x.
>
> Then if people use Spring and Quartz together, they may
Yes, this fulfill your requirements.
Best,
Christian
Sent from a mobile device
Am 24.05.2012 11:20 schrieb "ppou" :
> the bean opens a socket to connect to an external service and waits for a
> response, however in the current implementation when another Exchange
> reaches the bean it also sends
+1 for also adding more fields to the quartz component so persisted quartz
jobs are not rescheduled.
BTW I cannot speak for all components but so far what I have tested has been
under Spring 3.1.0-RELEASE and camel-2.9-2. Everything looks fine so far.
I hope quartz will support iCalendar, please
We also had a similar requirement for this in the past. I recommend to have
a look at the Tracer [1]. It's implemented as an interception strategy and
called between each processor invocation. There you can also find some
ideas how to limit the traced messages, configure the content, ...
I'm looki
And you should really have a look at [1], because your code will *NOT* do
what you want to do...
[1]
http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html
Best,
Christian
On Thu, May 24, 2012 at 3:41 PM, Claus Ibsen wrote:
> Hi
>
> Welcome to the community.
>
> I sugge
I find a solution by using the aggregator strategy provided by the splitter
pattern.
Tks
Greg
*Grégory Le Bonniec*
Directeur Général - Zenika Ouest
Tél : +33 (0)6 18 31 68 03
skype : gregory.lebonniec
18, rue de la Monnaie
35000 RENNES
On Thu, May 24, 2012 at 5:10 PM, Vincent Nonnenmach
This was user error on my part. What I was failing to account for was
exchanges that were already consumed by a handler thread and were waiting to
be serviced within the thread. Clearly those are no longer queued and
should not show as such. The SedaConsumer knows about the number of
inflight ex
The ZipDataFormat expects an InputStream and will return a ByteArray by
unmarshalling the payload.
If you read a ZIP file, you can convert it to an InputStream. But than, you
have to create a java.util.zip.ZipFile or a java.util.zip.ZipInputStream to
extract all entries from the archive. Than you c
Good you could figure it out by yourself.
Have a nice Camel ride,
Christian
On Thu, May 24, 2012 at 10:39 PM, csete wrote:
> This was user error on my part. What I was failing to account for was
> exchanges that were already consumed by a handler thread and were waiting
> to
> be serviced with
Hello all,
I am trying to unit test the following method, which is essentially the
Sending to multiple JMS destinations from one endpoint example from the
camel website. Since the Exchange object is a param and contains the
result, I'm having trouble Mocking it. The below test fails at the ***
li
Hi All,
I need some help in configuring route in Spring DSL for my project. Here is
the scenario:
http://camel.465427.n5.nabble.com/file/n5713528/route.png
It is sort of an ugly diagram but hopefully the explanation will help to
understand it.
(A) is where xml message is coming from user. Onc
I wouldn't mock the Exchange:
CamelContext ctx = new CamelContext();
Exchange ex = new DefaultExchange(ctx);
// your code...
Best,
Christian
On Thu, May 24, 2012 at 11:31 PM, Gershaw, Geoffrey <
geoffrey.gers...@credit-suisse.com> wrote:
> Hello all,
>
> I am trying to unit test the following
Hi
Change cm namespace form
xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0";
to
xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0";
and change lile from
to
After change config file $KARAF_HOME/etc/foo.cfg, blueprint restart all
camel route in this
Hi
A good idea is to search for the term first.
For example on the Camel front page, there is a search box. Type in
your words there, eg breadcrumb.
And read the links.
For example this page
http://camel.apache.org/mdc-logging.html
On Fri, May 25, 2012 at 2:29 AM, Frank wrote:
> Can any one h
I'm new to Camel but interested if my proposal makes sence. So here is the
solution I suggest:
I would copy A to a header variable for later use.
B requires A to be in the message body so that's ok. The XSLT B will put
the result of the transformation in the body.
put C also in the header and put
Hi
i have analyzed the problem a little bit and i think the problem is not
the InOut pattern, but the multipleConsumers=true flag;
if i run the same sample without the
everything seems to be fine, but when i look in the in (data/spike/in)
folder there are still *.camelLock files for each co
Hi,
I have a route which uses an xslt transformation. When I run the
transformation within eclipse everything works fine. But when I use that
transformation within my camel route, I get a TransformationException
with message: included href is empty.
within the xslt I have a
which causes t
33 matches
Mail list logo
