Re: File streaming using the Stream component in Camel 2.7 - changes

2012-04-26 Thread Claus Ibsen
Hi Can you enable DEBUG logging on org.apache.camel.component.stream And see in the logs. The exception may also be thrown due the file cannot be read (we should possible throw a better exception if thats the case). But the debug log will help us see what is going on. On Thu, Apr 26, 2012 at

Re: [SOLVED]Re: Camel-Stream URI error

2012-04-26 Thread Claus Ibsen
Hi I am not sure why you get empty lines. The components is using the API from the JDK to read a line by line with code line = br.readLine(); If you can reproduce the issue, then I suggest to use a debugger in the readFromStream method in the StreamConsumer, and see what is going on. Also it

Re: Gracefull shutdown timeouts due to NotifyBuilder blocks on context

2012-04-26 Thread Claus Ibsen
On Wed, Apr 25, 2012 at 1:29 PM, m.schm...@icw.de wrote: Hi Claus, I've attached a Eclipse/Maven testcase which exposes the blocking thread state every time. At least for me ;-) Could you give it a go? Thanks for the test case. I will take a look when I get some time. cheers, Matthias

Suitable scenario for Camel?

2012-04-26 Thread Fitzcaraldo
Hello We have the need to pull changes from Salesforce to an internal system using the web services API. For those that have not used it, the WS connection to salesforce has state in the sense that you must first login using a WS call, then query the relevant objects using one or more WS calls

Suitable scenario for Camel?

2012-04-26 Thread Fitzcaraldo
Hello We have the need to pull changes from Salesforce to an internal system using the web services API. For those that have not used it, the WS connection to salesforce has state in the sense that you must first login using a WS call, then query the relevant objects using one or more WS calls

Re: File streaming using the Stream component in Camel 2.7 - changes

