Re: URI contains unsafe characters

2016-04-12 Thread Marco Crivellaro
Any idea? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/URI-contains-unsafe-characters-tp5779497p5780919.html Sent from the Camel - Users mailing list archive at Nabble.com.

URI contains unsafe characters

2016-03-22 Thread Marco Crivellaro
Hi, when using the below URI Camel is logging a warning: ftp://user@host:21//?binary=false&disconnect=true&eagerDeleteTargetFile=false&fastExistsCheck=true&fileExist=Override&ftpClient.connectTimeout=3&ftpClient.dataTimeout=3&ftpClient.defaultTimeout=3&passiveMode=false&password=aPass&

How to customized Log Format of DefaultErrorHandler

2015-07-14 Thread Marco Crivellaro
Hi, I am using Camel 2.15.3-SNAPSHOT How do I customise the Log Format of default error handler? I would like to output the endpoint uri, exchange id, error message and stack trace only thanks a lot, Marco -- View this message in context: http://camel.465427.n5.nabble.com/How-to-customized-Lo

Re: java.net.URISyntaxException using recipientList

2015-07-10 Thread Marco Crivellaro
Thanks for the feedback, much appreciated. -- View this message in context: http://camel.465427.n5.nabble.com/java-net-URISyntaxException-using-recipientList-tp5769103p5769126.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: java.net.URISyntaxException using recipientList

2015-07-10 Thread Marco Crivellaro
Fastest fix ever! I don't see it yet in master or 2.15.x branch, was just wondering where the problem was. -- View this message in context: http://camel.465427.n5.nabble.com/java-net-URISyntaxException-using-recipientList-tp5769103p5769115.html Sent from the Camel - Users mailing list archive a

java.net.URISyntaxException using recipientList

