Worked :)
Thanks *Henryk Konsek*
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-escape-commas-in-CSV-file-tp5729241p5729584.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi all,I'm new to camel and trying to learn. I'm trying to submit a message
to the smsc, but unable to do so. I'm able to connect with smsc but not able
to submit message. Here is my route
definition:from("direct:start").to("smpp://smppclient1@localhost:2775?password=password&enquireLinkTimer=1
Hi,
I'm writing my own component and I wondered if it was possible for the
Endpoint URL to be able to contain a Simple expression.
For example:
or
I thought that perhaps Camel would process the URL before it was passed to
the Component object, but I'm happy to invoke Simple myself if necess
Claus,
Thanks for pointing to the Javadoc. In fact, I started out blind with a very
little idea on how an aggregation would work. But after working my way
through the above exercise, I got a good hold of it. In fact, I made the
mistake of having my aggregation logic in a processor. I moved them to
I have a scenario where I need to pick velocity based on locale. I have two
problems for this.
Do we any option in velocity endpoint to provide locale information? if not,
do we have option in camel to set some header property in Exchange message
so that velocity template gets picked up automatica
Can you show us exactly where you are inserting your log statements?
A log statement between the servlet endpoint and the http4 one should
display what you're after.
Sent while on the move
On 7 Mar 2013 18:36, "rouble" wrote:
> Willem, Scott, Claus et al,
>
> Appreciate all your input. So, is t
try cxf intercptors -input and output interceptors if its cxf service.It
gives wire incoming msg and wire outgoing msg
--
View this message in context:
http://camel.465427.n5.nabble.com/Enable-wire-logs-on-Camel-HTTP-Proxy-tp5723675p5729577.html
Sent from the Camel - Users mailing list archive
Use the defaultErrorHandler if you want handle the exception (not
rethrowing the exception).
Using the following test, the exception is logged at level WARN (using
Camel 2.11-SNAPSHOT):
package org.apache.camel.builder;
import org.apache.camel.ContextTestSupport;
import org.apache.camel.LoggingL
I think you are looking for a template engine like [1], [2] or [3].
[1] http://camel.apache.org/freemarker.html
[2] http://camel.apache.org/velocity.html
[3] http://camel.apache.org/stringtemplate.html
Best,
Christian
On Tue, Mar 19, 2013 at 7:29 AM, jinaLu wrote:
> I use camel 2.8 according m
I recommend to use the CamelTestSupport base class for your unit tests.
Have a look at the following tests:
https://svn.apache.org/repos/asf/camel/trunk/components/camel-jdbc/src/test/java/org/apache/camel/component/jdbc/
Best,
Christian
On Thu, Mar 14, 2013 at 10:16 AM, uzairkamal wrote:
> Hel
Hi,
Have got a basic question.
I would like to understand the prescribed method of starting and stopping the
Camel-spring application?
We are planning to have this application on the standalone, so need to
understand how to start and stop after deploying into the server.
Any model script will
I will answer this question myself .You can find the endpoint which the
exchange is used by using
exchange.getProperty("CamelToEndpoint") .
To answer the overall question - how to manipulate the message in
recipient/multicast according to endpoint keeping in mind the endpoint list
will be creat
I've ran into a bit of odd behavior from the JPA component. I've configured a
JPA consumption route as follows:
from("jpa:com.models.MyRecord?consumeDelete=false&consumer.query=select r
from com.models.MyRecord r where r.batchID = NULL").to("direct:jpaOut");
The model contains the following updat
Hi Wojtek,
> When consuming messages from more
> than one route with the same endpoint URI (lets say:
> guava-eventbus:eventBus), context doesn't start and throws exception
Actually I used multicast EIP to copy message from the given event bus
to multiple destination...
from("guava-eventbus:myBu
Hi,
I'm writting because I'm trying to configure the clientConnectionManager
httpEndpoint Option using camel-http4 but I'm having some problems.
In my endpoint definition (same endpoint, different configs each time) I'm
adding the option ?clientConnectionManager=XXX where XXX is a reference to a
I'm probably missing something obvious but I'm struggling with what seems
like a simple Camel/Zookeeper problem.
I have a zookeeper tree like:
/parent
/parent/child1
/parent/child2
/parent/child3
where the child nodes are ephemeral nodes so I don't know ahead of time what
or how many children I
Hi
Please read the documentation and research a bit first yourself.
For example with Java code there is javadoc that documents the API.
So if you read the API of the aggregate method, you will find about the "null".
http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/proces
I modified my route to look like below:
from("file:C:\\Users\\joe\\Desktop\\csv?noop=true").setHeader("isBuToPf",
simple("true")).
unmarshal().csv().process(new
RefDataProcessor()).to("direct:Process");
from("file:C:\\Users\\joe\\Desktop\\csv2?noop=true").setHeader
I have tried the following to achieve what I want. But I ran into some
errors:
My Route:
from("file:C:\\Users\\joe\\Desktop\\csv?noop=true").
unmarshal().csv().process(new
RefDataProcessor()).to("direct:Process");
from("file:C:\\Users\\joe\\Desktop\\csv2?noop=true
i went through my post and got the code :)
public void configureHttpClient(org.apache.http.client.HttpClient
httpClient) {
try {
final BasicHttpParams httpParams = new
BasicHttpParams();
//if y
I have read through it and i couldnt figure anything out for reasons i
mentioned in previous post.Rephrasing my questions short
1)Is there a property in exchange which says the which endpoint the message
is intended for??Can i use it in multicast for identifying the endpoint for
which exchange wi
Whatever server you are using, turn on SSL logs.
http://docs.oracle.com/javase/1.5.0/docs/guide/security/jsse/ReadDebug.html
. it usually lands up on console and not file atleast in karaf/smx. i mean
the SSL logs not your custom logging.It will tell you all steps in cert
exchange.The link explain
I think the previous post is the way to do.We/I dont automatically import
certs.That said i dont your requirements.I have a post explaining the way
httpClient should be used in camel in camel user forums.Search for all my
post you will have the full working code.That should use your trust store
ins
Hi,
Could be that this has to do with the server certificate not beeing
trusted by your java process.
Check if the sever (hangstrap.iriscouch.com) has a valid certificate
and that the root ca cert and any intermediate ca certs is in your
trust store.
Some browsers will auto-magicaly download the
Mhhh... lowering the Start Level of camel-stream and camel-core bundle
"fixed" this exceptions of not finding the components .
But now I'm getting:
17:54:07.812 ERROR o.a.camel.processor.DefaultErrorHandler:215Failed
delivery for (MessageId: ID-54038-1363798294273-1-2 on ExchangeId:
ID-5403
I need to create a schedule, i.e. a list of messages with a specific delivery
time, with 100s of milliseconds accuracy. The route has only one recipent.
Currently I have implemented it using ActiveMQ and the AMY_SCHEDULED_DELAY.
The scheduling is working, but the accuracy is poor; the messages get
> How do we create the csv with double quotes using camel csv component ? is
> it possible ?
Actually I've already explained this in my previous post. Please do
kindly refer to it. :)
Best regards.
--
Henryk Konsek
http://henryk-konsek.blogspot.com
Hi Claus,
sorry for being unclear.
My Testroute running on Windows7 client is following;
from("ftp://"; + getFTPServerAddress() +
"/test/ftpmove" +
"?password=top_secret" +
"&ftpClient.dataTimeout=3" +
In our input csv I am getting the data with double quotes (" "). like below
"ID","NAME","ADDR"
"1","Sarfaraj Sayyad","Pune,India"
but camel csv component created without double quotes. (1,Sarfaraj
Sayyad,Pune,India )
How do we create the csv with double quotes using camel csv component ? is
i
Hi
Not sure if you can configure the http client to follow redirects,
that may allow the http client
to detect the redirect and provide the credentials for basic auth
after the redirect.
On Wed, Mar 20, 2013 at 1:37 PM, cgsk wrote:
> Hi There,
>
> I am using Jetty endpoint exposed which invoke
Hi
Not sure, I am afraid you may need to debug the code a bit or check
the logs etc.
Did you find out more about this?
On Sun, Mar 17, 2013 at 10:17 PM, hangstrap wrote:
> Hi
>
> I have been trying to use camel-couchdb to send data to a couchDb datastore
>
>
> My code looks like
>
> .to(
> "co
I replaced the old 2.10.3 camel bundles with the new 2.10.4 ones.
But now camel somehow even can't start because of not finding its
components:
e.g.
Failed to resolve endpoint: stream://out due to: No component found with
scheme: stream
or
Failed to resolve endpoint: direct://WS due to: No comp
Hi
Yeah I am not sure with the nature of guava eventbus. If its pub/sub
based then yeah it could make sense to allow 2+ consumers on the same
topic name.
For that to happen, the endpoint need to implement, then Camel knows its allowed
http://camel.apache.org/maven/current/camel-core/apidocs/org/a
On Wed, Mar 20, 2013 at 2:10 PM, rouble wrote:
> Camel aficionados,
>
> I have a simple http proxy route in Camel 2.8:
> from("servlet:///proxyWebService/api/?matchOnUriPrefix=true")
> .process(preprocessor)
>
> .recepientlist("https4://realWebService:8443/api/?bridgeEndpoint=true&thr
i use to extract some information from an xml file to insert them into a jdbc
data base this is what i did and it doesn't work
**main***
public class Cntx {
/**
* @param args
* @throws Exception
*/
public static void main(S
In trace mode:
2013-03-20 14:37:01 - [devcyp05@192.168.0.203/tmp/JFL] FtpConsumer
INFO Connected and logged in to: ftp://devcyp05@192.168.0.203:21
2013-03-20 14:37:01 - [devcyp05@192.168.0.203/tmp/JFL] FtpConsumer
TRACE doPollDirectory from absolutePath: tmp/JFL, dirName: nu
Hi all !
I have the same problem with ftp transfert ( 550 Failed to change
directory.)
I am working with the 2.10.5-SNAPSHOT
An anonymous transfert from public ftp like :
from("
ftp://ftp.mozilla.org/pub/mozilla.org/b2g/manifests/1.0.0/2012/08/2012-08-15?stepwise=false
")
.to("file://C:/temp/
Hi
Yeah this can be a good idea. I added a comment on that JIRA.
Just keep on hacking on it and make it mature and ready for donation.
On Mon, Mar 18, 2013 at 1:55 PM, ladoe00 wrote:
> Hi,
>
> I've created a JIRA issue a few weeks ago on this topic and I would like
> to know if this could be
Hi
So what is the status of your test. Can you break it down more clearly
what works and doesn't work for you?
Also can you post how you have configured the Camel ftp endpoints.
On Wed, Mar 20, 2013 at 11:42 AM, Lutter, Robin
wrote:
> Hi Claus,
>
> Sorry for late response. Yes, I have successf
I am using Camel 2.9.1 and Java DSL.
I attempted to setup an expiration time for my custom message being sent to
a queue such as:
.from()
// DO some processing and create message
.setHeader("JMSExpiration", constant(System.currentTimeMillis() + 3000))
.setHeader("JMSDeliveryMode
Oki, thanks Claus for answer. I 've created the jira
https://issues.apache.org/jira/browse/CAMEL-6186.
2013/3/20 Claus Ibsen-2 [via Camel] <
ml-node+s465427n5729482...@n5.nabble.com>
> Hi
>
> Yeah that seems like a good improvement. Feel free to log a JIRA ticket
> http://camel.apache.org/contri
Hi Claus,
Sorry for late response. Yes, I have successfully tested the patch in our
environment. Thanks for applying it.
Yesterday exception was gone but files where not moved using both SNAPSHOT
versions
Today my experience is, that using 2.10.5-SNAPSHOT with windows client and ftp
server runn
Add a transformation from CSV to Map object before the aggregator.
Then let the aggregator store a list of maps, or a map of maps, in the
exchange body.
You can then use this list in any subsequent transformation.
It all depends on what it is you intend to do with the data after it
has been aggr
Thanks for the reply.
Would I be able to do the following? The 3 CSV files will contain different
information. I need to poll for these 3 files and get 3 Map objects out of
those 3 CSV files. I've seen the aggregation examples from the Camel
documentation, but there we combine the old and the new
On Wed, Mar 20, 2013 at 10:07 AM, sarfaraj wrote:
> I just reversed the **and ** still don't see any exception
>
>
> uri="sftp://root@10.0.0.1//temp?password=test123&throwExceptionOnConnectFailed=true&noop=true"/>
>
>
Check the logs what happens, could be sftp does not throw any
exception for i
On Tue, Mar 19, 2013 at 11:47 AM, hefiso
wrote:
> Hi
>
> I am using the Cache component where the elements are set to expire after,
> say, 5 minutes.
>
> However, when the component receives the operation CamelCacheCheck it does
> *not* check for expiry of the element but only checks if the elemen
Hi
Yeah that seems like a good improvement. Feel free to log a JIRA ticket
http://camel.apache.org/contributing.html
And patches is of course welcome.
On Tue, Mar 19, 2013 at 6:31 PM, Gardella juan
wrote:
> Hi,
>
> I have a route that is processing a file. So the body is an input stream. I
> w
I just reversed the **and ** still don't see any exception
ftp://root@10.0.0.1//temp?password=test123&throwExceptionOnConnectFailed=true&noop=true"/>
--
View this message in context:
http://camel.465427.n5.nabble.com/sftp-not-throwing-exception-tp5729470p5729481.html
Sent from the Camel - U
On Wed, Mar 20, 2013 at 9:29 AM, mdo wrote:
> Claus Ibsen-2 wrote
>> The file component has move and moveFailed options where you can
>> specify the directories to move the file.
>
> Sorry, I think I missed to describe a detail. The route should be more like
> this:
>
> 1. from: file:///incoming/?
hello,
I would like to use the CamelSpringJUnit4ClassRunner annotations on my
tests. I've read the instructions on
http://camel.apache.org/spring-testing.html, which says "Using
CamelSpringJUnit4ClassRunner runner with the @RunWith annotation [..]
provides the full feature set of Spring Test with s
Hello,
On Tue, Mar 19, 2013 at 11:22 PM, Chris Wolf wrote:
> On Mon, Mar 18, 2013 at 4:57 PM, Pontus Ullgren wrote:
>> Hello Chris,
>>
>> On Mon, Mar 18, 2013 at 8:54 PM, Chris Wolf wrote:
>>> Claus,
>>>
>>> I have a few further questions about CronScheduledRoutePolicy. I
>>> noticed that it h
Claus Ibsen-2 wrote
> The file component has move and moveFailed options where you can
> specify the directories to move the file.
Sorry, I think I missed to describe a detail. The route should be more like
this:
1. from: file:///incoming/?moveFailed=B
2. somehow filter/process the unmarshalled d
On Tue, Mar 19, 2013 at 9:13 PM, mdo wrote:
> Hello,
>
> I'm looking for a solution for processing (CSV) files with this flow:
> * consume a list of CSV files (file:///incoming/)
> * unmarshal the CSV contents of each file and process it with a bean
> * if the processing was successful move the
Hi
Maybe take a look at interceptors
http://camel.apache.org/intercept
On Wed, Mar 20, 2013 at 1:28 AM, santhosh wrote:
> My architecture needs to multicast to multiple endpoints which will be
> constructed dynamically and before the message is sent to end point it needs
> to be customized.Now
Hi
Check the logs what is happening. You can enable DEBUG logging on the
org.apache.camel.component.file.remote package to see what goes on.
Also if you download big files, use the localWorkDirectory option so
you wont read the files into memory. As 500 MB may affect your
ServiceMix server.
And i
Its the chicken and egg. The Camel error handler does normally only
trigger if a message has been consumed.
Now you have the consumer fail before it can route a message into the
Camel route.
You can use a custom poll strategy, see details here
http://camel.apache.org/file2
And from Camel 2.10 onw
56 matches
Mail list logo