Re: Help: FTP/SFTP File Delete Problem and FTP/SFTP Polling Problem
Hey buddy
I had faced similar issue few months back.
It so happened that my ftp admin hadn't provide delete and write
authorizations to my ftp credentials .
It would be a good idea to check with ur ftp admin personnel if these
rights are provided to ur ftp credentials.
Cheers
Reji
On 9 Jan 2015 12:36, yeandone willcours...@gmail.com wrote:
Hi, All.
I have an issue deleting a file with delete=true from a SFTP consumer.
My
route looks like the following:
route id=A_ROUTE
from
uri=
sftp:am...@xxx.com?password=xxxamp;delete=trueamp;filter=#fileFilter/
choice
when
simple${body} != null/simple
multicast
to uri=direct:a/
to uri=direct:b/
/multicast
/when
otherwise
to uri=direct:b/
/otherwise
/choice
to
uri=controlbus:route?routeId=A_Routeamp;action=stop /
/route
whenever it runs, it will end up
WARN Camel (platformSchedulerCamel) thread #7 - sftp://xxx
org.apache.camel.component.file.GenericFileOnCompletion - Rollback file
strategy:
org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy@4b474b47
for file: RemoteFile[a.txt]
Does anyone have any idea why it happens? What I want to do is deleting
original file after it's processed by direct: a and direct: b and then stop
the route which will stop the file polling from the sftp location. If
nothing is picked, then I want to do some processing in direct:b and then
stop the route.
If I remove
to uri=controlbus:route?routeId=A_Routeamp;action=stop / at the end,
the file will be deleted. However, the sftp consumer will never stop and
keep polling stfp, which I do not want to happen.
Any help or any ideas will be appreciated!!!
Thanks,
W
--
View this message in context:
http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Intermittent error: No content to map due to end-of-input
I read this thread and added convertBodyTo(String.class) after the wiretap and before unmarshal(). the error is gone. http://t166678.apache-camel-user.apacheforum.info/wiretap-problem-t166678.html any idea why a convert to string will resolve the issue? -- View this message in context: http://camel.465427.n5.nabble.com/Intermittent-error-No-content-to-map-due-to-end-of-input-tp5760725p5761661.html Sent from the Camel - Users mailing list archive at Nabble.com.
Apache Camel SFTP
I am working in a piece of code that routes from SFTP input to a bean process and then to SFTP output. So, my process takes about 15 minutos to complete and when they finishes, the Camel try to delete a input file from SFTP input route. At this moment, the FTP server throws an error: 13 Jan 2015 18:21:26 DEBUG org.apache.camel.component.file.remote.FtpOperations.deleteFile - Deleting file: ../flex-brazil/Portal_Forn/request_appr/364/NF_4.txt 13 Jan 2015 18:21:26 WARN org.slf4j.helpers.MarkerIgnoringBase.warn - Error during commit. Exchange[org.apache.camel.component.file.GenericFileMessage@3207779]. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - File operation failed: 421 Timeout (900 seconds): closing control connection. FTP response 421 received. Server closed connection.. Code: 421] org.apache.camel.component.file.GenericFileOperationFailedException: File operation failed: 421 Timeout (900 seconds): closing control connection. FTP response 421 received. Server closed connection.. Code: 421 at org.apache.camel.component.file.remote.FtpOperations.getCurrentDirectory(FtpOperations.java:701) at org.apache.camel.component.file.remote.FtpOperations.deleteFile(FtpOperations.java:224) at org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy.commit(GenericFileDeleteProcessStrategy.java:71) at org.apache.camel.component.file.GenericFileOnCompletion.processStrategyCommit(GenericFileOnCompletion.java:124) at org.apache.camel.component.file.GenericFileOnCompletion.onCompletion(GenericFileOnCompletion.java:80) at org.apache.camel.component.file.GenericFileOnCompletion.onComplete(GenericFileOnCompletion.java:54) at org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:100) at org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:228) at org.apache.camel.util.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:61) at org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:613) at org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:581) at org.apache.camel.processor.CamelInternalProcessor$InternalCallback.done(CamelInternalProcessor.java:240) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:173) at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:401) at org.apache.camel.component.file.remote.RemoteFileConsumer.processExchange(RemoteFileConsumer.java:99) at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:201) at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:165) at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:187) at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:114) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.commons.net.ftp.FTPConnectionClosedException: FTP response 421 received. Server closed connection. at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:367) at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:294) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:483) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:608) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:582) at org.apache.commons.net.ftp.FTP.pwd(FTP.java:1454) at org.apache.commons.net.ftp.FTPClient.printWorkingDirectory(FTPClient.java:2658) at org.apache.camel.component.file.remote.FtpOperations.getCurrentDirectory(FtpOperations.java:697) ... 25 more There are any parameter to teach the Camel to send keepalives to FTP server to avoid this situation? Thanks! -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-SFTP-tp5761656.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Help: FTP/SFTP File Delete Problem and FTP/SFTP Polling Problem
Hi, contractreji.
Thanks for the reply. I do have all the permissions because I use admin
credentials to access the sftp location. I wonder if you have any idea how
I can resolve the issue.
Thanks
On Tue, Jan 13, 2015 at 6:05 PM, contactreji [via Camel]
ml-node+s465427n5761660...@n5.nabble.com wrote:
Hey buddy
I had faced similar issue few months back.
It so happened that my ftp admin hadn't provide delete and write
authorizations to my ftp credentials .
It would be a good idea to check with ur ftp admin personnel if these
rights are provided to ur ftp credentials.
Cheers
Reji
On 9 Jan 2015 12:36, yeandone [hidden email]
http:///user/SendEmail.jtp?type=nodenode=5761660i=0 wrote:
Hi, All.
I have an issue deleting a file with delete=true from a SFTP consumer.
My
route looks like the following:
route id=A_ROUTE
from
uri=
sftp:[hidden email]
http:///user/SendEmail.jtp?type=nodenode=5761660i=1?password=xxxamp;delete=trueamp;filter=#fileFilter/
choice
when
simple${body} != null/simple
multicast
to uri=direct:a/
to uri=direct:b/
/multicast
/when
otherwise
to uri=direct:b/
/otherwise
/choice
to
uri=controlbus:route?routeId=A_Routeamp;action=stop /
/route
whenever it runs, it will end up
WARN Camel (platformSchedulerCamel) thread #7 - sftp://xxx
org.apache.camel.component.file.GenericFileOnCompletion - Rollback file
strategy:
org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy@4b474b47
for file: RemoteFile[a.txt]
Does anyone have any idea why it happens? What I want to do is deleting
original file after it's processed by direct: a and direct: b and then
stop
the route which will stop the file polling from the sftp location. If
nothing is picked, then I want to do some processing in direct:b and
then
stop the route.
If I remove
to uri=controlbus:route?routeId=A_Routeamp;action=stop / at the
end,
the file will be deleted. However, the sftp consumer will never stop and
keep polling stfp, which I do not want to happen.
Any help or any ideas will be appreciated!!!
Thanks,
W
--
View this message in context:
http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
If you reply to this email, your message will be added to the discussion
below:
http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486p5761660.html
To unsubscribe from Help: FTP/SFTP File Delete Problem and FTP/SFTP
Polling Problem, click here
http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5761486code=d2lsbGNvdXJzZXJhQGdtYWlsLmNvbXw1NzYxNDg2fDc4ODg5MzE5OQ==
.
NAML
http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml
--
View this message in context:
http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486p5761662.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache Camel SFTP
Hi Since you take 15 min to process the file, then try setting a higher session timeout on the FTP server. The keep alive checks are only in use when the ftp consumer is idle, not while it process a file. On Tue, Jan 13, 2015 at 9:39 PM, Luciano Nunes lnu...@gmail.com wrote: I am working in a piece of code that routes from SFTP input to a bean process and then to SFTP output. So, my process takes about 15 minutos to complete and when they finishes, the Camel try to delete a input file from SFTP input route. At this moment, the FTP server throws an error: 13 Jan 2015 18:21:26 DEBUG org.apache.camel.component.file.remote.FtpOperations.deleteFile - Deleting file: ../flex-brazil/Portal_Forn/request_appr/364/NF_4.txt 13 Jan 2015 18:21:26 WARN org.slf4j.helpers.MarkerIgnoringBase.warn - Error during commit. Exchange[org.apache.camel.component.file.GenericFileMessage@3207779]. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - File operation failed: 421 Timeout (900 seconds): closing control connection. FTP response 421 received. Server closed connection.. Code: 421] org.apache.camel.component.file.GenericFileOperationFailedException: File operation failed: 421 Timeout (900 seconds): closing control connection. FTP response 421 received. Server closed connection.. Code: 421 at org.apache.camel.component.file.remote.FtpOperations.getCurrentDirectory(FtpOperations.java:701) at org.apache.camel.component.file.remote.FtpOperations.deleteFile(FtpOperations.java:224) at org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy.commit(GenericFileDeleteProcessStrategy.java:71) at org.apache.camel.component.file.GenericFileOnCompletion.processStrategyCommit(GenericFileOnCompletion.java:124) at org.apache.camel.component.file.GenericFileOnCompletion.onCompletion(GenericFileOnCompletion.java:80) at org.apache.camel.component.file.GenericFileOnCompletion.onComplete(GenericFileOnCompletion.java:54) at org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:100) at org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:228) at org.apache.camel.util.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:61) at org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:613) at org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:581) at org.apache.camel.processor.CamelInternalProcessor$InternalCallback.done(CamelInternalProcessor.java:240) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:173) at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:401) at org.apache.camel.component.file.remote.RemoteFileConsumer.processExchange(RemoteFileConsumer.java:99) at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:201) at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:165) at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:187) at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:114) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.commons.net.ftp.FTPConnectionClosedException: FTP response 421 received. Server closed connection. at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:367) at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:294) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:483) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:608) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:582) at org.apache.commons.net.ftp.FTP.pwd(FTP.java:1454) at org.apache.commons.net.ftp.FTPClient.printWorkingDirectory(FTPClient.java:2658) at org.apache.camel.component.file.remote.FtpOperations.getCurrentDirectory(FtpOperations.java:697) ... 25 more There are any parameter to teach the Camel to send keepalives to FTP server to avoid this situation? Thanks! -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-SFTP-tp5761656.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
Re: Help: FTP/SFTP File Delete Problem and FTP/SFTP Polling Problem
Ok Thanks Claus. But if I keep the original code, will those warning messages have any negative impacts on my logics and route? On Mon, Jan 12, 2015 at 12:58 AM, Claus Ibsen-2 [via Camel] ml-node+s465427n5761580...@n5.nabble.com wrote: Hi You can use a route policy, and then stop the consumer in onExchangeDone http://camel.apache.org/routepolicy.html On Mon, Jan 12, 2015 at 8:31 AM, yeandone [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761580i=0 wrote: Will there be any risks if I stop route like that? After the exchange is processed by both end endpoints direct a and direct b. I need to stop the route so that the consumer can stop polling. Can you please give some ideas to stop route/consumer properly so that the route and consumer will stop properly without any risks? On Sun, Jan 11, 2015 at 9:36 PM, Claus Ibsen-2 [via Camel] [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761580i=1 wrote: On Sun, Jan 11, 2015 at 3:48 AM, yeandone [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761572i=0 wrote: Thanks, Claus. Will try a new version. But do you know why it always prompts the following warnings when the routes stops? Will they impact anything and the original file? 1. If choose not to delete the file, it prompts when the route stops: WARN Camel (platformSchedulerCamel) thread #7 - sftp://xxx org.apache.camel.component.file.GenericFileOnCompletion - Rollback file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@4b474b47 for file: RemoteFile[a.txt] Its because you stop the route from the route, eg then the current exchange is forced to be stopped and thus wants to rollback. 2. If choose not to delete the file, it prompts when the route stops: WARN Camel (platformSchedulerCamel) thread #7 - sftp://xxx org.apache.camel.component.file.GenericFileOnCompletion - Rollback file strategy: org.apache.camel.component.file.strategy.GenericFileNoOpProcessStrategy@4b474b47 for file: RemoteFile[a.txt] On Fri, Jan 9, 2015 at 11:24 PM, Claus Ibsen-2 [via Camel] [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761572i=1 wrote: Try with newer release, there may have been a bug fix On Fri, Jan 9, 2015 at 6:47 PM, yeandone [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761545i=0 wrote: HI, Claus. Thanks for the prompt reply! I am using Camel 2.12. I also tried adding aync=true in controlbus to uri=controlbus:route?routeId=A_Routeamp;aync=trueamp;action=stop / It does help delete the file, but it has some issues with polling. Until the file get deleted and control bus stops, the route still keeps polling for a while. What I want to do is deleting original file after it's processed by direct: a and direct: b and then stop the route which will stop the file polling from the sftp location. If nothing is picked, then I want to do some processing in direct:b and then stop the route and polling immediately. Any ideas to resolve the issue? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486p5761535.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761545i=1 Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8: http://fabric8.io/ -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486p5761545.html To unsubscribe from Help: FTP/SFTP File Delete Problem and FTP/SFTP Polling Problem, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Help-FTP-SFTP-File-Delete-Problem-and-FTP-SFTP-Polling-Problem-tp5761486p5761561.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: [hidden email] http:///user/SendEmail.jtp?type=nodenode=5761572i=2 Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action:
Camel jms listener on JMSReplyTo bahaviour
Hi all, from the documentation I saw that when within a Camel route I send a msg on a jms destination, with either a replyTo option set or specifying the MEP as InOut, Camel will then instantiate a jms listener to listen to that JMSReplyTo dest. So far so good, at least if that is correct. My point now is, how can I control that listener, I mean when a msg is delivered to my replyTo dest, and the listener receives it, how can I get hold of that msg? On slightly different note, how would you implement a scenario where a dynamic replyTo should be used? I mean from here http://camel.465427.n5.nabble.com/set-jms-reply-to-in-message-header-td4420767.html I got to know that Camel, and with good reason, does not implement that feature, but it seems to me that the replyTo is meaningless then. If I want to send a msg using a Rest PUT, where a camel rest consumer would read it, pass to a processor, and then sent a response back to myself on a destination specified by the JMSReplyTo, how'd go with this? Hopefully all is clear enough. Kind regards, Ettore. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-jms-listener-on-JMSReplyTo-bahaviour-tp5761654.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel jms listener on JMSReplyTo bahaviour
Hey Ett I understand that u are sending request via REST request. You should be getting the response as a REST response with some http status codes isn't it ? Why are you polling the jms queue for the response from your processor . It should already build build a response and send it back to ur REST client Cheers Reji On 13 Jan 2015 22:59, Ettoregia ettore...@gmail.com wrote: Hi all, from the documentation I saw that when within a Camel route I send a msg on a jms destination, with either a replyTo option set or specifying the MEP as InOut, Camel will then instantiate a jms listener to listen to that JMSReplyTo dest. So far so good, at least if that is correct. My point now is, how can I control that listener, I mean when a msg is delivered to my replyTo dest, and the listener receives it, how can I get hold of that msg? On slightly different note, how would you implement a scenario where a dynamic replyTo should be used? I mean from here http://camel.465427.n5.nabble.com/set-jms-reply-to-in-message-header-td4420767.html I got to know that Camel, and with good reason, does not implement that feature, but it seems to me that the replyTo is meaningless then. If I want to send a msg using a Rest PUT, where a camel rest consumer would read it, pass to a processor, and then sent a response back to myself on a destination specified by the JMSReplyTo, how'd go with this? Hopefully all is clear enough. Kind regards, Ettore. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-jms-listener-on-JMSReplyTo-bahaviour-tp5761654.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: how to send a new message to an endpoint, continue with the current one
You can even check out Camel ProducerTemplate .. Cheers Reji On 13 Jan 2015 14:34, hqi65334 hqi65...@mciek.com wrote: Hi, from(direct:start).process(processorA).to(myqueue).processor(processorB); after processing with processorA I'd like to send a customized message to the myqueue and continue with the output of processorA in processorB. What is the best way to to it in camel? My first idea was to send it to a seda:queue and create a customized message there and then send it to myqueue Thanks for help! -- View this message in context: http://camel.465427.n5.nabble.com/how-to-send-a-new-message-to-an-endpoint-continue-with-the-current-one-tp5761616.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: how to send a new message to an endpoint, continue with the current one
Hi, You can use the wiretap pattern to do this. Regards, 2015-01-13 9:55 GMT+01:00 hqi65334 hqi65...@mciek.com: Hi, from(direct:start).process(processorA).to(myqueue).processor(processorB); after processing with processorA I'd like to send a customized message to the myqueue and continue with the output of processorA in processorB. What is the best way to to it in camel? My first idea was to send it to a seda:queue and create a customized message there and then send it to myqueue Thanks for help! -- View this message in context: http://camel.465427.n5.nabble.com/how-to-send-a-new-message-to-an-endpoint-continue-with-the-current-one-tp5761616.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Charlie Mordant Full OSGI/EE stack made with Karaf: https://github.com/OsgiliathEnterprise/net.osgiliath.parent
Re: [feature request] Reporting startup failure
I'm sorry. I can't reproduce it now. I'm sure I saw it but please assume it's my error! -- View this message in context: http://camel.465427.n5.nabble.com/feature-request-Reporting-startup-failure-tp5761531p5761620.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: how to send a new message to an endpoint, continue with the current one
Thanks, I will try it.
.wireTap(myqueue).newExchangeBody(new Expression() {
public T T evaluate(Exchange exchange, ClassT type) {
return (T) new QueueMsg();
}
}).end()
I assume all current properties and headers would not be sent to the queue
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-send-a-new-message-to-an-endpoint-continue-with-the-current-one-tp5761616p5761618.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: What's wrong in my REST paths?
Sorry for the delay, Claus... I'm using a Tomcat 6 (I'm aware Camel 2.14.1 does not support Java 6, but I cannot change that for now) in my dev line, though on my dev machine it's running on Jetty, via mvn jetty:run-war. I'll build that test and see what happens... Thanks On Sun Jan 04 2015 at 14:50:30 Claus Ibsen claus.ib...@gmail.com wrote: The rest-dsl is just a facade on the choosen transport. And in your case its the servlet component. So I wonder if you can get that working to match a .csv uri? It may be that the servlet component from either Camel or the actual impl in the java servlet server may not support matching using dot. Though I would be a bit surprised. Maybe you can build a simple unit test in camel-servlet that just tries to get a url with a .csv and see if you can get that working or not. Then we can use that to track down. And btw what server do you use? Is it tomcat or something else? On Wed, Dec 31, 2014 at 9:19 AM, Giorgio Vespucci giorgio.vespu...@gmail.com wrote: Hi all This is my SO question about Rest paths: http://stackoverflow.com/questions/27707664/whats- wrong-in-my-apache-camel-rest-paths Many thanks for any hint Happy 2014 ending! :) -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8 http://hawt.io/fabric8: http://fabric8.io/
Where is logName used?
The following code: .log(LoggingLevel.ERROR, com.foo.server.ngw.router, Account Not Found. Message discarded.).stop(); Results in the following in the log: 10:12:11,690 ERROR org.slf4j.helpers.MarkerIgnoringBase:145 error() - Account Not Found. Message discarded. I was expecting to see com.foo.server.ngw.router somewhere above? Not sure what else it is supplied for..? James
Re: camel xmljson add @ signs to the json output. how to remove the @ signs
Do the component developers follow this list? I'd love to see a switch as well. Issue tracker for components ? On Wed Nov 26 2014 at 1:44:01 AM Claus Ibsen claus.ib...@gmail.com wrote: Hi Did you get in contact with the xmjson team about the issue and if they are willing to add a flag to turn this on/off etc? On Tue, Nov 18, 2014 at 9:18 AM, Claus Ibsen claus.ib...@gmail.com wrote: Hi Ah great to know it was hardcoded. I would suggest to ask them to add an option so you can turn that off. As there are use cases where you only need a one way transformation. They could also consider different strategies how to control this mapping. So there is a default strategy that does as today. And then people can switch to different ones, such as one that simply dont include those signs. And another that allow end users to provide their own mapping code to have 100% control how they want to do that. An alternative is that we introduce an option in the Camel component but then it would need to process the output message and remove those @ signs. But its IMHO better to improve this in the xmljson library itself. On Mon, Nov 17, 2014 at 9:10 PM, salemi sal...@avaya.com wrote: Hi Clause, I looked at their json-lib code and based on what I read they need to have the @ sign for the attributes and # for the text elements. They need those annotations to be able to covert a json properly back to xml. The @ and # signs are hard coded in their code. Do you think I should asked to change the code? Ali - Alireza Salemi -- View this message in context: http://camel.465427.n5.nabble. com/camel-xmljson-add-signs-to-the-json-output-how-to-remove-the-signs- tp5759013p5759220.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8: http://fabric8.io/ -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8 http://hawt.io/fabric8: http://fabric8.io/
