Re: Camel Security Framework - ActiveMQ Store error
You have a version mismatch, camel-core-2.12.2 is being used with
camel-jms-2.9.2
Taariq
On Wed, Jan 8, 2014 at 8:47 AM, contactreji contactr...@gmail.com wrote:
Hi
I was trying to do some encryption exercises. Once the message is
decrypted,
I am unable to store the result into a ActiveMQ Queue.
Would be really helpful if someone can suggest a fix. The encryption and
decryption are successfully working.
My Camel Routes are as follows:
*?xml version=1.0 encoding=UTF-8?
beans xmlns=http://www.springframework.org/schema/beans;
xmlns:camel=http://camel.apache.org/schema/spring;
xmlns:crypt=http://springcryptoutils.com/schema/crypt;
xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance;
xmlns:amq=http://activemq.apache.org/schema/core;
xsi:schemaLocation=
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://springcryptoutils.com/schema/crypt
http://springcryptoutils.com/schema/crypt.xsd;
bean id=activemq
class=org.apache.activemq.camel.component.ActiveMQComponent
property name=brokerURL
value=failover:tcp://localhost:61620 /
property name=userName value=admin /
property name=password value=admin /
/bean
crypt:keystore id=keyStore location=classpath:shared.jceks
password=sharedKeystorePassword type=JCEKS /
crypt:secretKey id=secretKey keystore-ref=keyStore
alias=shared password=sharedKeyPassword /
camelContext xmlns=http://camel.apache.org/schema/spring;
dataFormats
crypto id=sharedKeyCrypto algorithm=DES
keyRef=secretKey /
/dataFormats
route streamCache=true
from uri=activemq:inputToEncrypt /
log message=Encrypting message /
marshal ref=sharedKeyCrypto /
log message=Message encrypted: ${body} /
to uri=seda:decrypt /
/route
route
from uri=seda:decrypt /
log message=Decrypting message /
unmarshal ref=sharedKeyCrypto /
log message=Message decrypted: ${body} /
to uri=activemq:decryptedMessages /
/route
/camelContext
/beans*
The Exception which is thrown with stack trace is as follows
*
SLF4J: Failed to load class org.slf4j.impl.StaticLoggerBinder.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
details.
[INFO] Scanning for projects...
[INFO]
[INFO]
[INFO] Building ActiveMQ embedded with Camel 1.0.0-SNAPSHOT
[INFO]
[INFO]
[INFO] camel-maven-plugin:2.10.0.redhat-60024:run (default-cli) @
camel-activemq
[INFO]
[INFO] --- maven-resources-plugin:2.4.3:resources (default-resources) @
camel-activemq ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 4 resources
[INFO]
[INFO] --- maven-compiler-plugin:2.5.1:compile (default-compile) @
camel-activemq ---
[INFO] Nothing to compile - all classes are up to date
[INFO]
[INFO] --- maven-resources-plugin:2.4.3:testResources
(default-testResources) @ camel-activemq ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 0 resource
[INFO]
[INFO] --- maven-compiler-plugin:2.5.1:testCompile (default-testCompile) @
camel-activemq ---
[INFO] Nothing to compile - all classes are up to date
[INFO]
[INFO] camel-maven-plugin:2.10.0.redhat-60024:run (default-cli) @
camel-activemq
[INFO]
[INFO] --- camel-maven-plugin:2.10.0.redhat-60024:run (default-cli) @
camel-activemq ---
[INFO] Using org.apache.camel.spring.Main to initiate a CamelContext
[pache.camel.spring.Main.main()] MainSupportINFO
Apache
Camel 2.12.2 starting
[pache.camel.spring.Main.main()] ClassPathXmlApplicationContext INFO
Refreshing
org.springframework.context.support.ClassPathXmlApplicationContext@de643a:
startup date [Wed Jan 08 12:11:20 IST 2014]; root of context hierarchy
[pache.camel.spring.Main.main()] XmlBeanDefinitionReaderINFO
Loading XML bean definitions from file
[C:\Users\re267981\workspace\camel-security-exchangeEncryption\target\classes\META-INF\spring\camel-context.xml]
[pache.camel.spring.Main.main()] DefaultListableBeanFactory INFO
Pre-instantiating singletons in
Re: StackTraceElement using heap.
...update If we stop sending messages through the cxf endpoint, the heap growth is stopped, but it never decreases tp the normal level again, leaving a lot of StackTraceElement instances left in the heap. Funny thing is that when we do a heapdump from jvisualvm the garbage collection removes the StackTraceElement instances and the heap is back to normal. Is there a difference between the normal GC and the GC that is done when a heapdump is made? I guess when making a heapdump, one will ensure that only the instances that are really still into play are shown, so it might be more agressive in any way? But still, there must be something referencing the StackTraceElement / StackTraceelement[] long after the stack trace has happend. We are running a test now, where we are letting the endpoint decribed ealier connect, but responding with a message that fails in the response decoder, to see if we see the same problem. If not there must be something with regards to cxf I guess. /Trond -- View this message in context: http://camel.465427.n5.nabble.com/StackTraceElement-using-heap-tp5745623p5745726.html Sent from the Camel - Users mailing list archive at Nabble.com.
Is there a clean way to default route transaction mode at the route builder level
Hello,
in our current implementation, in camel 2.11, transaction mode is set
globally inside a class which extend routebuilder, inside the
interceptFrom() method.
Since camel 2.12 onwards, this seems not to be tolerated anymore due to the
fact that when switching the transaction mode the route is already started.
(which perfectly make sense)
I did tried to set it in an overrided configureRoute(RouteDefinition route)
method or override all the from() method to set the default transacted mode
at this stage but without sucess
here is what I tried :
protected void configureRoute(RouteDefinition route) {
super.configureRoute(route);
if (!route.getOutputs().contains(PolicyDefinition)){
route.transacted(PROPAGATION_REQUIRES_NEW);
//complains that output processor is missing ?? (chaining of
the
route is wrong remaining part still chain to the from() instead of the
from().output()
}
}
if you have some usefull info of the best approach to use, I would be
interested.
Thank-you in advance,
Regards,
Stéphane.
--
View this message in context:
http://camel.465427.n5.nabble.com/Is-there-a-clean-way-to-default-route-transaction-mode-at-the-route-builder-level-tp5745728.html
Sent from the Camel - Users mailing list archive at Nabble.com.
File component and include option
Hi, I have a File Consumer that reads files (something.txt) from the following folders: file://base/something/2013/12/30/specific/even/more file://base/something/2013/12/31/specific/even/more file://base/something/2014/01/01/specific/even/more etc. so the middle part of the folder name is variable. I'm using the following to build the camelUrlBuilder(base).append(Args.parse(inboundArgs)).build(); where: base=file://base/something inboundArgs=[a number of URI options amongst them the following include: something.txt) This is working fine, but since I know that the something.txt file always live inside the subdirectory /specific/even/more, I would like to provide Camel with this information to narrow down the search path. How do I do that? I've tried the following include strings: /specific/even/more/something.txt \specific\even\more\something.txt specific/even/more/something.txt specific\even\more\something.txt None of them work. Any idea? Many thanks! -- View this message in context: http://camel.465427.n5.nabble.com/File-component-and-include-option-tp5745730.html Sent from the Camel - Users mailing list archive at Nabble.com.
Distributed AggregationRepository
Hi camel-users, Since we're going to run our system distributed (multiple containers in Fuse Fabric) we need an alternative to the default MemoryAggregationRepository. Although we found it awkward that the Hazelcast component only offers an IdempotentRepository and no AggregationRepository we found an implementation here: https://github.com/smecsia/camel-hazelcast. We tried that but sometimes we get strange TimeoutExceptions and we're not experienced enough with Hazelcast to determine the root-cause. Some extra searching on the Camel site led me to HawtDB ( http://camel.apache.org/hawtdb.html). So I now have 3 questions: 1) does HawtDB work out-of-the-box in a distributed environment (provided that you can place the file on a shared location), and can it recover wihtout extra manual steps? 2) can you place multiple repositories in a single file or do you need a separate file per repository (we have 5 aggregators on our system, each one needing its own repository) 3) are there any other proven and documented implementations of AggregationRepository that work in distributed environments? Thanks in advance, Tom
Re: Spring AMQP Apache Camel Component Released
Hi, Just wanted to check with you and see if you were able to re-produce this issue. Let me know if you either need more information or if you want me to try some thing out. Thanks, Muthu -- View this message in context: http://camel.465427.n5.nabble.com/Spring-AMQP-Apache-Camel-Component-Released-tp5027785p5745736.html Sent from the Camel - Users mailing list archive at Nabble.com.
camel jms polling
Hi, I have two routes camel:route id=route1 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean1 method=method1/camel:bean /camel:route camel:route id=route2 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean2 method=method2/camel:bean /camel:route in bean1 and bean2, i poll messages from different JMS queues. When i start the server, polling consumer in bean1 waits (and blocks) for messages to be available in jms queue. Is there any way i can run both routes in parallel?
Re: Distributed AggregationRepository
Careful, HawtDB is deprecated, as advertised in the camel-hawtdb component page. Unfortunately, the warning doesn't render in a shaded box any longer (due to some recent Confluence migration), so it's easy to miss it. Sorry about that. LevelDB is recommended instead, but the technology has two limitation: it runs embedded and only one physical process can open the data files simultaneously. In other words, it does not support distributed access OOTB. The old-school advice would be to use the JDBC Aggregation Repository along with either a SQL DB or a NoSQL DB from whom JDBC support exists. For example, there are some experimental projects providing JDBC drivers for MongoDB, or OrientDB has some support for JDBC too. Alternatively, we would be extremely happy if you contributed a new NoSQL Aggregation Repository. I can see much benefit in incorporating a MongoDB Aggregation Repository to the camel-mongodb component which uses the native Java driver. Regards, *Raúl Kripalani* Apache Camel PMC Member Committer | Enterprise Architect, Open Source Integration specialist http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani http://blog.raulkr.net | twitter: @raulvk On Wed, Jan 8, 2014 at 3:14 PM, Tom Fornoville tom.fornovi...@roots.bewrote: Hi camel-users, Since we're going to run our system distributed (multiple containers in Fuse Fabric) we need an alternative to the default MemoryAggregationRepository. Although we found it awkward that the Hazelcast component only offers an IdempotentRepository and no AggregationRepository we found an implementation here: https://github.com/smecsia/camel-hazelcast. We tried that but sometimes we get strange TimeoutExceptions and we're not experienced enough with Hazelcast to determine the root-cause. Some extra searching on the Camel site led me to HawtDB ( http://camel.apache.org/hawtdb.html). So I now have 3 questions: 1) does HawtDB work out-of-the-box in a distributed environment (provided that you can place the file on a shared location), and can it recover wihtout extra manual steps? 2) can you place multiple repositories in a single file or do you need a separate file per repository (we have 5 aggregators on our system, each one needing its own repository) 3) are there any other proven and documented implementations of AggregationRepository that work in distributed environments? Thanks in advance, Tom
Re: camel jms polling
Here problem is both routes are running sequentially. I tried with camel:threadPoolProfile id=defaultThreadPoolProfile defaultProfile=true poolSize=10 maxPoolSize=20 maxQueueSize=1000 rejectedPolicy=CallerRuns / as well, doesn't help. On Wed, Jan 8, 2014 at 10:08 PM, Tarun Kumar agrawal.taru...@gmail.comwrote: Hi, I have two routes camel:route id=route1 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean1 method=method1/camel:bean /camel:route camel:route id=route2 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean2 method=method2/camel:bean /camel:route in bean1 and bean2, i poll messages from different JMS queues. When i start the server, polling consumer in bean1 waits (and blocks) for messages to be available in jms queue. Is there any way i can run both routes in parallel?
Re: Distributed AggregationRepository
Hi Tom, Since we're going to run our system distributed (multiple containers in Fuse Fabric) we need an alternative to the default MemoryAggregationRepository. As Raul said, JDBC is the only real distributed option for a while. Keep in mind however that even if SQL performance might not be the best option, you can start with JDBC repository and relatively easy switch to the other implementation later. Life time of data kept in aggregation repositories is very short, so there is no migration burden associated with the repository replacement. This might be an option to start with something and buy some time to create NoSQL/DistributedMemoryGrid/JGroups based solution that will scale better. Cheers. -- Henryk Konsek http://henryk-konsek.blogspot.com
Re: camel jms polling
give your timer name something unique for each route: http://camel.apache.org/timer.html On Wed, Jan 8, 2014 at 9:11 AM, Tarun Kumar agrawal.taru...@gmail.com wrote: Here problem is both routes are running sequentially. I tried with camel:threadPoolProfile id=defaultThreadPoolProfile defaultProfile=true poolSize=10 maxPoolSize=20 maxQueueSize=1000 rejectedPolicy=CallerRuns / as well, doesn't help. On Wed, Jan 8, 2014 at 10:08 PM, Tarun Kumar agrawal.taru...@gmail.comwrote: Hi, I have two routes camel:route id=route1 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean1 method=method1/camel:bean /camel:route camel:route id=route2 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean2 method=method2/camel:bean /camel:route in bean1 and bean2, i poll messages from different JMS queues. When i start the server, polling consumer in bean1 waits (and blocks) for messages to be available in jms queue. Is there any way i can run both routes in parallel? -- Christian Posta http://www.christianposta.com/blog twitter: @christianposta
Re: Holding a value in camel blueprint
You can always store values as properties on the exchange which will be available there for the lifecycle of the exchange. And if the value need to be accessible between multiple external interactions with the router, you can temporary store it in a cache [1] component. [1] http://camel.apache.org/cache.html Cheers. -- Henryk Konsek http://henryk-konsek.blogspot.com
Re: ActiveMQ processing
I know that I will get the result when the request is solved in queue, but for example, when I am processing big amount of data, I don't want to wait 20 seconds. You won't wait. :) You will submit task to the queue and immediately return control to the response bean at the end of the route. In the meantime another route will consume orders from the queue and create users in the background: from(activemq:queue:users.add). bean(SlowBeanAddingUsers.class). to(activemq:queue:users.done); from(activemq:queue:users.done).to(mock:notifyMeWhenUserHasBeenCreated); You're on the right track with your example. :) Cheers. -- Henryk Konsek http://henryk-konsek.blogspot.com
Re: CXF : Camel 2.12.2 : Karaf 3.0.0 : Soap-Timeout
I'm not sure this is a bug in PaxWeb, it might be in Jetty, but I think I've seen this once with a Karaf 2.x version. But I can't remember how I solved it. Something from the back of my head tells me it's something in the webservice. Somehting more like the payload might be to big ... regards, Achim 2014/1/8 Willem Jiang willem.ji...@gmail.com Hi Thomas, If the route can work in Karaf 2.3.3 instead of Karaf 3.0.0. I think it’s bug of PaxWeb which provide the Servlet OSGi service. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On January 8, 2014 at 3:36:38 AM, Freihalter Thomas ( thomas.freihal...@my-box.de) wrote: Hello guys, I am using Karaf 3.0.0 and Camel 2.12.2 If I send a Soap-Envelope to Jetty, the response contains a '8000' before the Soap-Envelope. What does this mean and how can I avoid this? SoapUi (and my jQuery-Client) is running into timeout. With Karaf 2.3.3 everything is okay (no '8000'). That's my route: I guess this is related to the response-size, because a mirroring response works (no '8000'): best regards Thomas SoapUi Http-Log: POST /cxf/XmlTransfer HTTP/1.1[\r][\n] Accept-Encoding: gzip,deflate[\r][\n] Content-Type: text/xml;charset=UTF-8[\r][\n] SOAPAction: [\r][\n] Content-Length: 846[\r][\n] Host: localhost:8181[\r][\n] Connection: Keep-Alive[\r][\n] User-Agent: Apache-HttpClient/4.1.1 (java 1.5)[\r][\n] [\r][\n] xmlns:soapenv=http://schemas.xmlsoap.org/soap/envelope/; xmlns:ns=http://xmltransfer.util.com;[\n] [\n] [\n] [\n] ...[\n] ?[\n] [\n] [\n] HTTP/1.1 200 OK[\r][\n] Content-Type: text/xml;charset=UTF-8[\r][\n] Transfer-Encoding: chunked[\r][\n] Server: Jetty(8.1.14.v20131031)[\r][\n] [\r][\n] 8000[\r][\n] xmlns:soap=http://schemas.xmlsoap.org/soap/envelope/;... [\r][\n] -- Apache Karaf http://karaf.apache.org/ Committer PMC OPS4J Pax Web http://wiki.ops4j.org/display/paxweb/Pax+Web/ Committer Project Lead OPS4J Pax for Vaadin http://team.ops4j.org/wiki/display/PAXVAADIN/Home Commiter Project Lead blog http://notizblog.nierbeck.de/
Re: Appending value to XML - Camel Blueprint
Did you checked [1] or [2]?
simple${bodyAs(String)}${property[empName]}/simple
or
ruby$body$property['empName']/ruby
or
...
[1] http://camel.apache.org/simple.html
[2] http://camel.apache.org/scripting-languages.html
Best,
Christian
-
Software Integration Specialist
Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member
https://www.linkedin.com/pub/christian-mueller/11/551/642
On Sun, Jan 5, 2014 at 4:00 AM, camel user cameluser2...@yahoo.in wrote:
I want to append a property set in the first route to the resultant XML of
the serviceURI hit from the second route. If its possible, please let me
know how.
Sample snippet below.
route
--some stuff goes here--
setProperty
propertyName=empNamexpath/result/empName/text()/xpath/setProperty
--some stuff goes here--
to uri=direct:route2
/route
route
from uri=direct:route2
to uri=serviceURI/
--${body} will have the resultant xml--
--here I want to append empName(property defined in route 1) as an XML tag
to ${body}--
/route
Thanks!
Re: Multicast EIP - Camel Blueprint
Why do you think you have to use multicast [1]? Didn't you want a pipeline
[2]?
[1] http://camel.apache.org/multicast.html
[2] http://camel.apache.org/pipes-and-filters.html
Best,
Christian
-
Software Integration Specialist
Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member
https://www.linkedin.com/pub/christian-mueller/11/551/642
On Sun, Jan 5, 2014 at 3:46 AM, camel user cameluser2...@yahoo.in wrote:
In the below snippet, I want the property empNo to be available in the
route3. Is it possible?
My ultimate goal here is that I want to use a value derived from the URI
in Multicast first route to be available in the multicast second route. How
to achieve it? Please help.
route id=1
--some stuuf goes here--
to uri=serviceURI1/
setBodysimple${body}/simple/setBody
multicast
to uri=direct:route2/
to uri=direct:route3/
/multicast
/route
route id=2
from uri=direct:route2/
to uri=serviceURI2/
setProperty
propertyName=empNoxpath/result/empNo/text()/xpath/setProperty
/route
route id=3
from uri=direct:route3/
log message=${property.empNo}/ --Prints nothing as empNo is not
available in this route
/route
Re: Camel Security Framework - ActiveMQ Store error
Taariq is right, java.lang.NoSuchMethodError indicate this most of the
time..
Best,
Christian
-
Software Integration Specialist
Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member
https://www.linkedin.com/pub/christian-mueller/11/551/642
On Wed, Jan 8, 2014 at 9:01 AM, Taariq Levack taar...@gmail.com wrote:
You have a version mismatch, camel-core-2.12.2 is being used with
camel-jms-2.9.2
Taariq
On Wed, Jan 8, 2014 at 8:47 AM, contactreji contactr...@gmail.com wrote:
Hi
I was trying to do some encryption exercises. Once the message is
decrypted,
I am unable to store the result into a ActiveMQ Queue.
Would be really helpful if someone can suggest a fix. The encryption and
decryption are successfully working.
My Camel Routes are as follows:
*?xml version=1.0 encoding=UTF-8?
beans xmlns=http://www.springframework.org/schema/beans;
xmlns:camel=http://camel.apache.org/schema/spring;
xmlns:crypt=http://springcryptoutils.com/schema/crypt;
xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance;
xmlns:amq=http://activemq.apache.org/schema/core;
xsi:schemaLocation=
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://springcryptoutils.com/schema/crypt
http://springcryptoutils.com/schema/crypt.xsd;
bean id=activemq
class=org.apache.activemq.camel.component.ActiveMQComponent
property name=brokerURL
value=failover:tcp://localhost:61620 /
property name=userName value=admin /
property name=password value=admin /
/bean
crypt:keystore id=keyStore location=classpath:shared.jceks
password=sharedKeystorePassword type=JCEKS /
crypt:secretKey id=secretKey keystore-ref=keyStore
alias=shared password=sharedKeyPassword /
camelContext xmlns=http://camel.apache.org/schema/spring;
dataFormats
crypto id=sharedKeyCrypto algorithm=DES
keyRef=secretKey /
/dataFormats
route streamCache=true
from uri=activemq:inputToEncrypt /
log message=Encrypting message /
marshal ref=sharedKeyCrypto /
log message=Message encrypted: ${body} /
to uri=seda:decrypt /
/route
route
from uri=seda:decrypt /
log message=Decrypting message /
unmarshal ref=sharedKeyCrypto /
log message=Message decrypted: ${body} /
to uri=activemq:decryptedMessages /
/route
/camelContext
/beans*
The Exception which is thrown with stack trace is as follows
*
SLF4J: Failed to load class org.slf4j.impl.StaticLoggerBinder.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for
further
details.
[INFO] Scanning for projects...
[INFO]
[INFO]
[INFO] Building ActiveMQ embedded with Camel 1.0.0-SNAPSHOT
[INFO]
[INFO]
[INFO] camel-maven-plugin:2.10.0.redhat-60024:run (default-cli) @
camel-activemq
[INFO]
[INFO] --- maven-resources-plugin:2.4.3:resources (default-resources) @
camel-activemq ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 4 resources
[INFO]
[INFO] --- maven-compiler-plugin:2.5.1:compile (default-compile) @
camel-activemq ---
[INFO] Nothing to compile - all classes are up to date
[INFO]
[INFO] --- maven-resources-plugin:2.4.3:testResources
(default-testResources) @ camel-activemq ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 0 resource
[INFO]
[INFO] --- maven-compiler-plugin:2.5.1:testCompile (default-testCompile)
@
camel-activemq ---
[INFO] Nothing to compile - all classes are up to date
[INFO]
[INFO] camel-maven-plugin:2.10.0.redhat-60024:run (default-cli) @
camel-activemq
[INFO]
[INFO] --- camel-maven-plugin:2.10.0.redhat-60024:run (default-cli) @
camel-activemq ---
[INFO] Using org.apache.camel.spring.Main to initiate a CamelContext
[pache.camel.spring.Main.main()] MainSupportINFO
Apache
Camel 2.12.2 starting
[pache.camel.spring.Main.main()] ClassPathXmlApplicationContext
Measuring time to make call to custom endpoint
Hi I have a simple route defined in the Spring DSL. route from:endpoint to:custom-endpoint log message=Time to make call to custom endpoint is / bean ref=bean-name method-name=method-name/ .. /route Basically, I would like to output the time taken to call the custom endpoint. Hence, I was thinking of adding the current time as a header before the call to the custom endpoint and then comparing this date with a new date after the call. However, I am struggling to do the Simple Expression language. Any suggestions much appreciated Thanks Joe -- View this message in context: http://camel.465427.n5.nabble.com/Measuring-time-to-make-call-to-custom-endpoint-tp5745754.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Unable to deploy a camel route in WebSphere application server 8.5
What's your issue? Best, Christian - Software Integration Specialist Apache Member V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer Apache Incubator PMC Member https://www.linkedin.com/pub/christian-mueller/11/551/642 On Wed, Jan 8, 2014 at 3:11 PM, anupama_prad...@bcbsil.com wrote: Hi Sriramen, Were you finally able to use camel namespace in Websphere 8.5? can you please let me know how? We are trying to use WAS 8.5 for our osgi POC where we are using CXF and Camel. Thanks --- Anu Pradhan EAS Common Services Phone: (312) 653 - 4812 Mobile: (312) 823 - 9206 email: anupama.prad...@bcbsil.com Wireless PIN: 10588063 HCSC Company Disclaimer The information contained in this communication is confidential, private, proprietary, or otherwise privileged and is intended only for the use of the addressee. Unauthorized use, disclosure, distribution or copying is strictly prohibited and may be unlawful. If you have received this communication in error, please notify the sender immediately at (312)653-6000 in Illinois; (800) 437-5000 in Montana; (800)835-8699 in New Mexico; (918)560-3500 in Oklahoma; or (972)766-6900 in Texas.
Re: camel jms polling
Thanks. That works! On Thu, Jan 9, 2014 at 1:28 AM, Christian Posta christian.po...@gmail.comwrote: give your timer name something unique for each route: http://camel.apache.org/timer.html On Wed, Jan 8, 2014 at 9:11 AM, Tarun Kumar agrawal.taru...@gmail.com wrote: Here problem is both routes are running sequentially. I tried with camel:threadPoolProfile id=defaultThreadPoolProfile defaultProfile=true poolSize=10 maxPoolSize=20 maxQueueSize=1000 rejectedPolicy=CallerRuns / as well, doesn't help. On Wed, Jan 8, 2014 at 10:08 PM, Tarun Kumar agrawal.taru...@gmail.com wrote: Hi, I have two routes camel:route id=route1 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean1 method=method1/camel:bean /camel:route camel:route id=route2 camel:from uri=timer://foo?period=1/camel:from camel:bean ref=bean2 method=method2/camel:bean /camel:route in bean1 and bean2, i poll messages from different JMS queues. When i start the server, polling consumer in bean1 waits (and blocks) for messages to be available in jms queue. Is there any way i can run both routes in parallel? -- Christian Posta http://www.christianposta.com/blog twitter: @christianposta
Re: Spring AMQP Apache Camel Component Released
Thanks for following up. I'm hoping to have this and one other bug fixed committed prior to February. I appreciate you submitting the route and the steps to reproduce! -- View this message in context: http://camel.465427.n5.nabble.com/Spring-AMQP-Apache-Camel-Component-Released-tp5027785p5745758.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: File component and include option
See here: http://camel.apache.org/file2.html you should use antInclude option... I put together a quick test here: https://github.com/christian-posta/camel-sandbox/blob/master/camel-2.12.1-issues/src/test/java/posta/FileAntPathTest.java#L42 On Wed, Jan 8, 2014 at 4:17 AM, geppo geppore...@gmail.com wrote: Hi, I have a File Consumer that reads files (something.txt) from the following folders: file://base/something/2013/12/30/specific/even/more file://base/something/2013/12/31/specific/even/more file://base/something/2014/01/01/specific/even/more etc. so the middle part of the folder name is variable. I'm using the following to build the camelUrlBuilder(base).append(Args.parse(inboundArgs)).build(); where: base=file://base/something inboundArgs=[a number of URI options amongst them the following include: something.txt) This is working fine, but since I know that the something.txt file always live inside the subdirectory /specific/even/more, I would like to provide Camel with this information to narrow down the search path. How do I do that? I've tried the following include strings: /specific/even/more/something.txt \specific\even\more\something.txt specific/even/more/something.txt specific\even\more\something.txt None of them work. Any idea? Many thanks! -- View this message in context: http://camel.465427.n5.nabble.com/File-component-and-include-option-tp5745730.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Christian Posta http://www.christianposta.com/blog twitter: @christianposta
Re: Measuring time to make call to custom endpoint
I would take a look at the Debug and breakpoint API: https://camel.apache.org/camel-2x-debugger-api.html On Wed, Jan 8, 2014 at 2:50 PM, gilboy josephoto...@gmail.com wrote: Hi I have a simple route defined in the Spring DSL. route from:endpoint to:custom-endpoint log message=Time to make call to custom endpoint is / bean ref=bean-name method-name=method-name/ .. /route Basically, I would like to output the time taken to call the custom endpoint. Hence, I was thinking of adding the current time as a header before the call to the custom endpoint and then comparing this date with a new date after the call. However, I am struggling to do the Simple Expression language. Any suggestions much appreciated Thanks Joe -- View this message in context: http://camel.465427.n5.nabble.com/Measuring-time-to-make-call-to-custom-endpoint-tp5745754.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Christian Posta http://www.christianposta.com/blog twitter: @christianposta
Handling ConnectException at route startup
Hi, I'm planning to design an application which can receive files from multiple transports like JMS, FTP, FILE, REST etc. I'm having trouble to handle the ConnectException thrown at route startup if any endpoint(JMS,FTP etc.) is down. I have designed a global exception handler using onException which is able to handle the exceptions once the route is started. Consider following scenarios... 1) Suppose we have a route FILE -- JMS -- Process -- FTP.If FILE consumer is trying to send a file to JMS and JMS server is down then ConnectException is thrown and handled by global exception handler. But if there is no file to consume for FILE consumer and JMS server goes down then ConnectException is thrown by activemq(the broker I used) but this exception is not handled by exception handler. 2) Now if we have a route JMS -- FILE -- Process -- FTP. If the JMS server is down while trying to start the route we get ConnectException which is not handled by global exception handler. After exploring some discussion threads I understood to handle such ConnectException we need have exception listeners or need to do some socket programing for individual components. But I don't want to create exception listeners for individual component. Instead is there any way to globally handle such ConnectException be it thrown by JMS, FTP or REST or by any other network component? Thanks for short feedback! Regards, Bijoy -- View this message in context: http://camel.465427.n5.nabble.com/Handling-ConnectException-at-route-startup-tp5745762.html Sent from the Camel - Users mailing list archive at Nabble.com.
