activemq store percent is very high

Hi, i have simple camel route, which reads from activemq queue and sends email messages, if exception occurs message is moved to dead letter queue. The problem is, store percent usage is very high. 10 messages in DLQ consumes 30% store (limit for storage is 1 gb), it is ~30mb for one message, but

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

Is this problem related to recipientList? Or it is general issue with camel request/reply over jms? I haven't noticed this behaviour in other routes with InOut pattern over amq queue. Do you have any link to jira issue or other pages where this problem is described? Thank you. -- View this mess

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

Thanks for quick reply. The problem is, I can't update camel version because the system is running is production with a lot bundles. Upgrading to new camel requires a lot of refactoring due to api changes... Is there any workaround (other than upgrading camel) possible in this case? -- View thi

Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

Hello, after about 1 day usage, I got a strange situation - there are lot of ActiveMQMessageConsumers created (~640k) with selector JMSCorrelationID='CamelDummyJmsMessageSelector'. All consumer objects use around 1GB heap memory. Camel route is quite simple:

Re: Problem with cxf web service invocation via nmr transport

Hi Willem, I have enabled jaxws client logging feature and it doesn't receive any response when soap fault without detail is returned from cxf service. (when soap fault with detail is returned or successful response - everything works fine) -- View this message in context: http://camel.465427.n

Problem with cxf web service invocation via nmr transport

Hello, I have simple cxf endpoint (using NMR transport), configured as follows: http://www.w3.org/2001/XMLSchema-instance";> And the camel route implementing service: (1) (1) FatalProcessor just throws Exception: public vo

Re: Help with nmr, cxf endpoints and fault handling

Willem, here is the code for addSoapFault(exchange, new CantTalkFault_Exception("Ups", cantTalkFault)); I am using it with cxf PAYLOAD data format. public static void addSoapFault(Exchange exchange, Exception faultException) throws Exception { if (!faultException.getClass().isAnnota

Re: Help with nmr, cxf endpoints and fault handling

Hi, sorry, maybe the situation wasn't clear enough. I have a simple jetty http endpoint, which accepts requests and simply forwards it to nmr endpoint. And then, there is a cxfEndpoint (configuration in first post), listening to nmr:fatal:endpoint and simple camel route: fatalProcessor just t

Help with nmr, cxf endpoints and fault handling

Hello, I have the following camel context: and my FatalProcesor just throws fault defined in wsdl: When sending request to http://localhost:9080/hello endpoint, I get the soap fault as I expect: .. but http response response code is "200 OK". Why not 500 as it is returned from cxf endpoint

Re: Scheduled FTP download

Hi, you can try using cron scheduled route policy (http://camel.apache.org/cronscheduledroutepolicy.html) -- View this message in context: http://camel.465427.n5.nabble.com/Scheduled-FTP-download-tp5716638p5716639.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-sftp polling and file listing

Hi, I am using camel-ftp to download files from remote sftp server, using idempotency (file), polling every 5 minutes, receiving max 50 files per poll and disconnecting after each polling. The problem is, that getting file list from sft server causes to high sftp server load (there are a lot of fil

Camel sftp endpoint and exception handling.

Hello, I have route (camel 2.7.1): ftp://user@host/folder?password=password&delete=true"; /> java.lang.Exception If I don't have permissions to delete the remote file, the same file gets processed and is put to activemq queue over and over again (onException block d

setting jms headers and defining daa types

Hello, I am setting jms message headers inspring dsl like this: 1234567893214411 and sending message to IBM Websphere MQ. Is it possible to define the value type (for example long)? In my case it is stored in ibm mq message RFH2 like: 1234567893214411 It causes problems other appl

camel-quartz 2.6.0 and multiple bundles

Hi, I have two bundles (in servicemix) using camel quartz. The first one has route trigerred by quartz from("quartz://MyTimer...).to(uri). And the second bundle has route, which uses org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy with routeStartTime and routeStop time. I noti

Re: CronScheduledRoutePolicy

property placeholders doesn't help in this case ( The problem is, that route must be running during the working hours (from 10am till 4pm). On other hours it must be stopped. So the routeStartTime and routeStopTime properties are used in CronScheduledRoutePolicy. But deployments are done sometimes

CronScheduledRoutePolicy

Hi, I am using CronScheduledRoutePolicy to start/stop route at specific time. I have defined configuration as follows: The problem is with route deployment. If the route is deployed between 10am and 4pm, by default it is stopped (autoStartup="false"), but according to route p

Re: camel-cache configuration

this might be related with your problem. http://fusesource.com/forums/thread.jspa?messageID=9547╋ ehcache-failsafe.xml is missing inside ehcache bundle. -- View this message in context: http://camel.465427.n5.nabble.com/camel-cache-configuration-tp4514476p4515096.html Sent from the Camel - User

Re: camel message headers

I am not using DSL in this case, i am setting headers in bean. But headers are not set... in route configuration i have And in java: public void processHeaders(Message message) { Map headers = message.getHeaders(); for (Map.Entry

camel message headers

Hi, what values can be stored in message headers (using camel 2.6)? Is it restricted only to String values (like setHeader("MY_HEADER", "string value"))? Can I store any Java object (serializable) in message header (setHeader("MY_HEADER", new MyNewObject()) ) -- View this message in context:

endpoints password protection

Hello, is there any way to secure passwords for camel endpoints (ftp, smtp, ...)? Currently we store passwords in properties file (text) and use it in spring DSL like Can properties file be encrypted? Thanks. -- View this message in context: http://camel.465427.n5.nabble.c

Re: camel-ftp and file size check

it works with ftp as well, thanks! -- View this message in context: http://camel.465427.n5.nabble.com/camel-ftp-and-file-size-check-tp4364251p4364877.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-ftp and file size check

Hello, regarding camel-ftp component (I am using ftps), is there any way to get file size before consuming the file? The problem is, that I have to load the whole file into memory and process it. Loading big files into memory would cause out of memory exception, so I want to limit file size up to

camel components

Hi, i am new to camel (i use it in serviceMix), so the question might sound strange. How many instances of component class are created? For example, i use camel-cache component in several different bundles, injected with @EndpointInject(uri = "cache://cacheName?properties") //uri is differe

Re: IBM Websphere MQ <--> Camel routes

nfiguration for the route which is supposed to do the > reply that fails with the targetClient. > > > > On Tue, Feb 1, 2011 at 3:27 PM, tnk <[hidden email]> wrote: >> >> Hello, >> >> I have several IBM MQ brokers, who are sending messages through MQ hub.

IBM Websphere MQ <--> Camel routes

Hello, I have several IBM MQ brokers, who are sending messages through MQ hub. Messages arriving to Camel have JMSReplyTo property of format queue://QManager/QueueName. I need to define two Camel routes: first route reads requests from MQ queue and puts messages to ActiveMQ (IBMMQ2ActiveMQ), and