2012-04-26 Thread Gnanaguru S
Claus, How do i enable DEBUG mode. ? :( Regards Guru -- View this message in context: http://camel.465427.n5.nabble.com/File-streaming-using-the-Stream-component-in-Camel-2-7-changes-tp4375640p5666843.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: File streaming using the Stream component in Camel 2.7 - changes

2012-04-26 Thread Claus Ibsen
On Thu, Apr 26, 2012 at 8:42 AM, Gnanaguru S gnanaguru.sattanat...@wipro.com wrote: Claus, How do i enable DEBUG mode. ? :( DEBUG logging. For example if you use log4j then configure its log4j.properties to enable logging at DEBUG level for the given package name. For example there is a

Unable to rollback exchange while unmarshalling a file

2012-04-26 Thread priya
Hi, We are having trouble while maintaining the transactions in a route which involves unmarshalling of a file and then writing its content into DB. Route is like: from( seda:xyz”) .transacted() .onException(Exception.class).maximumRedeliveries(0) .end() .split(new

Re: Configuring ShiroSecurityPolicy in XML

2012-04-26 Thread Claus Ibsen
On Wed, Apr 25, 2012 at 8:03 PM, dm...@gmx.de wrote: Hello, With Camel 2.9.2, how can I configure a route using a ShiroSecurityPolicy in Spring XML like the following Java sample? I have noticed a policy XML element, but this seems to do something else. ListPermission permissionsList =

Re: Http Route with WireTap -- Question/Issue

2012-04-26 Thread Claus Ibsen
Hi When you use http based routes, then the message is most likely stream based. And then you have to a bit more careful, as reading a stream message may only be possible once. So either enable stream caching in Camel. http://camel.apache.org/stream-caching.html Or convert the message to a

Re: JMS Endpoint Reuse and sending to different destinations @ Runtime

2012-04-26 Thread Claus Ibsen
Hi This seems like a permission/security setting. That your JMS broker denies sending to non existing topics. javax.jms.InvalidDestinationException: Not allowed to create destination You may need to create the destination on the JMS broker using its admin interface for that. On Wed, Apr 25,

Re: Cannot find resource in classpath using OSGi blueprint

2012-04-26 Thread Tobias Hofer
Hi, I've created the JIRA Issue CAMEL-5223 and attached a small test case. Regards, Tobias -- Tobias Hofer CTO, Geschäftsleitung basis06 AG - Birkenweg 61 - CH-3013 Bern http://www.basis06.ch - source of smart business - Original Message - From: Willem Jiang willem.ji...@gmail.com

Re: Cannot find resource in classpath using OSGi blueprint

2012-04-26 Thread Tobias Hofer
Hi, There was a recent fix on this. Can you try 2.9.3 SNAPSHOT. I tried that version, but the problem still exists here too. Also do you use xslt include or something? eg how is your xslt endpoint configured,etc. And do you use Windows or other OS. No include is used. See CAMEL-5223 for

javax.management.AttributeNotFoundException

2012-04-26 Thread Narita Bagchi
Hi, I am at Camel 2.9.0. I am able to view the MBean data for running processes in JConsole. I need to display the same in our user interface. While I try to fetch the attribute values, I get the following error. Note - Attribute EndpointUri is fetching the right value. Problem is with

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread Stefan Burkard
Hi - Is the adviced route working (is the expected exception thrown)? And make sure your transacted-statement in the route follows directly after the from-statement. cheers stefan On Wed, Apr 25, 2012 at 23:23, javaxmlsoapdev javaxmlsoap...@yahoo.com wrote: Hello, I have a use case to pick

Re: New JMS connection being created for every message

2012-04-26 Thread weberj
Yes, the pool is defined in Spring XML. Camel should run in JBoss 4, MQ is in the resource adapter (therefore the application client container complaint). Guess I'll have to remote debug the code.. The connection and route definitions cannot be totally wrong, as one or two messages are delivered

Re: javax.management.AttributeNotFoundException

2012-04-26 Thread Claus Ibsen
Hi Yeah Camel 1.x and 2.x has changed. The API for JMX is now in javadoc, and you can see the attributes here http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.html from this package

Re: New JMS connection being created for every message

2012-04-26 Thread Christian Schneider
In a container like jboss it should not be necessary to use the CachingConnectionFactory. Instead you should configure the resource adapter to support pooling. Then you can simply lookup the ConnectionFactory on jndi and use it as it is. The CachingConnectionFactory is typically used when

Re: New JMS connection being created for every message

2012-04-26 Thread weberj
This was my original configuration that pooling was in the resource adapter (the MQ RA has a default of 10 maxConnections). But when Camel closes the connection this somehow seems to close the RA's underlying connection, too. -- View this message in context:

Re: Read a file from network location

2012-04-26 Thread Claus Ibsen
On Thu, Apr 26, 2012 at 11:44 AM, Gnanaguru S gnanaguru.sattanat...@wipro.com wrote: Hi I am doing a simple file movement. My source file was in some remote location. How can I describe my shared location in my camel route. Whatever way that works with the java.io.File API. Regards

Re: Prevent done file deletion after file consumption

2012-04-26 Thread edvicif
Ok. I create a JIRA. Because with noop=true I expect not even done files got deleted. -- View this message in context: http://camel.465427.n5.nabble.com/Prevent-done-file-deletion-after-file-consumption-tp5665345p5667144.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Prevent done file deletion after file consumption

2012-04-26 Thread edvicif
Ticket generated under: https://issues.apache.org/jira/browse/CAMEL-5224 -- View this message in context: http://camel.465427.n5.nabble.com/Prevent-done-file-deletion-after-file-consumption-tp5665345p5667191.html Sent from the Camel - Users mailing list archive at Nabble.com.

RE: javax.management.AttributeNotFoundException

2012-04-26 Thread Narita Bagchi
We are fetching the values through MBeanServerConnection::getAttribute(X) method. I went through the Camel source code where these attributes are obtained through org.apache.camel.management.mbean.Statistic. I tried (non-static way) -

Re: Read a file from network location

2012-04-26 Thread Gnanaguru S
Ya. Its not working. from uri=file:10.200.208.223\\share\\input/ This is how i specified. Regards Guru -- View this message in context: http://camel.465427.n5.nabble.com/Read-a-file-from-network-location-tp5667150p5667219.html Sent from the Camel - Users mailing list archive at

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread javaxmlsoapdev
yeah. advised route is working as expected. it's throwing an expected exception. Also transacted() is directly after from(). Any other idea? Thanks, -- View this message in context: http://camel.465427.n5.nabble.com/Transacted-test-case-with-ActiveMQ-not-working-tp5666012p5667229.html Sent

Re: New JMS connection being created for every message

2012-04-26 Thread Christian Schneider
This is then probably an issue with the resource adapter. As far a I understood a Java EE application is expected to close the connection after each method call and the pool should then handle that this still is performant. Christian Am 26.04.2012 11:40, schrieb weberj: This was my original

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread Claus Ibsen
And you got a route that is properly setup to route from JMS - and do some stuff. Mind that a message only goes into the AMQ if the message is *already* in the broker. Also mind that to use persistent queues to ensure messages is kept in the queues if there is no active consumers. And for unit

Re: Read a file from network location

2012-04-26 Thread Marco Westermann
the file URI is file:// so the URL would look like file://\\10.200.208.223/share/input regards, marco Am 26.04.2012 12:28, schrieb Gnanaguru S: Ya. Its not working. from uri=file:10.200.208.223\\share\\input/ This is how i specified. Regards Guru -- View this message in context:

Re: Unable to rollback exchange while unmarshalling a file

2012-04-26 Thread Claus Ibsen
Hi There is a shareUnitOfWork option on the splitter. http://camel.apache.org/splitter On Thu, Apr 26, 2012 at 8:50 AM, priya joshipriyadarsh...@gmail.com wrote: Hi, We are having trouble while maintaining the transactions in a route which involves unmarshalling of a file and then writing

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread Stefan Burkard
You could also check for messages in DLQ.[your-queue-name] since this is often used as deadletterstrategy: individualDeadLetterStrategy queuePrefix=DLQ. useQueueForQueueMessages=true / If you find your message in there, you should check if you really work with embedded broker. I had

Re: Read a file from network location

2012-04-26 Thread Gnanaguru S
hi Marco, The route is started. 2092 [org.apache.camel.spring.Main.main()] INFO org.apache.camel.spring.SpringCamelContext - Route: route1 sta rted and consuming from: Endpoint[file://\\10.200.208.223/share/input] But it doesnt work. :( Regards Guru -- View this message in context:

Re: Read a file from network location

2012-04-26 Thread Claus Ibsen
On Thu, Apr 26, 2012 at 1:51 PM, Gnanaguru S gnanaguru.sattanat...@wipro.com wrote: hi Marco, The route is started. 2092 [org.apache.camel.spring.Main.main()] INFO org.apache.camel.spring.SpringCamelContext - Route: route1 sta rted and consuming from:

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread javaxmlsoapdev
Thanks all for taking time in responding. However it still doesn't work for me. May some stupid mistake? Any other ideas? here is how my route definition looks like in Java DSL @Component public class CustomRouter extends SpringRouteBuilder{ @Autowired private CustomQProcessor

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread Claus Ibsen
Remove the parallelProcessing as transactions should generally occur in the same thread. On Thu, Apr 26, 2012 at 3:56 PM, javaxmlsoapdev javaxmlsoap...@yahoo.com wrote: Thanks all for taking time in responding. However it still doesn't work for me. May some stupid mistake? Any other ideas?

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread Stefan Burkard
Can you give it a try to remove the whole broker-definition (broker:broker) from your config a try again? You are using the vm-transport-protocol and therefore, as I mentioned in the last post, activemq creates automatically a broker. I also had issues with missing messages as long as I had a

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread javaxmlsoapdev
Thanks Claus and Stefan. Removed parallelProcessing and also broker: config but still same behavior. May be I am missing something stupid? here is a stacktrace if that helps 1375 [main] INFO org.apache.camel.spring.SpringCamelContext - Apache Camel 2.9.1 (CamelContext: camelContext) is

Re: File Name through Aggregator

2012-04-26 Thread ebinsingh
Hi Claus, I have another issue with the aggregator. Hi, I am trying the aggregation with completionSize set to 2000. What happens is that the first output has 2000 records, but the second output has 4000 records instead of the next 2000 records. Is there someting am missing in my aggregator

Re: File Name through Aggregator

2012-04-26 Thread Claus Ibsen
I suggest to change your aggregation code to *not* create a new DefaultExchange manually. You should ideally just mutate the oldExchange all the time. On Thu, Apr 26, 2012 at 7:12 PM, ebinsingh ebenezer.si...@verizonwireless.com wrote: Hi Claus, I have another issue with the aggregator.

Re: Understanding Request-Reply EIP in Spring DSL

2012-04-26 Thread Eugeniu
I think your advice won't work in my case since I am trying to send different replies based on some conditions. Here is the scenario I am trying to implement in a route: 1. from is a cxf endpoint which gets order requests. 2. Perform first validation stage. If error - construct a error message,

DefaultJettyHttpBinding

2012-04-26 Thread Chris Odom
Has anyone every used this class? Currently I have implemented this strategy with in my JetyHttpComponent but no matter what happens my override methods never get called. In debug the jettyHttpBind property gets set to my Spring bean as I guess it suppose to but like I said I never ever get to

FileNotFoundException using propertyPlaceholder/

2012-04-26 Thread Henrique Viecili
Hi guys, I have a servicemix-camel SU and packaged inside a have a properties file META-INF/resources/conf/configuration.properties, and I declared it in my camel-context.xml with: camel:propertyPlaceholder id=properties location=classpath:META-INF/resources/conf/configuration.properties/ when

RE: JMS Endpoint Reuse and sending to different destinations @ Runtime

2012-04-26 Thread Gershaw, Geoffrey
Hi Claus, Thanks for the reply. I agree there is a permissions issue on the JMS Broker. The problem is that I can't see in the logs the name of the topic where I'm publishing. I am using the ProducerTemplate msgHeaders.put(JmsConstants.JMS_DESTINATION_NAME, destinationName);

Re: Transacted test case with ActiveMQ not working

2012-04-26 Thread Christian Müller
You didn't set the transaction manager in your ActiveMQComponent... May be this samples are useful for you: https://github.com/muellerc/camel-in-transaction There is a similar unit test at:

Re: Http Route with WireTap -- Question/Issue

2012-04-26 Thread mccabejj
Thanks Claus. You are correct the messages are stream based, and the behavior I've noticed seems to fit in precisely with the http://camel.apache.org/stream-caching.html documentation . Per your advice I have tried reconfiguring both the Camel Context and the individual routes to have

A simple that was working before is not working now (2.10-SNAPSHOT)

2012-04-26 Thread soumya_sd
The following route was working a while ago without any errors. I'm using 2.10-SNAPSHOT in my pom.xml. Any idea what might have changed which is causing this exception ? OR what am I doing wrong here. from(direct://start) --

Re: Understanding Request-Reply EIP in Spring DSL

2012-04-26 Thread Claus Ibsen
On Thu, Apr 26, 2012 at 8:16 PM, Eugeniu eugen...@hotmail.com wrote: I think your advice won't work in my case since I am trying to send different replies based on some conditions. Here is the scenario I am trying to implement in a route: 1. from is a cxf endpoint which gets order requests.

How to achieve multi-threading within a route

2012-04-26 Thread Deepthi
Hi, I am trying to read files from 1 server through FTP, process the files and FTP it to another server. How can i achieve multi-threading within a route. If i have 50 files in the source server, I want 50 threads to be running simultaneously, read the files and process all the files

Re: A simple that was working before is not working now (2.10-SNAPSHOT)

2012-04-26 Thread Gnanaguru S
Can you copy your route here ? Regards Guru -- View this message in context: http://camel.465427.n5.nabble.com/A-simple-that-was-working-before-is-not-working-now-2-10-SNAPSHOT-tp5669186p5669254.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: DefaultJettyHttpBinding

2012-04-26 Thread Claus Ibsen
Hi Yes its in use. What version of Camel are you using? And you need to either configure it on the jetty http component, or on the endpoint with the option name jettyHttpBindingRef On Thu, Apr 26, 2012 at 9:09 PM, Chris Odom chris.o...@mediadriver.com wrote: Has anyone every used this class?

Re: Transform and multiply

2012-04-26 Thread Claus Ibsen
On Thu, Apr 26, 2012 at 6:21 AM, Hynek Cihlar hynek.cih...@gmail.com wrote: Hynek Cihlar wrote Claus Ibsen-2 wrote On Tue, Apr 24, 2012 at 6:03 PM, Hynek Cihlar lt;hynek.cihlar@gt; wrote: Hello all, what would be the best approach to solve the transform and multiply behavior? That is,

Re: JMS Endpoint Reuse and sending to different destinations @ Runtime

2012-04-26 Thread Claus Ibsen
On Thu, Apr 26, 2012 at 11:02 PM, Gershaw, Geoffrey geoffrey.gers...@credit-suisse.com wrote: Hi Claus, Thanks for the reply. I agree there is a permissions issue on the JMS Broker. The problem is that I can't see in the logs the name of the topic where I'm publishing. Well thats maybe