2015-07-10 Thread Marco Crivellaro
Hi, I am trying to upgrade to Camel 2.15 from camel 2.8.6 and I am finding a problem when trying to serve endpoints which URIs contains the character { as a java.net.URISyntaxException is thrown. As an example a destination FTP endpoint contains the character '{' in the password; ie: '12{34' whe

Re: HttpProducer to ignore response body avoiding stream caching

2015-06-15 Thread Marco Crivellaro
Should I take care of opening a JIRA issue to request the feature? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/HttpProducer-to-ignore-response-body-avoiding-stream-caching-tp5767260p5768274.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: HttpProducer to ignore response body avoiding stream caching

2015-05-22 Thread Marco Crivellaro
yes that's exactly what I'd need. Should I open a JIRA issue? Best, Marco -- View this message in context: http://camel.465427.n5.nabble.com/HttpProducer-to-ignore-response-body-avoiding-stream-caching-tp5767260p5767416.html Sent from the Camel - Users mailing list archive at Nabble.com.

HttpProducer to ignore response body avoiding stream caching

2015-05-19 Thread Marco Crivellaro
I am using camel-http to send HTTP Post notifications to a wide range of endpoints which I don't control directly, sometimes the endpoints response is quite big and due to the fact HttpProducer is caching the response stream temporary files are being written to disk. I can set the caching threshol

camel HttpProducer caching stream

2015-05-19 Thread Marco Crivellaro
Hi, I just found out HttpProducer (camel-http) is always caching the response stream, having a look a the Camel Stream Caching documentation (http://camel.apache.org/stream-caching.html) I would expected this to not occur since on camel 2.x Stream Caching is off by default. I would think it worth

Re: request-reply with ActiveMQ and Camel

2015-02-13 Thread Marco Crivellaro
Thanks for the replies Camel is only used to consume the request queue and post the replies, the requestor is a .NET app based on NMS and the aggregation part works fine as the setup works fine when using a standard queue on JMSReplyTo header: camel is sending the multiple replies to the queue and

request-reply with ActiveMQ and Camel

2015-02-12 Thread Marco Crivellaro
Hi, I have managed to get a simple request-reply working with ActiveMQ and Camel/NMS. - The Producer is an NMS client which creates a temporary queue and then sends the request to a queue (queue.request) setting the replyTo header to the temporary queue. - The Consumer is a Java component which use

Re: camel-rabbitmq logging exceptions as debug

2014-10-27 Thread Marco Crivellaro
opened https://issues.apache.org/jira/browse/CAMEL-7967 thanks -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-logging-exceptions-as-debug-tp5757936p5758069.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-rabbitmq logging exceptions as debug

2014-10-23 Thread Marco Crivellaro
Hi, I am using Camel 2.14.0 Connecting to RabbitMQ using camel-rabbitmq I've noticed that no ERROR is logged if the component cannot connect, the exceptions are handled and logged as DEBUG. This is a bit inconvenient as logging all DEBUG messages for the component fills up our logs, in production w

Re: loggingErrorHandler formatting

2013-12-12 Thread Marco Crivellaro
I have tried the suggested approach but it doesn't seem to work like having a DefaultErrorHandler; in my route there is an aggregator and once an exchange runs in error the routing does not proceed to the step after the aggregation if this runs in timeout. -- View this message in context: http:

loggingErrorHandler formatting

2013-12-11 Thread Marco Crivellaro
how do I define the log format when using loggingErrorHandler? I am interested in setting properties like: showExchangeId, showExchangePattern, showBody... the default format is too verbose -- View this message in context: http://camel.465427.n5.nabble.com/loggingErrorHandler-formatting-tp57446

users@camel.apache.org

2013-12-10 Thread Marco Crivellaro
created https://issues.apache.org/jira/browse/CAMEL-7057 -- View this message in context: http://camel.465427.n5.nabble.com/Issue-with-password-having-double-tp5744323p5744570.html Sent from the Camel - Users mailing list archive at Nabble.com.

users@camel.apache.org

2013-12-04 Thread Marco Crivellaro
Hi, there is an issue with handling password with double && even when wrapping it into RAW() constraint For instance the use of URI http://hostname/script.php?authMethod=Basic&authPassword=RAW(pa&&word)&authUsername=usr throws the exception: org.apache.camel.ResolveEndpointFailedException: Fail

Re: issue with ExchangeHelper.resolveEndpoint when using RAW() parameter on authPassword

2013-12-04 Thread Marco Crivellaro
my bad, it is the same for FTP. I got confused by another issue I've found... will open a separate thread -- View this message in context: http://camel.465427.n5.nabble.com/issue-with-ExchangeHelper-resolveEndpoint-when-using-RAW-parameter-on-authPassword-tp5744246p5744320.html Sent from the Ca

Re: issue with ExchangeHelper.resolveEndpoint when using RAW() parameter on authPassword

2013-12-03 Thread Marco Crivellaro
why does it work in a different way between authPassword on HTTP and password on FTP endpoint parameters? -- View this message in context: http://camel.465427.n5.nabble.com/issue-with-ExchangeHelper-resolveEndpoint-when-using-RAW-parameter-on-authPassword-tp5744246p5744268.html Sent from the Ca

Re: issue with ExchangeHelper.resolveEndpoint when using RAW() parameter on authPassword

2013-12-03 Thread Marco Crivellaro
I have forgotten to mention I am using camel 2.12.1 -- View this message in context: http://camel.465427.n5.nabble.com/issue-with-ExchangeHelper-resolveEndpoint-when-using-RAW-parameter-on-authPassword-tp5744246p5744247.html Sent from the Camel - Users mailing list archive at Nabble.com.

issue with ExchangeHelper.resolveEndpoint when using RAW() parameter on authPassword

2013-12-03 Thread Marco Crivellaro
Hi, I've just bumped into an issue with ExchangeHelper.resolveEndpoint when used on a URI which has authPassword parameter value using RAW() value ExchangeHelper.resolveEndpoint(exch, "http://host:80/script.php?httpClient.soTimeout=360&authMethod=Basic&authPassword=RAW(pass!)&authUsername=us

Re: ActiveMQ composite destination producer

2013-08-07 Thread Marco Crivellaro
Thanks The example I reported though is properly pushing 2 messages on the broker though. So it seems to work but not supporting a mix of topic and queue in the list. correct me if I am wrong but using multicast is not exactly the same thing of using composite destinations, if I've understood it

ActiveMQ composite destination producer

2013-08-06 Thread Marco Crivellaro
Hi All, I have a requirement to send the same message to 2 distinct destinations (a queue and a topic) on ActiveMQ and I would like to use the composite destination feature of ActiveMQ. http://activemq.apache.org/composite-destinations.html I've tried to setup the producer URI as follow: the m

Re: bean String parameter binding

2013-08-02 Thread Marco Crivellaro
Hi, works fine on 2.12-SNAPSHOT, I can't fetch some dependencies to test it on 2.11.2-SNAPSHOT I reported I was using 2.11.2 by mistake, the issue is shown on 2.11.1 Thanks, Marco -- View this message in context: http://camel.465427.n5.nabble.com/bean-String-parameter-binding-tp5736688p57366

bean String parameter binding

2013-08-02 Thread Marco Crivellaro
Hi All, I am using Camel 2.11.2 with a spring context. In my route I am calling a bean method passing 2 wildcard params and a string. for example: method signature is: SetMissingHeaderToZero(Exchange exchange, String headersCSV) everything works fine but camel is writing following WARN: WARN

Re: camel-sql, connection test required?

2013-08-01 Thread Marco Crivellaro
Thanks for pointing that out, I'll have a look at it. -- View this message in context: http://camel.465427.n5.nabble.com/camel-sql-connection-test-required-tp5736549p5736624.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel-sql, connection test required?

2013-07-31 Thread Marco Crivellaro
I've found out you can use c3p0 library (http://www.mchange.com/projects/c3p0) so you can rely on connection pooling are not forced to write your own connection testing in the route. here is an example of the jdbc datasource bean:

camel-sql, connection test required?

2013-07-31 Thread Marco Crivellaro
Hi all, when using camel-sql should connection pooling and connection test be implemented? I am building a camel based application which will run as a daemon and might write the database once every few days. This means between writes the connection to the database (mysql) might timeout. Is camel te

JMS properties to In message headers

2013-07-29 Thread Marco Crivellaro
Hi all, I am using Camel 2.11.1 By default Camel adds the a list of JMS properties to the In message headers when it receives a JMS message, for instance: JMSTimestamp, JMSType, JMSXGroupID... is there a way to extend this list without having to create a Processor to the route? I would like to a

Re: Ignore JMSReplyTo

2013-03-28 Thread Marco Crivellaro
That worked, thanks a lot! -- View this message in context: http://camel.465427.n5.nabble.com/Ignore-JMSReplyTo-tp5729973p5730015.html Sent from the Camel - Users mailing list archive at Nabble.com.

Ignore JMSReplyTo

2013-03-27 Thread Marco Crivellaro
Hi, I have a very simple route where messages are sent to an ActiveMQ queue with JMSReplyTo header set which I would like to ignore. I cannot avoid setting the header as messages are pushed using composite destination by another component. I've set the route as following but the messages are still

Re: camel processor in InOut to send 2 replies

2013-02-27 Thread Marco Crivellaro
Hi Hadrian, thanks for your reply. Sorry if I've been unclear. The messages I am publishing to the In queue have JMSReplyTo header set. As you suggested I've used the reply to header to send an additional message using a bespoke producer in the process method of the Processor: javax.jm

camel processor in InOut to send 2 replies

2013-02-26 Thread Marco Crivellaro
Hi All, I have a requirement to send 2 messages in as reply of a request using InOut pattern. How can I achieve this? My route looks as following: http://camel.apache.org/schema/spring"; autoStartup="true">

Re: camel shutsdown route even when using failover

2013-02-19 Thread Marco Crivellaro
I manage to get it working, I think I was setting the context in the wrong way. This now works, camel context won't stop and wait for the broker to reconnect using failover provided via config public class MainHulk { private static Logger LOG = LoggerFactory.getLogger(MainHulk.class);

Re: camel shutsdown route even when using failover

2013-02-19 Thread Marco Crivellaro
I've tried what you've suggested but the route will shutdown in in case the broker connection is lost, in my previous test it looked like System.Runtime was being called. This is how my main method looks like now: public class MainHulk { private static Logger LOG = LoggerFactory.getLogge

camel shutsdown route even when using failover

2013-02-19 Thread Marco Crivellaro
Hi All, I am setting up a camel context with 2 routes consuming 2 ActiveMQ queues. The connectionstring to the broker specifies failover protocol, however if the broker for some reason goes offline the context shutsdown itself automatically. Is there a way to keep the context trying to reconnect to

Re: little issue with ActiveMQ Consumer having prefetch set to 0 (polling)

2013-01-11 Thread Marco Crivellaro
Any idea on how Client ID and Connection ID are created when connecting to ActiveMQ? -- View this message in context: http://camel.465427.n5.nabble.com/little-issue-with-ActiveMQ-Consumer-having-prefetch-set-to-0-polling-tp5725050p5725391.html Sent from the Camel - Users mailing list archive at

GenericFileProducer ISSUE - target deletion with eagerdeletefile set to false

2013-01-11 Thread Marco Crivellaro
Hi all, I just noticed an issue related to deleting the target file when writing using temporary file names and eagerDeleteTargetFile is set to false. the producer first checks if target file exists, it than writes the temporary file. Once temporary file is written the target file is deleted in ca

little issue with ActiveMQ Consumer having prefetch set to 0 (polling)

2013-01-07 Thread Marco Crivellaro
Hi All, I am looking into a small issue I am facing when using ActiveMQ consumer (Camel route, standalone application) configured to poll messages (ActiveMQ connectionstring parameter jms.prefetchPolicy.queuePrefetch=0) current setup involves 450 consumers which are restarted by a cron (not all at

Re: Issues with URI containing %40 or %26

2012-09-13 Thread Marco Crivellaro
I took the decision to go back to camel 2.8 (2.8.6) as all our endpoints had user in the authority part. I am looking forward for a fix on camel 2.10 (or 2.11 even) since camel is too cool to stay behind... :) -- View this message in context: http://camel.465427.n5.nabble.com/Issues-with-URI-co

Re: Issues with URI containing %40 or %26

2012-09-11 Thread Marco Crivellaro
Thanks for letting me know. The ticket doesn't have any target milestone, is there a short term plan to work on this issue? Othewise I suppose the only way out for me would be to roll back to last 2.8.x... -- View this message in context: http://camel.465427.n5.nabble.com/Issues-with-URI-contai

Re: Issues with URI containing %40 or %26

2012-09-11 Thread Marco Crivellaro
in which version have this behaviour been introduced? I'd prefer to use an older version which supports %40 and %26 in URI until this is URISupport is fixed. Would 2.9.x be ok? -- View this message in context: http://camel.465427.n5.nabble.com/Issues-with-URI-containing-40-or-26-tp5719118p57191

Re: Issues with URI containing %40 or %26

2012-09-11 Thread Marco Crivellaro
% is encoded as %25 calling URISupport.normalizeURI on ftp://us%2540r@host?password=t%2526st returns following URI which doesn't seem correct either: ftp://us%40r@host?password=t%2526st it seems URI parameters are not being decoded.. I would expect following result: ftp://us%40r@host?password=t

Re: Issues with URI containing %40 or %26

2012-09-11 Thread Marco Crivellaro
Claus Ibsen-2 wrote > > Give 2.10.1 a try > 2.10.1 have issues as well valid uri: ftp://us%40r@host?password=t%26st is normalized to invalid uri: ftp://us@r@host?password=t&st -- View this message in context: http://camel.465427.n5.nabble.com/Issues-with-URI-containing-40-or-26-tp5719118p5

Issues with URI containing %40 or %26

2012-09-11 Thread Marco Crivellaro
Hi all, using camel 2.8.0 it was possible to have endpoint uris containing %26 (&) or %40 (@) encoded values. This is essential if you want to support credentials such as username 'us@r' or password 't&st'. Many of the endpoints we are serving makes use of @ or & in their parameters. We've recentl

stop a quartz route

2012-09-07 Thread Marco Crivellaro
Hi All, my Camel context is making use of a watchdog to monitor the status of the application. In case a flag is set I would like to stop the watchdog, I cannot find a way to stop the route. The watchdog have been implemented using camel-quartz: from("quartz://watchdog/checkpendingexchanges?trigge

Re: recipientList with parallelProcessing, how to stop thread(s)

2012-09-06 Thread Marco Crivellaro
Thank you, in the meantime I've worked it around by using an InflightRepository keeping track of exchange alive time, but it would be great to have a way to graceful stop running tasks. -- View this message in context: http://camel.465427.n5.nabble.com/recipientList-with-parallelProcessing-how-

recipientList with parallelProcessing, how to stop thread(s)

2012-09-03 Thread Marco Crivellaro
Hi All, in our route we are using a recipientList with parallelProcessing which is than aggregated. We also use an aggregation timeout. When the aggregation runs in timeout the threads which have been created to process in parallel the recipient list will continue running. Is there a way to list th

Re: URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-08-08 Thread Marco Crivellaro
Unfortunately interceptors cannot be used. We use a recipientList in our route and password cannot be set in a header like filename... really need this to be fixed. -- View this message in context: http://camel.465427.n5.nabble.com/URISupport-normalizeUri-different-result-from-camel-2-8-2-to-2-

Re: URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-08-08 Thread Marco Crivellaro
hadrian wrote > > Would using properties be acceptable as a solution (including > camel-jasypt maybe if you don't want the pwd in clear)? > > Hadrian > Hi Hadrian, unfortunately I can't use properties without re engineering the whole application. we manage hundreds of endpoints centrally and

Re: URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-08-08 Thread Marco Crivellaro
hadrian wrote > > Would using properties be acceptable as a solution (including > camel-jasypt maybe if you don't want the pwd in clear)? > > Hadrian > No sure what you mean, would it be possible for you to provide an example? -- View this message in context: http://camel.465427.n5.nabbl

Re: URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-08-06 Thread Marco Crivellaro
hekonsek wrote > > Ok. The good news is that I got a workaround for you :) . > > Create the component without the FTP password defined in the > parameters and then programatically set it on the endpoint. > I wish it was this easy... unfortunately our architecture is build around the endpoint u

Re: URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-08-06 Thread Marco Crivellaro
thank you Henryk. I saw you planned to fix it for Camel 2.11.0; is there a chance to have in 2.10 too since it is a major bug? Marco -- View this message in context: http://camel.465427.n5.nabble.com/URISupport-normalizeUri-different-result-from-camel-2-8-2-to-2-10-0-tp5716633p5716870.html Sen

Re: URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-08-03 Thread Marco Crivellaro
can you please let me know if this is how it should work and therefore camel 2.8.2 was buggy? I just need to know if I have to find a workaround until a bugfix is release or instead I am implementing it in the wrong way. Thank you. -- View this message in context: http://camel.465427.n5.nabble

URISupport.normalizeUri different result from camel 2.8.2 to 2.10.0

2012-07-31 Thread Marco Crivellaro
Hi all, I am migrating my application from Camel 2.8.2 to Camel 2.10.0 and found following issue: when normalizing a uri with URISupport.normalizeUri which contains %26 in one of its parameters the entity is transformed to '&' and essentially lost from the parameter value; this was not happening w

Aggregator Exchange.MULTICAST_COMPLETE recipientList

2012-07-06 Thread Marco Crivellaro
Hi, I am currently using a recipientList with parallel processing and streaming option with a custom aggregator strategy. Exchange.MULTICAST_COMPLETE property read on aggregation seems to rely on the recipient list order instead of the order in which they are aggregated. For instance if in recipi

Re: recipientList, aggregationStrategy and completionTimeout

2012-06-22 Thread Marco Crivellaro
Is there a chance dinamic timeout can be added in a future version? I suppose it can be done provided the fact it is avaliable in aggregation. Is there a way to make use of completionTimeout of the aggregation strategy? -- View this message in context: http://camel.465427.n5.nabble.com/recipien

recipientList, aggregationStrategy and completionTimeout

2012-06-22 Thread Marco Crivellaro
Hi all, I am re-factoring a component which makes use of Camel (just moved to camel 2.9.2), a part of the route is currently built as: .recipientList(header("recipientListHeader").tokenize(",")) .parallelProcessing().timeout(aggregationTimeout) .executorService(customThreadPoolExecutor) .streaming

RecipientList-AggregateTask thread creation

2011-10-04 Thread Marco Crivellaro
I have a route with a recipientList parallel processed and than streamed to an aggregation strategy: .recipientList(header("recipientListHeader").tokenize(",")) .parallelProcessing().timeout(3) .executorService(customThreadPoolExecutor) .streaming().aggregationStrategy(new RecipientAggregation

Re: information about the inflight exchange(s) when shutting down

2011-10-04 Thread Marco Crivellaro
Claus Ibsen-2 wrote: > > The default in flight registry only stores number of in flights. > You can implement a custom in flight registry and include more details. > Is there a reference in the documentation on how to create a custom inflight repository? Claus Ibsen-2 wrote: > > We wanted a

information about the inflight exchange(s) when shutting down

2011-10-04 Thread Marco Crivellaro
Is there any way to collect some information (exhange.properties / headers) of any inflight exchange while shutting down camel context? I'd need this in order to track down an issue I have with a camel based application. I am using camel 2.8.0 -- View this message in context: http://camel.465427

how to try delivery again after a recipientlist timeout

2011-07-19 Thread Marco Crivellaro
Hi all! I would like to ask you which would be the best way of attempting a redelivery after a recipient list timeout. I currently have a route which receives a message from JMS with a list of recipients and through a processor it changes the payload of the message and builds the recipientlist hea

Re: GenericFileOperations optimization

2011-04-20 Thread Marco Crivellaro
Thank you, what about the second point about lock? -- View this message in context: http://camel.465427.n5.nabble.com/GenericFileOperations-optimization-tp4315363p4315567.html Sent from the Camel - Users mailing list archive at Nabble.com.

GenericFileOperations optimization

2011-04-20 Thread Marco Crivellaro
Hi, when using camel as FTP/SFTP producer the exchange process is taking longer time when many files are stored in the destination folder. This should be related to the operations.existsFile calls being processed by the method. At the moment GenericFileProducer.processExchange is calling twice op

Re: missing region property in aws-sns component

2011-04-14 Thread Marco Crivellaro
You have to create an AmazonSNSClient and specify the endpoint otherwise it will default to us-east-1 AWSCredentials awsCredentials = new BasicAWSCredentials("***", "!!!"); AmazonSNSClient client = new AmazonSNSClient(awsCredentials); client.setEndpoint("http://sns.eu-west-1.amazonaws.com/";);

Re: Exchange.MAXIMUM_CACHE_POOL_SIZE is not affecting producers created by recipientList

2011-04-04 Thread Marco Crivellaro
Excellent! That is something I was looking for since Camel 2.5! -- View this message in context: http://camel.465427.n5.nabble.com/Exchange-MAXIMUM-CACHE-POOL-SIZE-is-not-affecting-producers-created-by-recipientList-tp4257273p4279856.html Sent from the Camel - Users mailing list archive at Nabbl

Re: Exchange.MAXIMUM_CACHE_POOL_SIZE is not affecting producers created by recipientList

2011-04-01 Thread Marco Crivellaro
Thank you, I will check it using the example provided. -- View this message in context: http://camel.465427.n5.nabble.com/Exchange-MAXIMUM-CACHE-POOL-SIZE-is-not-affecting-producers-created-by-recipientList-tp4257273p4275924.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: getCurrentCacheSize when using recipientList

2011-04-01 Thread Marco Crivellaro
reason why I am asking is because I've tried to set it to a low value (say 50) and then send several messages to a list of 100 unique recipents (3 recipient for each exchange). I than took a snapshot with jmap and found all 100 producers -- View this message in context: http://camel.465427.n5.na

getCurrentCacheSize when using recipientList

2011-04-01 Thread Marco Crivellaro
Is there a way to get the current cache size when using a recipientList? in my route I am consuming messages from an ActiveMQ queue and then sending to recipients using the recipientList. -- View this message in context: http://camel.465427.n5.nabble.com/getCurrentCacheSize-when-using-recipientL

Re: java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-28 Thread Marco Crivellaro
Hi Claus, I've seen you closed the ticket and added a unit test. The unit test uses mock up endpoint which does not show the wrong behaviour. The test I've attached to the ticket does not make use of custom thread pool as you've reported: from("direct:start").recipientList(header(InterceptSendToEn

Re: Exchange.MAXIMUM_CACHE_POOL_SIZE is not affecting producers created by recipientList

2011-03-25 Thread Marco Crivellaro
this affects 2.7.0 release too -- View this message in context: http://camel.465427.n5.nabble.com/Exchange-MAXIMUM-CACHE-POOL-SIZE-is-not-affecting-producers-created-by-recipientList-tp4257273p4264057.html Sent from the Camel - Users mailing list archive at Nabble.com.

Exchange.MAXIMUM_CACHE_POOL_SIZE is not affecting producers created by recipientList

2011-03-22 Thread Marco Crivellaro
Camel 2.7.0-SNAPSHOT I've tried to set the maximum producer cache size to 5 and send messages to 100 of different ftp endpoints (using several recipientList exchanges), checking the jmap heap dump I've found out there were 100 FTPClient, FTPConfigurations, FTPOperations ... loaded in memory. Is t

Re: java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-21 Thread Marco Crivellaro
I've created a ticket and attached a test to it https://issues.apache.org/jira/browse/CAMEL-3795 please let me know if you need further details. -- View this message in context: http://camel.465427.n5.nabble.com/java-util-concurrent-RejectedExecutionException-using-interceptSendToEndpoint-tp3425

Re: cleanup camel cached producers

2011-03-16 Thread Marco Crivellaro
the problem I am having is that my application after running for some days runs out of memory, checking what is in the heap I can find a lot of producers (and related instances). I would like to stop a producer at the end of the route (or every timeframe) as the producer my application will use ar

Re: java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-15 Thread Marco Crivellaro
The following sample: http://camel.465427.n5.nabble.com/file/n3710309/FirstTest.java FirstTest.java shows the same issue with only 2 messages sent to 2 distinct endpoints. if instead of using a single interceptor "(ftp|sftp|ftps|http):.*" 2 distinct interceptors are defined: "(ftp|sftp|ftps):.*

Re: java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-15 Thread Marco Crivellaro
to make it run in exception you don't even need to run a cycle of with many messages sent, you just need to define an the interceptor for ftp and http: interceptSendToEndpoint("(ftp|sftp|ftps|http):.*").process( new Processor() { public void process(Exchange exchange) throws Exception {

Re: java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-15 Thread Marco Crivellaro
why isn't the route running in exception if instead of using an intercept send to endpoint for all protocols I define 2 different inteceptors, 1 for ftp and 1 for http? -- View this message in context: http://camel.465427.n5.nabble.com/java-util-concurrent-RejectedExecutionException-using-interce

cleanup camel cached producers

2011-03-15 Thread Marco Crivellaro
Is there a way to access the list of camel producers and cleanup all instances so that they can be collected by the garbage collector? -- View this message in context: http://camel.465427.n5.nabble.com/cleanup-camel-cached-producers-tp3708189p3708189.html Sent from the Camel - Users mailing list

Re: java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-14 Thread Marco Crivellaro
That is not an heavy load sample, it runs in exception after the 2nd time it runs the for cycle... -- View this message in context: http://camel.465427.n5.nabble.com/java-util-concurrent-RejectedExecutionException-using-interceptSendToEndpoint-tp3425179p3556257.html Sent from the Camel - Users ma

java.util.concurrent.RejectedExecutionException using interceptSendToEndpoint

2011-03-11 Thread Marco Crivellaro
in some circumstances interceptSendToEndpoint in conjunction with recipientList and parallel processing is running in exception. this seems to be the case when and http endpoint is sent in the recipient list after having processed and ftp in the previous exchange attached test case shows the expec

Re: ActiveMQ connection with failover and prefetch

2011-03-10 Thread Marco Crivellaro
This is the URI format to use: failover:(tcp://localhost:61616?wireFormat.maxInactivityDuration=0&keepAlive=true)?jms.prefetchPolicy.queuePrefetch=1&initialReconnectDelay=1&useExponentialBackOff=false&maxReconnectAttempts=0&randomize=false more details can be found here: http://activemq.22833

Re: camel caching producers

2011-03-09 Thread Marco Crivellaro
thank you. Is there any way I can access the list of producers and stop them at the end of the route? In such a way I will ensure I won't risk a high memory consumption if the route will server thousands of distinct ftp servers (which could be the case in the future) -- View this message in conte

Re: camel caching producers

2011-03-07 Thread Marco Crivellaro
thanks, the temporary file name we use is also dinamic, which is the Exchange header to set the tempFileName uri property? -- View this message in context: http://camel.465427.n5.nabble.com/camel-caching-producers-tp3412417p3412698.html Sent from the Camel - Users mailing list archive at Nabble.c

Re: camel caching producers

2011-03-07 Thread Marco Crivellaro
problem is I am using a recipientList to serve our endpoints as we are not serving only FTP endpoints. any way to limit LRU cache? -- View this message in context: http://camel.465427.n5.nabble.com/camel-caching-producers-tp3412417p3412665.html Sent from the Camel - Users mailing list archive at

Re: camel caching producers

2011-03-07 Thread Marco Crivellaro
that means that if I need to deliver to 1000 distinct ftp servers I should expect space to be allocated even if they are used just once? Isn't there a way to get the garbage collected? -- View this message in context: http://camel.465427.n5.nabble.com/camel-caching-producers-tp3412417p3412643.htm

Re: camel caching producers

2011-03-07 Thread Marco Crivellaro
even setting cache limit to 10 and disabling camel JMX support (-Dorg.apache.camel.jmx.disabled=true) I can see the number of FTPClient, FTPConfiguration, FTPOperations, FTPEndpoint and ListenerList growing constantly. Each exchange I run has a distinct endpoint URI -- View this message in contex

Re: issue with sftp producer

2011-03-07 Thread Marco Crivellaro
I've tested latest snapshot, everything works like a charm! Camel rocks! -- View this message in context: http://camel.465427.n5.nabble.com/issue-with-sftp-producer-tp3408052p3412452.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel caching producers

2011-03-07 Thread Marco Crivellaro
thanks a lot! -- View this message in context: http://camel.465427.n5.nabble.com/camel-caching-producers-tp3412417p3412449.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel caching producers

2011-03-07 Thread Marco Crivellaro
Hi all, having a look the to memory usage of my camel based application; I've found out camel is caching producers. I am running a huge amount of deliveries to distinct endpoints, is there a way to limit the amount of producers cached? -- View this message in context: http://camel.465427.n5.nabbl

Re: ActiveMQ connection with failover and prefetch

2011-03-04 Thread Marco Crivellaro
I've created a new discussion on ActiveMQ forum. http://activemq.2283324.n4.nabble.com/ActiveMQ-connection-with-failover-and-prefetch-td3335495.html -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-connection-with-failover-and-prefetch-tp3387737p3409712.html Sent from

Re: ActiveMQ connection with failover and prefetch

2011-03-04 Thread Marco Crivellaro
doesn't work... it is the first URL format I've used. -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-connection-with-failover-and-prefetch-tp3387737p3409686.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ActiveMQ connection with failover and prefetch

2011-03-04 Thread Marco Crivellaro
I've tried the same using a local instance: ant -Durl="failover://tcp://localhost:61616?wireFormat.maxInactivityDuration=0&jms.prefetchPolicy.queuePrefetch=1&initialReconnectDelay=10&maxReconnectDelay=15000" producer -Dsubject="test" same result: producer doesn't start -- View this message in co

Re: ActiveMQ connection with failover and prefetch

2011-03-04 Thread Marco Crivellaro
I've tried to run the example you suggested and the producer hangs (same issue shown by camel) ant -Durl="failover://tcp://hostname:61616?wireFormat.maxInactivityDuration=0&jms.prefetchPolicy.queuePrefetch=1&initialReconnectDelay=10&maxReconnectDelay=15000" producer -Dsubject="test" the only dif

Re: issue with sftp producer

2011-03-03 Thread Marco Crivellaro
I've forgot to the JIRA ticket link: https://issues.apache.org/jira/browse/CAMEL-3749 -- View this message in context: http://camel.465427.n5.nabble.com/issue-with-sftp-producer-tp3408052p3408268.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: issue with sftp producer

2011-03-03 Thread Marco Crivellaro
I can work on a patch, have two proposal as solution: solution 1: in case directory information on filename cannot be retrieved uses "/" solution 2: in case directory information on filename cannot be retrieved uses current directory (there should be a way to retrieve it) I'd prefer the latter.

Re: issue with sftp producer

2011-03-03 Thread Marco Crivellaro
I am using Camel 2.7 SNAPSHOT with jsch 0.1.44 the endpoint URI is as follow: sftp://user@hostname:22?disconnect=true&eagerDeleteTargetFile=false%3Bstepwise%3Dfalse&fileName=SYSTEM01&password=**&soTimeout=3&tempFileName=%24%7Bfile%3Aname.noext%7D.8937937.tmp stack trace: [2011-03-03 14:

issue with sftp producer

2011-03-03 Thread Marco Crivellaro
Hi, I am experiencing an issue with and sftp producer, I am not sure if this should be considered a camel or a JCraft JSCH libray issue. The exchange run in exception when it comes to list check if file exists on destination org.apache.camel.component.file.remote.SftpOperations.existsFile I've fo

Re: ActiveMQ connection with failover and prefetch

2011-03-02 Thread Marco Crivellaro
As the connection string you suggested is not working should I consider this a Camel or an ActiveMQ issue? -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-connection-with-failover-and-prefetch-tp3387737p3406724.html Sent from the Camel - Users mailing list archive at N

Re: ActiveMQ connection with failover and prefetch

2011-02-21 Thread Marco Crivellaro
I've tried to use the URI format you suggested but the result is the same using the URI I posted -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-connection-with-failover-and-prefetch-tp3387737p3394630.html Sent from the Camel - Users mailing list archive at Nabble.com

  1   2   >