Re: ConsumerTemplate and OOM exception

Just to follow up on this.. It seems like I overwrote my startup file and so the -Xmx512m was not there anymore.. After adding it back I don't saw the OOM anymore.. Thx for all your help, Norman 2010/3/23 Norman Maurer : > Will do.. > > Bye, > Norman > > > 2010/3/23 Claus Ibsen : >> Hi >> >> Al

Re: CXFRS Routing in 2.2.0 does not behave like in 2.0.0

Hi, Can you try to use the latest Camel 2.3.0-SNAPSHOT? I just remembered I fixed a bus related issue[1] last month. [1]https://issues.apache.org/activemq/browse/CAMEL-2465 Willem jejmaster wrote: Okay so here's how i defined my applicationContext for camel routing. By the way, I am using b

Re: try-catch conflict with default-error-handler

Sorry, I forget to say, this is running on camel 2.2; I have checked the camel's document and source-code; the camel-document say " try-catch will disable the error-handler"; but while I checking the source-code of camel , it only disable error-handlers of node (which is conjunction with doTry pa

try-catch conflict with default-error-handler

Follow route use a default-error-handler for the route, and also defined a custom exception handle logic using try-catch-pattern. But if the "myProcessRaiseError" raised exception the catch-clause cannot be invoked; Why? Is it camel's bug? $

Re: Dynamic FTP Poller

On Thu, Mar 25, 2010 at 8:39 PM, johnf wrote: > > Hi, > > We have a need to poll a number of different ftp locations for various > files. We normally express the pattern of the files we are looking for with > wild cards. > > I'm trying to come up with a generic way in Camel to configure routes for

Re: How camel define content of message sent to catch clause ?

On Fri, Mar 26, 2010 at 6:07 AM, ext2 wrote: > > > In camel , try-catch means , if exception occurs , catch-clause will be > execute. > And how does camel define : What is message(catch-clause received) 's > content? > > Is the content exactly equals to the processed content where exception just >

Re: CXFRS Routing in 2.2.0 does not behave like in 2.0.0

Okay so here's how i defined my applicationContext for camel routing. By the way, I am using both Soap And REST as router endpoints for this. applicationContext-camel.xml http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:jaxws="ht

How camel define content of message sent to catch clause ?

In camel , try-catch means , if exception occurs , catch-clause will be execute. And how does camel define : What is message(catch-clause received) 's content? Is the content exactly equals to the processed content where exception just occurs? For pipe line , catch-clause will received a mess

Re: CXFRS Routing in 2.2.0 does not behave like in 2.0.0

You are using CXFServlet transport, can I have a look at your hole application context configuration? It may relate to CXF Bus configuration. Willem jejmaster wrote: Hello, Currently, I tried to upgrade Camel version from 2.0.0 to 2.2.0 and CXF version to 2.2.2 to 2.2.6. In 2.0.0, I have a CX

CXFRS Routing in 2.2.0 does not behave like in 2.0.0

Hello, Currently, I tried to upgrade Camel version from 2.0.0 to 2.2.0 and CXF version to 2.2.2 to 2.2.6. In 2.0.0, I have a CXFRS Endpoints and Route as follows: http://localhost:8080/services/rest"; serviceClass="com.project.service.impl.ServiceManagerImpl" /> Upon invoking

Dynamic FTP Poller

Hi, We have a need to poll a number of different ftp locations for various files. We normally express the pattern of the files we are looking for with wild cards. I'm trying to come up with a generic way in Camel to configure routes for each location/pattern we need to poll for. I've looked at

Re: error-handling advice with queues

