Single threaded route execution

Hi I got troubles, cause several threads are executing my route at the same time Now I want to make sure the route can only be executed by max. 1 thread at a time. But I couldn't find the definition how to do that. In older versions there was a .synchronized() Or a .executorService(Executors.n

Error with dynamic HTTPS call

Hi I have an error when initiating a dynamic HTTPS call as follows: .toD("${header.URLString}") The URLString in this case is: https://apps.synesty.com/studio/api/flow/v1?id=J4M_SportXX_Verkaufsauftraege_abholen&t=Ubk15h-jeO50n-qQ31y9-a7ixv3&proxyHost=webproxy.dc.migros.ch&proxyPort=9099&httpMe

RE: Issue with ProducerTemplate (processor not started)

: users@camel.apache.org Subject: Re: Issue with ProducerTemplate (processor not started) On Fri, Aug 11, 2023 at 5:08 PM Reto Peter wrote: > Hi Claus > > You mean I should just change my executeQuery route this way, from > dynamic to static? > > OLD > from("direct:

RE: Issue with ProducerTemplate (processor not started)

a new endpoint/producer per SQL query combination. On Fri, Aug 11, 2023 at 4:39 PM Reto Peter wrote: > Hi Claus > > Thanks for fast response. > The call is to an SQL query: > result = producer.requestBodyAndHeader("direct:executeQuery", "", > "sqlquery

RE: Issue with ProducerTemplate (processor not started)

;) .toD("sql:${header.sqlquery}") ; -Original Message- From: Claus Ibsen Sent: Friday, 11 August 2023 22:29 To: users@camel.apache.org Subject: Re: Issue with ProducerTemplate (processor not started) What endpoint do you send to with the producer template On Fri, Aug 11, 2023

Issue with ProducerTemplate (processor not started)

Hi I got an issue with the ProducerTemplate used inside a bean The Bean class called Resolvement.class injects the ProducerTemplate as follows: @EndpointInject private ProducerTemplate producer; inside the bean resolve() method, I do then use this producer like this: producer.requestBodyAndHe

Route doesnt get started

Hi I have a strange situation with a Route, which is not getting started when it is called by another Route. If the Route is not called by any other Route, it is getting started. Example: from("direct:checkClientSession") .routeId("checkClientSession") .to("log:myLogger?showAll=true") .log("

How to clear the cache of MemoryIdempotentRepository

Hi all I have a route, which checks for uniqueness of a certain value (find duplicates, and in case of duplicates, the route will throw an exception). That works fine so far. At the end of the route, I want to clear the cache, so next time the route gets executed, it shall start with an empty c

PollEnrich with File from classpath

Hi I have a simple issue with the following route: This works .pollEnrich("file://src/main/resources/supplier/xxx/article?fileName=ExcelFooter.txt&noop=true&idempotent=false") But I need to replace the classpath 'src/main/resources' folder, cause otherwise it doesn't work when its deployed. How

Consume Files with specific dynamic content only

Hi I want to read all files inside a directory, but only process files with a specific file content. The specific file content is dynamic. It is available inside the route as a Property, Header or Body The reason is, cause I have any files inside a directory, (for ex. Orders, Invoices) and the

Autowiring fails with Spring Boot 3

under Spring Boot 3? Can anyone guide me to fixing this supposedly autowiring problem that I've spent my morning trying to debug? I am fully prepared for it to be a simple case of a missing annotation, but I just can't see it myself. Peter

RE: Splitter and Aggregater onCompletion

:53 AM Claus Ibsen wrote: > Hi > > Ah sorry there is both an onCompletion EIP you can use in routes. > And then AggregationStrategy with overloaded/default methods for > various callbacks. > > > > On Tue, Nov 8, 2022 at 11:39 AM Reto Peter > wrote: > >> Hi

RE: Splitter and Aggregater onCompletion

ing exchange which has onCompletion. Its a bit difficult to explain, if you have the CiA2 book then take a look in the EIP chapter about the aggregator. On Tue, Nov 8, 2022 at 9:43 AM Reto Peter wrote: > Hi all > > I am using a Splitter and an Aggregator. > All of the output are writte

Splitter and Aggregater onCompletion

Hi all I am using a Splitter and an Aggregator. All of the output are written into the final result. But at the end of the Split, I wanted to add something more. This is where the 'onCompletion' method inside the Aggregator can be used (in my mind, cause that works for scenarios without a Splitt

RE: Predicates

icates Hi systemConfig.isActive is a key name, so that only works if the property is really named like that. Its not doing any kind of method call - i.e. calling isActive() on the property with key , that the simple can do. On Tue, Oct 18, 2022 at 9:01 AM Reto Peter wrote: > Hi Clause > > So for a he

RE: Predicates

") This is not simple language, but refers to a exchange property key with the given name. You need to use simple as predicate instead of exchangeProperty On Mon, Oct 17, 2022 at 7:38 PM Reto Peter wrote: > Hi > I have a simple question about the Predicates I got a syst

Predicates

Hi I have a simple question about the Predicates I got a systemConfig object, which has 2 getters/setters. The systemConfig object is set as an exchange property. When I use a the simple function, that works! from("direct:testPredicates") .to("direct:getSystemConfig") .choice() .when(simple

RE: Unable to locate Spring NamespaceHandler

on to be able to read the parameters of the Login object? In my case it has public getters and setters and is annotated like this: @XmlAccessorType(XmlAccessType.FIELD) @XmlType(name = "login", propOrder = { "userName", "password", "anotherId","an

CXF: Unable to locate Spring NamespaceHandler

Hi I try to invoke my first Webservice with CXF inside Camel. Camel: 3.18.2, Java 15, SpringBoot 2.7.3 But got the following error: Configuration problem: Unable to locate Spring NamespaceHandler for XML schema namespace [http://camel.apache.org/schema/cxf] My POM includes CXF as follows:

SFTP fails after upgrade to Camel 3.18.0

Hi In Camel 3.16.0 we did successfully use the SFTP component like this: from("sftp://{{sftp.host}}:{{sftp.port}}/{{sftp.remotedir.from.customer}}"; + "?username={{sftp.username}}" + "&password={{sftp.password}}" + "&u

RE: DropBox expired_token

t is short lived? Or do you know if its standard at DropBox to have tokens limited to 4 hours? If its so short lived, then we should look at a way for Camel to be able to automatic extend the token expiry, fetch a updated token, or what means DropBox supports. On Mon, Apr 11, 2022 at 8:14 AM

DropBox expired_token

Hi I have successfully used the dropbox component for download, upload and delete files. You can see my implementation below, cause there was some important issues to solve before it worked Actually the only problem I have is the expired_token. The generated token (which I created in the app c

RE: JdbcAggregationRepository is not permanently?

corresponding headers in the aggregated Exchange. On 05/04/2022 10:12, Reto Peter wrote: > Hi > > Using the JdbcAggregationRepository I am trying to save the relation between > my incoming messages and the aggregate, as a 1-n relation. It is actually the > EDI Messages (

JdbcAggregationRepository is not permanently?

Hi Using the JdbcAggregationRepository I am trying to save the relation between my incoming messages and the aggregate, as a 1-n relation. It is actually the EDI Messages (Single message) into the EDI Interchange (Collection of messages). When I run the route, I see that the entries are availabl

RE: CamelSqlGeneratedKeyRows is not updated

alling the 2nd insert .setHeader("CamelSqlRetrieveGeneratedKeys").simple("true") On Wed, Mar 23, 2022 at 9:59 AM Reto Peter wrote: > > Hi > > I have a route with 2 following SQL INSERT commands. > One inserts into table A (CamelSqlGeneratedKey

Re: CamelSqlGeneratedKeyRows is not updated

Ya sorry. Camel version: 3.15.0 On 23 March 2022 17:03:19 Andrea Cosentino wrote: Report the camel version, please Il mer 23 mar 2022, 09:59 Reto Peter ha scritto: Hi I have a route with 2 following SQL INSERT commands. One inserts into table A (CamelSqlGeneratedKeyRows is correct) Next

CamelSqlGeneratedKeyRows is not updated

Hi I have a route with 2 following SQL INSERT commands. One inserts into table A (CamelSqlGeneratedKeyRows is correct) Next inserts into table B (CamelSqlGeneratedKeyRows is wrong, the value is not updated, it remains the same) I am using mySQL and Java 11 My simplified route: fro

RE: Camel fails to rename/delete the source file

and read it into memory as a string and then give that to smooks. Then smooks dont have anything to worry about closing file handles / resources So try add before the processor .convertBodyTo(String.class) On Mon, Mar 7, 2022 at 10:40 AM Reto Peter wrote: > > Hi Claus > > Thanks

RE: Camel fails to rename/delete the source file

. On Mon, Mar 7, 2022 at 9:14 AM Reto Peter wrote: > > I am trying to convert an EDIFACT file into an XML file. > > The conversion is done with smooks. The conversion works fine. The target > file is successfully converted and also written to the disk. > > The problem arises

Camel fails to rename/delete the source file

I am trying to convert an EDIFACT file into an XML file. The conversion is done with smooks. The conversion works fine. The target file is successfully converted and also written to the disk. The problem arises after when Camel try to move the file to the .camel subdir. The source file is copied t

RE: Re: Running Camel Main from Eclipse

sspath. > > > On Wed, Jan 19, 2022 at 1:20 PM Peter Lundin Q > wrote: > > > > Hi, > > > > I noticed that when upgrading from 3.13.0 to 3.14.0 the possibility of > > running a Camel Main application from Eclipse stopped working both for "Run &g

Running Camel Main from Eclipse

er.addRoutes(ProcessorReifier.java:579) at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:236) ... 14 more Best Regards /Peter

[ANNOUNCE] Apache Camel Quarkus 1.5.0 Released

details please take a look at the release notes at https://camel.apache.org/releases/q-1.5.0/ You may also want to check the blog post https://camel.apache.org/blog/2020/12/camel-quarkus-release-1.5.0/ Thanks, Peter Palaga

RE: Camel CXF with SOAP 1.1 and SOAP 1.2

IQA0oFCAQSATFKBQgHEgExSgUICRIBMUoGCAoSAjI4UOBbWONsYONyaABwAHgAgAEAiAEAkgEAmAEDoAEBqgEHZ3dzLXdpesABAQ&sclient=psy-ab&ved=0ahUKEwi-qLu96tLsAhUIsJ4KHWNDCjsQ4dUDCA0&uact=5> seems like you are missing             org.apache.cxf             cxf-rt-transports-http-jetty             ${

Re: Camel CXF with SOAP 1.1 and SOAP 1.2

instance, which integrates with the route. The type of payload injected into the route depends on the value of the endpoint’s dataFormat option. Producer — (at other points in the route) represents a WS client proxy, which converts the current exchange object into an operation invocation on a remote

Re: Camel CXF with SOAP 1.1 and SOAP 1.2

s url parameter as it clearly asks) should help.     From: Peter Turányi [mailto:[hidden email] ] Sent: Thursday, October 22, 2020 6:33 AM To: [hidden email] Subject: RE: Camel CXF with SOAP 1.1 and SOAP 1.2   I am sorry but I didn't found any useful code there.   My project contains standard

RE: Camel CXF with SOAP 1.1 and SOAP 1.2

ura...@pobox.sk" Dátum: 22.10.2020 15:06 Predmet: RE: Camel CXF with SOAP 1.1 and SOAP 1.2 Hi Peter,   my code looks similar to whats provided in the docs: https://camel.apache.org/components/latest/cxf-component.html <https://camel.apache.org/components/latest/cxf-component.html&g

Re: Camel CXF with SOAP 1.1 and SOAP 1.2

Hello. Sorry, I don't know answer. But tell me how do you configure cxf beast to work with Camel Apache. I have tried but I have no luck. :( __ > Od: "Shenavai, Manuel [via Camel]" > Komu: "PT" > Dátum: 22.10.2020 10:27 > Predmet: Came

Apache Camel Fuse soap CXF proxy service marshal jacksonXML output

   I use Red Hat Fuse CodeReady Studio 12.16.0.GA. I have created soap proxy service using CXF. Here is main part of proxy service wsdl. http://schemas.xmlsoap.org/wsdl/"; xmlns:xs="http://www.w3.org/2001/XMLSchema"; xmlns:soap="http://schema

Re: Apache Camel Fuse soap proxy service CXF input type

  I found that null input is caused by log activity in route. When I have removed log Transfomer bean get input message without problem. Now I have to parse input message. __ > Od: "Peter Turányi" > Komu: users@camel.ap

Apache Camel Fuse soap proxy service CXF input type

I use Red Hat Fuse CodeReady Studio 12.16.0.GA. I have created soap proxy service using CXF. I have defined start of route uri="cxf:bean:countryInfoProxyServiceClient?dataFormat=RAW"/> because PAYLOAD and CXF-MESSAGE data formats cause exception Message part {http://www.demo.com/countryinfo}VsetkyI

Apache Camel Fuse soap proxy service CXF input type

I use Red Hat Fuse CodeReady Studio 12.16.0.GA. I have created soap proxy service using CXF. I have defined start of route uri="cxf:bean:countryInfoProxyServiceClient?dataFormat=RAW"/> because PAYLOAD and CXF-MESSAGE data formats cause exception Message part {http://www.demo.com/countryinfo

help route jms to -> from ?

Here are my camel routes. The issue is the "price" route (has a JMS consumer) never runs (receives a message)? It seems like the "taxes" never sents .to(finalPrice) message? : Any ideas? Thanks in advance, Peter. // workflow 1.1 (Entry Point & Add T

camel-jms: how to set TLS parameters for network connector in Spring Boot and Java

, this seems not being supported by camel-jms. CiA lists some components, but not camel-jms Spring Boot docs do not mention parameters related to activemq and TLS. So what is the right way to set the TLS parameters, ideally externalized via application.properties ? Peter

camel-ftp: meaning of option "UseUserKnownHostsFile" in combination with "knownHostsUri"

ponent.file.remote.SftpOperations] - JSCH -> Permanently added 'sftpserver (RSA) to the list of known hosts. ... Why do I have to add this option ? Shouldn't specifying knownHostsUri rule out files based stuff automatically ? Bonus question: should the target server key be written

[solved] activemq-camel: accessing a javax.jms StringProperty ?

indeed, that works! I don't understand the background why the camel.Exchange class has less methods than the javax.jms.Message class, but as there is a clever "workaround" I am fine. Thanks Peter -Original Message- From: Steve Huston Sent: Tuesday, May 21, 2019 3:

activemq-camel: accessing a javax.jms StringProperty ?

getIn(); // cast not possible String prop = inMessage.getStringProperty("myprop"); // as only javax.jms does have the getStringProperty method org.apache.camel.Message outMessage=exchange.getOut(); outMessage.setHeader("CamelFileName",zipFileName); Is there a way to access the jms

RE: from camel.main.Main to camel.spring.Main: how to replace registry bind method without XML?

ally works with this example as i don't have an Azure account at the ready to verify, but I've been using the same pattern in other projects with success. https://github.com/runstache/camel-sample-springdsl On Mon, May 13, 2019 at 6:54 AM Marx, Peter wrote: > I want to move my use

from camel.main.Main to camel.spring.Main: how to replace registry bind method without XML?

redentials=#credsreg ) This is because camel.spring.Main has no bind method in contrast to camel.main.Main. What alternatives do I have to get my bean stored in a registry without using SpringXML, which would mean e.g. ? Can I use the default ApplicationContextRegistry then? Peter From: M

RE: [solved] camel-azure: syntax for setting blobnames dynamically when uploading files to BlockBlob ?

://issues.apache.org/jira/browse/CAMEL-13462 On Thu, Apr 25, 2019 at 5:35 PM Marx, Peter wrote: > > I found the solution myself in CiA, 2nd edition (which arrived today, > replacing my 1st edition now..), in chapter 2.5.1. > > Using .toD instead .to, Simple expressions are evaluated: &

[solved] camel-azure: syntax for setting blobnames dynamically when uploading files to BlockBlob ?

tials=#credsreg&operation=updateBlockBlob"); sets the name of the created blob to the filename of the source file. Peter -Original Message- From: Marx, Peter Sent: Tuesday, April 23, 2019 2:49 PM To: users@camel.apache.org Subject: camel-azure: syntax for setting blobnames dy

camel-azure: syntax for setting blobnames dynamically when uploading files to BlockBlob ?

lting blob has of course the content of the file which was uploadad last: from("file:c:\\mx\\source?delete=true") .to("azure-blob://shared1/mxtest/blobname?credentials=#credsreg&operation=updateBlockBlob"); How can I inject the filename found by "from" into t

RE: azure-blob with JavaDSL: can't set URI options with bean or any other method

I see.. Lookup does work now! Reading CiA I had assumed that the lookup for the (only) bean method happens automatically and would return a CloudBlob instance. Not sure if this my general misunderstanding or is special to using beans in URI. Thanks Peter -Original Message- From

RE: azure-blob with JavaDSL: can't set URI options with bean or any other method

can't set URI options with bean or any other method Hi You should use # to refer to a bean in the registry, eg to do a lookup. So use #client On Fri, Apr 19, 2019 at 10:56 AM Marx, Peter wrote: > > Hi, > > I want to add a route for the camel-azure component 2.23.0 in pur

azure-blob with JavaDSL: can't set URI options with bean or any other method

clientreg" - I assume the bean lookup does not work - would be my 2. question how to fix that.. The azureBlobClient option must be of type CloudBlockBlob, credentials of type StorageCredentials. How can I set the required credentials or client options in the URI ? Peter packa

Re: How to read messages from a queue in parallel

ground-queue-parallel-processing-ordered. It's Docker based, so no external dependencies is needed. The full code related to this thread can be found on https://github.com/pbillen/playground-queue-parallel-processing-ordered/blob/master/src/test/java/C_RabbitMQ_IT.java . Thanks. On Tue,

Re: How to read messages from a queue in parallel

es, for example during a service restart. I'll experiment and come back with my results. Thanks. On Mon, Dec 17, 2018 at 4:41 PM Valdis Andersons wrote: > Hi Peter, > > Given you have a header already identifying the message categories, you > could try to look i

How to read messages from a queue in parallel

Hi all, I am reading from a RabbitMQ queue as following: from("rabbitmq://localhost/?queue=camel&autoAck=false&concurrentConsumers=1& threadPoolSize=1&prefetchEnabled=true&prefetchCount=50") Some remarks about the configuration parameters: - I set `autoAck` to false to be able to acknowledge ma

Re: understanding InOut

to the end of the route and is an InOut, the Out from the last endpoint goes back to the 'from' starting point. http://camel.apache.org/request-reply.html -Steve -Original Message----- From: Peter Nagy (Jr) Sent: Friday, December 14, 2018 10:27 AM To: users@camel.apache.o

understanding InOut

I still don't quite grok how InOut works. When I set the exchange pattern to InOut, what exactly will happen? Will the *next* processor reply to the previous one? If so, how? If so, how does the previous processor act on the reply? Or is the InOut just about 1 Processor? If so, can e.g. a Proc

Re: throttling/backpressure on a route

check tomorrow. Thanks for all the tips so far. Valdis Andersons writes: > Hi Peter, > > Could you potentially use a message broker (RabbitMQ, ActiveMQ etc.) > downstream from the aggregator that is causing you concern? > > Mongo -> Aggregator -> Message Broker Queu

Re: throttling/backpressure on a route

t; and when it catches up tell B "OK please send more". Otherwise things will flow downstream, filling up memory. Surely constraining memory usage is a solved problem? I'm just too new to understand what pattern(s) solve it. > > > On Tue, Oct 16, 2018 at 10:18 AM Pe

throttling/backpressure on a route

Newbie question incoming. I have a route that looks like ... .setHeader("CamelMongoDbBatchSize", 128) .to("mongodb3:mymongo?...&operation=aggregate&outputType=MongoIterable") .split(constant(true)) .streaming() ... .aggregate(constant(true), new GroupedBodyAggregationStrategy()) .completionSize(1

Topics and temporary queues with a durable subscriber

Exchange through a non-CamelContext connection, I can access the headers - or if there’s something I can set on a new non-CamelContext connection to ensure the headers get passed through - that’d be an acceptable solution? Can anyone assist? I’ve spent a week or two on this already, so t

Re: NPE in org.apache.camel.test.junit4.CamelTestSupport.logCoverageSummary

Hi Claus > On 21 May 2017, at 17:06, Claus Ibsen wrote: > > No it ought to work with that little route as well. > > What version of Camel do you use? I see your later reply (sorry for my tardiness) - for clarity, I’m on 2.19.0. Thanks very much for the quick fix! Peter

NPE in org.apache.camel.test.junit4.CamelTestSupport.logCoverageSummary

atingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) ... If I simply add ".to("mock:result”)” to the end of the first route, the NPE disappears. Is this a problem in my implementation? Peter

jCIFS timeout settings

I have a camel route that needs to delete a file over CIFS. For the most part it works, but occasionally, I get a timeout from the CIFS server. jcifs.smb.SmbException: Transport1 timedout waiting for response to SmbComDelete[command=SMB_COM_DELETE,received=false,errorCode=0,flags=0x0018,flags2=0xC

Re: Using method inside a choice/when

I found the root cause of my issue. I previously had been setting a header, and simply forgot to set it here. Once the header is added back in, the predicate works as advertised. I obviously need a test for null in my code. -- View this message in context: http://camel.465427.n5.nabble.com

Re: Using method inside a choice/when

public class OpenCNPredicate implements Predicate { private static Logger logger = LoggerFactory.getLogger(OpenCNPredicate.class); /** * Checks RMS to see if the CN in the STPCaseNo header exists in RMS or not * * @param exchange the exchange object subject to the test

Using method inside a choice/when

I am trying to use a custom predicate inside of a choice in Spring XML, but I'm finding my predicate is always being treated as "false" - the bean itself does not seem to be called.

Re: smb cannot connect to server

One thing I should make clear, the remove vendor supports Windows Networking, period. There is no option for changing the protocol, so please understand that is NOT a solution to this problem. -- View this message in context: http://camel.465427.n5.nabble.com/smb-cannot-connect-to-server-t

smb cannot connect to server

Camel: 2.16.3 camel-jcifs: 2.15.0 (latest release) I am trying to pull files from a remote Windows Share. I have a route that works fine when connecting to a Windows Share in my own domain, but when I try to connect to a host in another domain, it constantly errors with: org.apache.camel.compone

smb cannot connect to server

Camel: 2.16.3, camel-jcifs: 2.15.0 (latest) I am using jCIFS and attempting to connect to a remote share in a different domain. I can connect to this share without issue using Windows Explorer (Win 7) and the UNC path. I can also connect through Linux using smbclient (SuSE 11, samba-client-3.6.

Re: HTTP Unspecified length

ssing-data-from-a-long-lived-HTTP-streaming-URL-td5753758.html - but I never found a solution to it. Peter

Processing data from a long-lived HTTP streaming URL

HTTP stream and pass them on - it seems to want to consume the *whole* stream, and then send it on. I've proved this by using the following Camel route: Test When I run this, I see an HTTP connection to the API, but nothing in /tmp/test, Can anyone help? Cheers, Peter

Re: zip file best practices

I believe there was an original request on this post for someone to please show how to use the ZipSplitter with Spring DSL. But I have not seen this anywhere and I have not been able to get it to work. Here is a snippet of my attempt: http://camel.apache.org/schema/spring";>

Re: De-duplicate route file name?

culateFileName' method - whether Camel will pick this method because it's the only one, or whether it has to have that name, for example. I’ll save that for another day. Thanks again, Peter

Re: De-duplicate route file name?

Ah, cool - thanks. That's much less code than a custom component, endpoint and producer. I discounted the 'move' option, because the default behaviour seemed to be to move the existing files to make room for the duplicate, instead of picking a different name for the duplicate.

Re: De-duplicate route file name?

Component()) 5. Change my file:// URIs to archive:// URIs to use my new component. Peter On 16 May 2013, at 12:23, Peter Hilton wrote: > I’m using Camel to process files, and need to save a copy of each incoming > file to an 'archive' directory. In addition, if another file arri

Re: De-duplicate route file name?

On 16 May 2013, at 12:23, Peter Hilton wrote: > I’m using Camel to process files, and need to save a copy of each incoming > file to an 'archive' directory. In addition, if another file arrives with the > same name as an earlier file, I must add this to the archive with a dif

De-duplicate route file name?

; end point? Note that I have to implement a specific (and weird) file naming strategy: repeatedly receiving 'foo.msg' must result in foo.msg, foo.msg-1, foo.msg-2, foo.msg-3, … I'm using: Camel 2.11.0, Scala DSL, Scala 2.10.0, sbt 0.12.2, JDK 1.6.0_43, OSX 10.8.3 Peter

Solved: Logging cause of failure with deadLetterChannel error handler?

On 14 May 2013, at 18:10, Peter Hilton wrote: > I have a route that takes a file, parses it and then sends JSON to a web > service. If the Camel processor that parses the file throws a parse > exception, the configured error handler moves the file to the dead letter > endpoint. Thi

Re: Logging cause of failure with deadLetterChannel error handler?

On 14 May 2013, at 18:10, Peter Hilton wrote: > … > > val deadLetterErrorHandler = > deadLetterChannel(failureEndpoint).disableRedelivery() > deadLetterErrorHandler.setFailureProcessor(ErrorProcessor()) > errorHandler(deadLetterErrorHandler) >

Logging cause of failure with deadLetterChannel error handler?

r customer error processor, but its process method was never called. What is the correct way to customise log output for DeadLetterChannelBuilder whose endpoint is a directory that the message (file) will be moved to? How much of this can I do using standard Camel components and the Scala DSL? Peter

Re: Splitting XML but including attribute from parent-document

Thanks. Was hoping there was a Sping DSL way to do it, but I guess a POJO just about as easy. On May 14, 2012, at 10:06 PM, alexey-s wrote: > Hey. > Read Splitter https://camel.apache.org/splitter.html > Section "Using a Pojo to do the splitting", a class MySplitterBean. > Change the method si

Re: XSLT not working after route added in camel web console

Please disregard, my bad :) On Tue, May 1, 2012 at 4:17 PM, Peter Kleczka wrote: > Hello > > I am running ActiveMQ 5.4.2 with Camel 2.4.0. I have a route that does > XSLT on a message. Today I tried to add a route through the Camel web > console just for testing purposes and

XSLT not working after route added in camel web console

. Thanks, Peter

two routes , one problem, convertors are different

nInvocation on the server side to send it back? Thanks. Peter.

Re: JMS - replyToDestinationSelectorName - how to set the value?

this property. Looking at the code it would be rather strait forward to actually make the replyToDestinationSelectorValue configurable in the same way as replyToDestinationSelectorName. Would you consider adding this if I supplied a patch for it? /Peter -- View this message in context: http://camel.4

JMS - replyToDestinationSelectorName - how to set the value?

at the code it seems that the value is always set to a random hex by camel. Regards /Peter -- View this message in context: http://camel.465427.n5.nabble.com/JMS-replyToDestinationSelectorName-how-to-set-the-value-tp5560301p5560301.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Alternatives to JConsole

What OS are you using? On Feb 28, 2012, at 8:44 AM, "m.jimen.blazquez" wrote: > Hi, > > I can connect to every java process but I cannot connect to the java > processes which use camel. > > I have tried every possible solution I have seen in goole but I haven't > found a solution to my probl

Updating cached content without restart?

Hi I am using Spring for my Camel routes. I have an XSLT component that calls for the style sheet over HTTP. If that resource changes I have to restart ActiveMQ. I read that I could use Camel 2.6 and turn off caching on the XSLT component, but I wonder if there are other methods to refresh t

threadpool hangs when terminating app.

Peter Thygesen (camel 2.8) the route looks something like this: http://camel.apache.org/schema/spring";> com.mycompany.package

An example of a named DataFormat would be useful in the DataFormat and JAXB pages

Hi, On the pages http://camel.apache.org/data-format.html and http://camel.apache.org/jaxb.html it talks about named DataFormats and just points to the JAXBContext api doc. The Spring version of this config is clear but how to achieve the same results in Java DSL is not. The example code just u

Re: EJB Component JNDI lookup problems

pping" enabled. But this I disabled afterwards and it still works. Maybe I'll post this litte experiment on my blog... /Peter Thygesen 2011/9/7 Willem Jiang > Can you look up you EJB with the jndi setting and name CamelBeanJNDI as a > simple EJB client ? > It looks more l

EJB Component JNDI lookup problems

I'm trying to get the EJB component to work with/in Glassfish 3.1.1. But I get an lookup exception. What am I doing wrong? /Peter avax.naming.NamingException: Lookup failed for 'CamelInterface' in SerialContext[myEnv={...removed...} [Root exception is javax.naming.NameNo

Fwd: onCompletion error? Polling w/ FTP

Hi Please disregard. I got this working by setting up a separate route. I was thinking that somehow the route that sent the file needed to call the route that pulls the response file. -- Forwarded message -- From: Peter Kleczka Date: Wed, Aug 10, 2011 at 10:03 AM Subject

onCompletion error? Polling w/ FTP

on is not the correct solution to this problem. Thanks in advance for your help. --Peter

Re: Blueprint and XSLT

I had the same problem. Gave up on osgi (once more) Wrote about here. http://fusesource.com/forums/thread.jspa?messageID=10210⟢ My xslt was part of my bundle and placed in resources/com/company/packagename. Sent from my iPhone On 02/05/2011, at 19.53, Ioannis Canellos wrote: > Halo Jean Bapti

Bug in camel-lucene component

: Camel 2.5 Route: from("file:src/data?noop=true") .bean(³doSomethingWithTheContentAndReplaceBodyBean²) .to("lucene:MyIndex:insert?analyzer=#analyzer&indexDir=#index&srcDir=#source "); Thx. /Peter Thygesen

  1   2   >