Re: Newbie question: Topology for Camel: Servlet -> Quartz -> JMS

Hi On Wed, Apr 25, 2012 at 5:11 PM, Reynald wrote: > Hi all, > > I'm reading through all the documentation of Camel. I'm really excited but > due to the extent of the docs and my lack of experience on it, I'd > appreciate if somebody give some guidelines on the following scenario. I > want to ke

Re: Http Route with WireTap -- Question/Issue

Hi Are you http payloads big? The Camel stream cache will spool to disk for > 64kb, and when it does that, it will automatic cleanup the disk when the routing is done. I could be that when wire tapping the big streams will just copy the reference to the disk file, and so when the routing is done t

Re: Sample Camel service for HTTP/HTTPS

On Wed, Apr 25, 2012 at 8:23 PM, goutham wrote: > Hi, > > we are trying to implement a camel service. Please help me out with few > samples if you have. > > Requirement. > > Channel will make a call to particular Endpoint Via HTTP/HTTPS call and > internally the camel should make a call to some ot

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

On Thu, Apr 26, 2012 at 11:02 PM, Gershaw, Geoffrey 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 because Camel dont reach so far

Re: Transform and multiply

On Thu, Apr 26, 2012 at 6:21 AM, Hynek Cihlar wrote: > > Hynek Cihlar wrote >> >> >> Claus Ibsen-2 wrote >>> >>> On Tue, Apr 24, 2012 at 6:03 PM, Hynek Cihlar >>> wrote: Hello all, what would be the best approach to solve the "transform and multiply" behavior? T

Re: DefaultJettyHttpBinding

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 wrote: > > > Has anyone every used this class? Currently I have implem

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

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.

How to achieve multi-threading within a route

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 simultaneous

Re: Understanding Request-Reply EIP in Spring DSL

On Thu, Apr 26, 2012 at 8:16 PM, Eugeniu 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. is a cxf endpoint which gets order requests. > 2. Perform first vali

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

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) --> https://maps.googleapis.com/maps/api/place/search/json?sensor=false&lo

Re: Http Route with WireTap -- Question/Issue

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 streamCach

Re: Transacted test case with ActiveMQ not working

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: https://github.com/muellerc/camel-in-transaction/blob/master/src/test/java/org/apache/cmueller/camel/samples

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

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); jmsProducer.se

FileNotFoundException using

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: when I deploy the SA in ServiceMix I get the FileNotFoundException. I've checked the .zip packages and my SU.zip c

DefaultJettyHttpBinding

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 my

Re: Understanding Request-Reply EIP in Spring DSL

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. is a cxf endpoint which gets order requests. 2. Perform first validation stage. If error - construct a error message, send t

Re: File Name through Aggregator

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 wrote: > Hi Claus, > > I have another issue with the aggregator. > > Hi, > > I am trying the aggregat

Re: File Name through Aggregator

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 log

Re: Transacted test case with ActiveMQ not working

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 starting

Re: Transacted test case with ActiveMQ not working

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 brok

Re: Transacted test case with ActiveMQ not working

Remove the parallelProcessing as transactions should generally occur in the same thread. On Thu, Apr 26, 2012 at 3:56 PM, javaxmlsoapdev wrote: > 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 d

Re: Transacted test case with ActiveMQ not working

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 cus

Re: Read a file from network location

On Thu, Apr 26, 2012 at 1:51 PM, Gnanaguru S 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: Endpoint[file://\\10.200.208.223/share/input] > > But it doesn

Re: Read a file from network location

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: http://c

Re: Transacted test case with ActiveMQ not working

You could also check for messages in DLQ.[your-queue-name] since this is often used as deadletterstrategy: If you find your message in there, you should check if you really work with embedded broker. I had issues with two brokers as soon as I declared one in spring-xml-config for testing since on

Re: Unable to rollback exchange while unmarshalling a file

Hi There is a shareUnitOfWork option on the splitter. http://camel.apache.org/splitter On Thu, Apr 26, 2012 at 8:50 AM, priya wrote: > 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

Re: Read a file from network location

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. This is how i specified. Regards Guru -- View this message in context: http://camel.465427.n5.nabble.com/Read-a-file-fr

Re: Transacted test case with ActiveMQ not working

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 te

Re: New JMS connection being created for every message

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 c

Re: Transacted test case with ActiveMQ not working

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 fro

Re: Read a file from network location

Ya. Its not working. 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 Nabble.com.

RE: javax.management.AttributeNotFoundException

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) - MBeanServerConnection::getAttribute("org.apache.camel.fir

Re: Prevent done file deletion after file consumption

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: Prevent done file deletion after file consumption

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: Read a file from network location

On Thu, Apr 26, 2012 at 11:44 AM, Gnanaguru S 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 > Guru > > -- > View this

Re: New JMS connection being created for every message

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: http://camel.465427.n5.nabble.com/New-

Re: New JMS connection being created for every message

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 yo

Re: javax.management.AttributeNotFoundException

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 http://camel.apache.org/maven/current

Re: New JMS connection being created for every message

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: Transacted test case with ActiveMQ not working

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 wrote: > Hello, > > I have a use case to pick up a message from sour

javax.management.AttributeNotFoundException

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 "Firs

Re: Cannot find resource in classpath using OSGi blueprint

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 d

Re: Cannot find resource in classpath using OSGi blueprint

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" > To: users@camel.apac

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

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, 2

Re: Http Route with WireTap -- Question/Issue

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 Strin

Re: Configuring ShiroSecurityPolicy in XML

On Wed, Apr 25, 2012 at 8:03 PM, 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. > > List permissionsList = new ArrayList();

Unable to rollback exchange while unmarshalling a file

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 SplitterExpression(inputFile