I would think something like .beanRef("processor", "process") .split().method("mySplitterBean", "splitMessage") .choice .when(simple("${in.header.error} != null").to("mock:invalid") .otherwise().to("mock:valid"); Your mySplitterBean would just create a 2 different messages, one with the error hea

Re: Starting and Suspending routes

On Thu, Mar 25, 2010 at 10:39 AM, Tarjei Huse wrote: > > Hi, > > Yesterday C. Ibsen tough me that you cannot start and stop routes when you > use JMS connectors, but you can suspend them using a route policy. > Your problem was that you wanted to stop a JMS listener in the same thread it was proc

Re: error-handling advice with queues

The splitter stuff doesn't seem to be useful for my issue, but I can see now in the CBR page how to do logic in the route based on the header. In fact, I was using the CBR on my route already. I'm still not clear on how to actually set the header to the "error object in java code. Here is the g

Exception not redelivered - camel 2 - SMX3

Hi, I try to redeliver 3 times when an error occurs but this does not seem to be the case !! Here is the route deployed in a SU on ServiceMix 3 : public void configure() throws Exception { Tracer tracer = new Tracer(); tracer.setLogLevel(LoggingLevel.FATAL); tracer.s

Re: How to invoke specific operation with params for cxf webservice endpoint through configuration

Oh, you are working in MESSAGE dataformat, which means you need to build the request message yourself. But if you want camel-cxf to generate the request for you, you need to use CXF wsdl2java tool to build the artifacts with the WSDL first, then you can follow the example[1] to invoke the servi

Re: How to invoke specific operation with params for cxf webservice endpoint through configuration

Hi Ashwin, Is there anywhere to specify ( to call specific method of web-service) like operationName="sayHello" in the following http://localhost:8080/someService/"; wsdlURL="../sr-binding/src/main/resources/META-INF/wsdl/someservice.wsdl" endpointName="s:myEndpointName" serviceName="s:myServ

Re: Reconnect topic subscriber after connection failure

Hi, I am performing some tests, and noticed that when I create the route in xml (with the subscriptionDurable=true parameter), the subscribers come online after restart of activeMQ. When I use the fluent api the subscriber goes offline. This code goes offline when ActiveMQ restarts public void c

Re: Reconnect topic subscriber after connection failure

I think that you must define the subscription as durable like that : from(activemq:queue:example1?durableSubscriptionName=TopicReader1&subscriptionDurable=true").to(""); Charles Moulliard Senior Enterprise Architect Apache Camel Committer * blog : http://cmoullia

Re: FileConsumer always reads the data in system charset/encoding

Hi, > There used to be a issue in Camel with using CGLib proxied Spring > beans, but I recall that was fixed in 2.2 as well. > And that issue was only when you used Camel @annotations which causes > them to not work as expected. > Spring @Transactional is to my knowledge working. > > Maybe the Spr

Re: Reconnect topic subscriber after connection failure

Hi Charles, the behavior might be correct but not what I expected :-) No really, is there a way to configure spring/camel to restart the topic subscriber when the connection is refreshed? I would like to have messages forwarded all the time, even after restarts of the ActiveMQ broker or network p

Re: Reconnect topic subscriber after connection failure

Leen, The behavior observed is correct because messages could not forwarded till that a jms client (= camel jms endpoint) consume the messages from the topic. Kind regards, Charles Moulliard Senior Enterprise Architect Apache Camel Committer * blog : http://cmoulliar

Reconnect topic subscriber after connection failure

Hi, I have the following topic subscriber public void configure() throws Exception { ActiveMQConnectionFactory connectionFactory = lookup(ActiveMQConnectionFactory.class); JmsTransactionManager jmsTransactionManager = lookup(JmsTransactionManager.class); JmsEndpoint topic = (JmsEndpoint) endpoin

Re: JMS send Timeout

Yes, that is what I would like to achieve. When the queue cannot accept a message immediately the producer should receive an error and retry later. My problem is that the producer is a critical single threaded process (and out of my control) and should never be blocked. This parameter helps in some

Starting and Suspending routes

Hi, Yesterday C. Ibsen tough me that you cannot start and stop routes when you use JMS connectors, but you can suspend them using a route policy. Today I want to rewrite a simple interface I've written to handle starting and stopping routes so that they are suspended instead - I.e. that I work

Re: JMS send Timeout

Hi Leen, >From my understanding, this parameter "sendFailIfNoSpace" of ActiveMq will send back to the producer an error message when we have slow consumers and if memory usage is reached. See here for an explanation : http://blog.garytully.com/2009/01/activemq-systemusage-xml-configuration.html

Re: JMS send Timeout

Hi, to answer my own question. I managed to do what I wanted by setting this parameter in activemq.xml

Re: Must I using the spring-osgi-namespace in osgi environment?

On Thu, Mar 25, 2010 at 9:55 AM, ext2 wrote: > > Hi: >        camel-osgi component give another a spring osgi > namespace."http://camel.apache.org/schema/osgi";. >        But if I use the normal > spring-namespace(http://camel.apache.org/schema/spring), it seems works well > too in osgi environmen

Must I using the spring-osgi-namespace in osgi environment?

Hi: camel-osgi component give another a spring osgi namespace."http://camel.apache.org/schema/osgi";. But if I use the normal spring-namespace(http://camel.apache.org/schema/spring), it seems works well too in osgi environment. So what's the real different for the osgi name

Re: FileConsumer always reads the data in system charset/encoding

On Wed, Mar 24, 2010 at 6:52 PM, Kevin Jackson wrote: > Hi, > > To clear this whole thing up - I can now report that everything is > working as expected, the problem was (and still is) with Spring's > transactional test support, not rolling back the data that my > processing is adding to the datab

Re: Possible cause of slow

Hi Check which kind of message exchange pattern you use: InOnly or InOut. As if you use the latter then sending over JMS will have it wait for a reply. And thus could explain the slow. Routing slip is sometimes mixed up with recipient list EIP pattern. So take a look if its the right pattern you

Re: Building camel from source deletes C:\Temp\*

Hi Well the temp folder is there for a reason since its a temp folder. If you want to keep stuff use a NON temp folder :) You are welcome to search the unit tests to see if you can find the tests which may delete that folder. Mind that its uses the Java temp folder as Unix machines uses /tmp On