Re: When CallerRuns is set, a Rejected Execution exception is still thrown
Thanks Claus. Your suggestion worked. Regards -- View this message in context: http://camel.465427.n5.nabble.com/When-CallerRuns-is-set-a-Rejected-Execution-exception-is-still-thrown-tp5776934p5776982.html Sent from the Camel - Users mailing list archive at Nabble.com.
When CallerRuns is set, a Rejected Execution exception is still thrown
I have set up thread sync in my route with the following config: with bigpool defined as: I expect the running thread to continue to run if this QTellerProvThread is full, but I have this exception thrown: at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:524)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:213)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RecipientList.sendToRecipientList(RecipientList.java:151)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RecipientList.process(RecipientList.java:112)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:81)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.TryProcessor.process(TryProcessor.java:104)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.TryProcessor.process(TryProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[147:org.apache.camel.camel-core:2.10.0.fuse-
Reactive Programming with Camel Components
I have an open source enterprise middleware application that is expected to process quite a huge number of transactions daily. My current architecture (flow) looks thus: JettyServer -> Preprocessor -> JDBCClient -> Processor -> HTTPClient I will like to make this reactive like this: Camel-Vertx(HTTPServer) -> Camel-Rx(JDBCClient)-> Camel-Rx(Busines logic Processor) -> Camel-Rx(HTTPClient) My assumptions are: Vertx HTTPServer has one or more threads that just accepts request from the client Vertx HTTPServer receives response to request on a separate thread/handler Client waits for response to request nad connection is not cut off while the HTTPServer has handed off request asynchronoulsy to Camel-Rx Vertx HTTPServer asynchronously hands over the request to Camel-RX JDBCClient Camel-RX JDBCClient doesnt wait for/block on Database response/result, it is available to process next request Camel-RX JDBCClient proceeds (Through callback or what not) to hand over request to Camel-Rx Business Logic Processor Camel-Rx Business Logic Processor proceeds to hand over request to Camel-Rx HTTPClient Camel-Rx HTTPClient doesnt wait for/block on Network response/result, it is available to process next request Camel-RX HTTPClient proceeds (Through callback or what not) to return response through the src travel path back to Vertx HTTPServer. This way, the host threads are never block on I/O. The only time to be spent is actually in the Camel-Rx Business Logic Processor where is is expected to do marshalling, some encryption/decryption, message transformation and other non I/O operations. With my design above, will my assumptions be met? Regards -- View this message in context: http://camel.465427.n5.nabble.com/Reactive-Programming-with-Camel-Components-tp5765862.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: No component found with scheme: context
Hi Ashwin, Thanks for responding. My application bundle is importing the same version of camel-core & camel-spring and yet it fails. Any other ideas. I am actually using camel-core, camel-spring, camel-context; all 2.7.1-fuse-00-43. Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/No-component-found-with-scheme-context-tp5472141p5478530.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: No component found with scheme: context
I did that, it didnt work. -- View this message in context: http://camel.465427.n5.nabble.com/No-component-found-with-scheme-context-tp5472141p5478401.html Sent from the Camel - Users mailing list archive at Nabble.com.
No component found with scheme: context
Hi all,
I noticed that camel-context component does come with the SMX list of
features.
How can I add it to the list of features?
Update:
Ifinally got this install by doing this:
install mvn:org.apache.camel/camel-context/2.8.1-fuse-01-13
However, when I started my component, it said:
"Failed to resolve endpoint: context://sampleCC:sampleProcessor due to: No
component found with scheme: context, jaxwsContext={}},"
Regards.
--
View this message in context:
http://camel.465427.n5.nabble.com/No-component-found-with-scheme-context-tp5472141p5472141.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: NoClassDefFoundError : javax.xml.namespace.QName CXF SOAP Consumer
Hi, something else came up. Have you ever tried running servicemix 4.4 on Windows 7? I am running mine on Windows 7 and here are the errors I am getting when starting it up: 10:59:35,041 | NIOSocketConnectorWrapper| 159 - org.ops4j.pax.web.pax-web-jetty - 1.0.3 | Connection on port 8181 cannot be open. Reason: Address already in use: bind 10:59:36,246 | XmlBeanDefinitionReader | 68 - org.springframework.beans - 3.0.5.RELEASE | Ignored XML validation warning java.net.ConnectException: Connection refused: connect at org.apache.xerces.util.ErrorHandlerWrapper.createSAXParseException(Unknown Source)[:] at org.apache.xerces.util.ErrorHandlerWrapper.warning(Unknown Source)[:] at org.apache.xerces.impl.XMLErrorReporter.reportError(Unknown Source)[:] at org.apache.xerces.impl.XMLErrorReporter.reportError(Unknown Source)[:] at org.apache.xerces.impl.xs.traversers.XSDHandler.reportSchemaWarning(Unknown Source)[:] at org.apache.xerces.impl.xs.traversers.XSDHandler.getSchemaDocument1(Unknown Source)[:] at org.apache.xerces.impl.xs.traversers.XSDHandler.getSchemaDocument(Unknown Source)[:] at org.apache.xerces.impl.xs.traversers.XSDHandler.parseSchema(Unknown Source)[:] at org.apache.xerces.impl.xs.XMLSchemaLoader.loadSchema(Unknown Source)[:] at org.apache.xerces.impl.xs.XMLSchemaValidator.findSchemaGrammar(Unknown Source)[:] at org.apache.xerces.impl.xs.XMLSchemaValidator.getGlobalElementDecl(Unknown Source)[:] at org.apache.xerces.impl.xs.SubstitutionGroupHandler.getMatchingElemDecl(Unknown Source)[:] at org.apache.xerces.impl.xs.models.XSDFACM.oneTransition(Unknown Source)[:] at org.apache.xerces.impl.xs.XMLSchemaValidator.handleStartElement(Unknown Source)[:] at org.apache.xerces.impl.xs.XMLSchemaValidator.startElement(Unknown Source)[:] at org.apache.xerces.impl.XMLNSDocumentScannerImpl.scanStartElement(Unknown Source)[:] at org.apache.xerces.impl.XMLDocumentFragmentScannerImpl$FragmentContentDispatcher.dispatch(Unknown Source)[:] at org.apache.xerces.impl.XMLDocumentFragmentScannerImpl.scanDocument(Unknown Source)[:] at org.apache.xerces.parsers.XML11Configuration.parse(Unknown Source)[:] at org.apache.xerces.parsers.XML11Configuration.parse(Unknown Source)[:] at org.apache.xerces.parsers.XMLParser.parse(Unknown Source)[:] at org.apache.xerces.parsers.DOMParser.parse(Unknown Source)[:] at org.apache.xerces.jaxp.DocumentBuilderImpl.parse(Unknown Source)[:] at org.springframework.beans.factory.xml.DefaultDocumentLoader.loadDocument(DefaultDocumentLoader.java:75)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:388)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:334)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:302)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:143)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:178)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:149)[68:org.springframework.beans:3.0.5.RELEASE] at org.springframework.osgi.context.support.OsgiBundleXmlApplicationContext.loadBeanDefinitions(OsgiBundleXmlApplicationContext.java:164)[82:org.springframework.osgi.core:1.2.1] at org.springframework.osgi.context.support.OsgiBundleXmlApplicationContext.loadBeanDefinitions(OsgiBundleXmlApplicationContext.java:136)[82:org.springframework.osgi.core:1.2.1] at org.springframework.context.support.AbstractRefreshableApplicationContext.refreshBeanFactory(AbstractRefreshableApplicationContext.java:130)[70:org.springframework.context:3.0.5.RELEASE] at org.springframework.context.support.AbstractApplicationContext.obtainFreshBeanFactory(AbstractApplicationContext.java:467)[70:org.springframework.context:3.0.5.RELEASE] at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.access$800(AbstractDelegatedExecutionApplicationContext.java:69)[82:org.springframework.osgi.core:1.2.1] at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$3.run(AbstractDelegatedExecutionApplicationContext.java:269)[82:org.springframework.osgi.core:1.2.1] at org.spri
Re: NoClassDefFoundError : javax.xml.namespace.QName CXF SOAP Consumer
Here: karaf@root> headers 244 Generic SOAP Services Consumer (244) Manifest-Version = 1 Bnd-LastModified = 1313052666388 Tool = Bnd-1.43.0 Build-Jdk = 1.6.0_25-ea Created-By = Apache Maven Bundle Plugin Bundle-Name = Generic SOAP Services Consumer Bundle-SymbolicName = generic-soap-consumer-bridge Bundle-Version = 1.0.0 Bundle-ManifestVersion = 2 Import-Package = com.mchange.v2.c3p0;version="[0.9,1)", javax.xml.namespace, org.apache.activemq;version="[5.2,6)", org.apache.camel.builder;version="[2.2,3)", org.apache.camel.component.jms;version="[2.2,3)", org.apache.camel.processor;version="[2.2,3)", org.apache.camel.processor.interceptor;version="[2.2,3)", org.apache.camel.processor.loadbalancer;version="[2.2,3)", org.springframework.beans.factory.config;version=2.5, org.springframework.jms.connection;version=2.5 Require-Bundle = org.apache.cxf.bundle -- View this message in context: http://camel.465427.n5.nabble.com/NoClassDefFoundError-javax-xml-namespace-QName-CXF-SOAP-Consumer-tp4685413p4688861.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: NoClassDefFoundError : javax.xml.namespace.QName CXF SOAP Consumer
Hi, The error persisted even though I have javax.xml.namespace imported. Any ideas why this is so? -- View this message in context: http://camel.465427.n5.nabble.com/NoClassDefFoundError-javax-xml-namespace-QName-CXF-SOAP-Consumer-tp4685413p4685898.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: NoClassDefFoundError : javax.xml.namespace.QName CXF SOAP Consumer
Thank you for your response. I am a little new to OSGi. Is there a way I can import all java.* packages in my pom fileor do I have to import one after the other as needed? Regards. -- View this message in context: http://camel.465427.n5.nabble.com/NoClassDefFoundError-javax-xml-namespace-QName-CXF-SOAP-Consumer-tp4685413p4685492.html Sent from the Camel - Users mailing list archive at Nabble.com.
NoClassDefFoundError : javax.xml.namespace.QName CXF SOAP Consumer
Hi all, I am trying to migrate a csf service from SMX 4.3 to 4.4 and when I deployed in the new SMX 4.4.0-fuse-00-43, it throws the following exception: 11:50:48,442 | ContextLoaderListener| 85 - org.springframework.osgi.extender - 1.2.1 | Application context refresh failed (OsgiBundleXmlApplicationContext(bundle=generic-soap-consumer-bridge, config=osgibundle:/META-INF/spring/*.xml)) java.lang.NoClassDefFoundError: javax.xml.namespace.QName not found from bundle [generic-soap-consumer-bridge] at $Proxy94.(Unknown Source) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)[:1.6.0_25-ea] at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)[:1.6.0_25-ea] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)[:1.6.0_25-ea] at java.lang.reflect.Constructor.newInstance(Constructor.java:513)[:1.6.0_25-ea] at java.lang.reflect.Proxy.newProxyInstance(Proxy.java:588)[:1.6.0_25-ea] at org.apache.cxf.tools.util.SOAPBindingUtil.getProxy(SOAPBindingUtil.java:89) at org.apache.cxf.tools.util.SOAPBindingUtil.getSoapBinding(SOAPBindingUtil.java:286) at org.apache.cxf.tools.util.SOAPBindingUtil.getSoapBinding(SOAPBindingUtil.java:278) at org.apache.cxf.binding.soap.SoapBindingFactory.createBindingInfo(SoapBindingFactory.java:627) at org.apache.cxf.wsdl11.WSDLServiceBuilder.buildBinding(WSDLServiceBuilder.java:487) at org.apache.cxf.wsdl11.WSDLServiceBuilder.buildServices(WSDLServiceBuilder.java:349) at org.apache.cxf.wsdl11.WSDLServiceBuilder.buildServices(WSDLServiceBuilder.java:198) at org.apache.cxf.wsdl11.WSDLServiceFactory.create(WSDLServiceFactory.java:142) at org.apache.cxf.service.factory.ReflectionServiceFactoryBean.buildServiceFromWSDL(ReflectionServiceFactoryBean.java:382) at org.apache.cxf.service.factory.ReflectionServiceFactoryBean.initializeServiceModel(ReflectionServiceFactoryBean.java:499) at org.apache.cxf.service.factory.ReflectionServiceFactoryBean.create(ReflectionServiceFactoryBean.java:241) at org.apache.cxf.frontend.AbstractWSDLBasedEndpointFactory.createEndpoint(AbstractWSDLBasedEndpointFactory.java:101) at org.apache.cxf.frontend.ServerFactoryBean.create(ServerFactoryBean.java:157) at org.apache.camel.component.cxf.CxfConsumer.(CxfConsumer.java:249) at org.apache.camel.component.cxf.CxfEndpoint.createConsumer(CxfEndpoint.java:130) at org.apache.camel.impl.EventDrivenConsumerRoute.addServices(EventDrivenConsumerRoute.java:61) at org.apache.camel.impl.DefaultRoute.onStartingServices(DefaultRoute.java:75) at org.apache.camel.impl.RouteService.warmUp(RouteService.java:128) at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:1839) at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:1765) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1555) at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1447) at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1338) at org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:164) at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:67) at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:54) at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1316) at org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:203) at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:101) at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:238) at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:97)[70:org.springframework.context:3.0.5.RELEASE] at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:303)[70:org.springframework.context:3.0.5.RELEASE] at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:911)[70:org.springframework.context:3.0.5.RELEASE] at org.springframework.osgi.context.support.AbstractOsgiBundleApplicationContext.finishRefresh(AbstractOsgiBundleApplicationContext.java:235)[82:org.springframework.osgi.core:1.2.1] at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:358)[82:org.springframework.osgi.core:1.2.1] at org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(Privil
Content based processing in camel - Best approach
Hi, I 'd like to process a message (basically modify an exchange body) based on an identifier (which is also part of the message). The processing on the exchange body can be quite handful and may involve manipulating bytes (which seem to influence my decision to use groovy). Is there a way I can dynamically load groovy script (at runtime) from a camel route? If no, how else can I achieve this? Note, i'd prefer not to modify the camel route for new manipulation of the exchange body. -- View this message in context: http://camel.465427.n5.nabble.com/Content-based-processing-in-camel-Best-approach-tp4611695p4611695.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Unit Testing with Spring.
Hi, Thanks for your response. However, in my camel-context, I referenced a class which is part of the same project. but it kept throwing excpetion: org.springframework.beans.factory.CannotLoadBeanClassException: Cannot find class [mycompany.generic_soap_provider_bridge.ServiceClient] for bean with name 'serviceClient' defined in class path resource [META-INF/spring/HTTPMethodTester-context.xml]; nested exception is java.lang.ClassNotFoundException: mycompany.generic_soap_provider_bridge.ServiceClient How do I ensure d classes in my project can be loaded when I run the test? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Unit-Testing-with-Spring-tp4271068p4305692.html Sent from the Camel - Users mailing list archive at Nabble.com.
Camel Unit Testing with Spring.
Hi,
After following the steps describes in Camel in Action to set up a unit
test, I keep getting the following error when I try to
test run my unit case:
Invalid NamespaceHandler class [org.apache.camel.osgi.CamelNamespaceHandler]
for namespace [http://camel.apache.org/schema/osgi]: problem with handler
class file or dependent class; nested exception is
java.lang.NoClassDefFoundError:
org/springframework/osgi/context/BundleContextAware
See my camel context:
${header.soapAction}
${header.contenttype}
${header.serviceurl}
${header.httpmethod}
${header.sslenabled}
And I have these in my dependencies:
commons-logging
commons-logging
${commons.logging.version}
provided
org.apache.camel
camel-core
${camel-version}
org.apache.camel
camel-cxf
${camel-version}
org.apache.camel
camel-test
${camel-version}
test
org.slf4j
slf4j-api
1.5.6
test
org.slf4j
slf4j-log4j12
1.5.6
test
org.springframework
spring-test
2.5.6.SEC01
test
junit
junit
4.4
test
What am I missing?
Regards.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Unit-Testing-with-Spring-tp4271068p4271068.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Camel CXF workaround with self signed certificates
I have this classic ssl problem on camel cxf when trying to connect to a server, who has a self generated certificate. I have imported the cert into my keystore but is says "Caused by: javax.net.ssl.SSLHandshakeException: java.security.cert.CertificateException: No subject alternative names present" Note that I have set and this persists How do I resolve this? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-workaround-with-self-signed-certificates-tp4262133p4262133.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to stop implicit call to Type Converters
Interesting, but the trace shows the method is called? What else could force that call? -- View this message in context: http://camel.465427.n5.nabble.com/How-to-stop-implicit-call-to-Type-Converters-tp3391321p3391393.html Sent from the Camel - Users mailing list archive at Nabble.com.
How to stop implicit call to Type Converters
How do I stop implicit call to a custom type converter made by camel. see my script below: I turned on traces on the custom converter and I realize after the first (explicit) call to the customConverter - which converts from String to a bean - class, camel implicitly calls the converter (to change from the new bean to a string body type) just before calling endpoiint2. This needlessly causes unnecessary overhead. Is there a way to prevent this call? kr. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-stop-implicit-call-to-Type-Converters-tp3391321p3391321.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Tracer impedes performance.
I am curious, is it the TraceEventHandler that impedes the performance or the TraceInceptor or the InterceptStrategy? If the differences in the usage of these classes are clear to you, can you please explain to me how they differ? I assume, when there is a new exchange on a node, the TraceInterceptor intercepts the message using a strategy defined by the InterceptStrategy (This I assume should actually create a new thread and get a copy of the exchange. At this point I assume the main Exchange, should not try to transform exchange message to suite the interceptor). I also assume it is after the Trace Interceptor accepts the message, then the TraceEventHandler 'd attempt to "handle" or process the trace event. At this time, the main exchange should not be impeded (meaning, messages should be forwarded to subsequent nodes/endpoints without it being blocked by the the trace processing). Again, these are my assumptions. Kindly help clarify what are, and what are not. Basically, all I want to do is, allow original message to continue being processed then use a separate thread handle traces. This way, my original transaction will not be blocked by the tracer and it can still be completed as if the tracer were not turned on. How long its takes traces to be log is not a big deal as it is a trace, so it can take for as long it wants to - reasonably though. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Tracer-impedes-performance-tp3389173p3389307.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Tracer impedes performance.
Thanks a lot for your response. Whats is the name of the default trace event handler used by camel tracer? I 'd like to take a look at that class and see how I can optimize it. I will actually prefer if messages intercepted and logged in a separate thread form the main exchange thread. This way, the main exchange can keep running without having to be blocked/impeded by the trace handler. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Tracer-impedes-performance-tp3389173p3389254.html Sent from the Camel - Users mailing list archive at Nabble.com.
Camel Tracer impedes performance.
Hi, I noticed that extending the camel tracer to log exchange data into the database impedes performance on the ESB. I followed the example in the camel samples, where I defined a direct endpoint http://camel.apache.org/schema/spring"; trace="true"> ... What I did was to create a custom bean that logs this tracemessage to database. I assume the process of calling this route is off the main route (meaning I assume its like an interceptor and should not in any way slow down the time it takes to travel from one node to another). But it seems it does in reality. As whenever I turn of the custom trace, it takes considerable less time to complete a transaction and when its on, it takes more time. A background to this problem that might be helpful is the fact that, exchange message body type is a bean (and not string or xml). I noticed each time its going from one node to another, it implicitly tries to convert from bean to String, before handling the message to the direct endpoint. (May be its just my imagination) It is also noteworthy that the main route uses vm and the preferred endpoint uri while the log interfaces uses the direct uri. Is there another way, I can efficiently do this? kr. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Tracer-impedes-performance-tp3389173p3389173.html Sent from the Camel - Users mailing list archive at Nabble.com.
Timeout on replyTo destination queue
Hi All, I have two brokers. I also have 2 JMS Clients (a producer and a consumer) jms config: tcp://brokerB-ip:61616 jms:queue:request?replyTo=queue:response Producer sends a synchronous request (and it is expecting a response) to a queue on broker B, and it expects a response on queue response (Ideally, this response queue I 'd expect to would be created on broker B), however, I realize the response comes but broker A is expecting to pick the response from brokerB response queue but it goes to a queue on broker A. So this request times out. How do I solve this problem? -- View this message in context: http://camel.465427.n5.nabble.com/Timeout-on-replyTo-destination-queue-tp3303321p3303321.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Re: Cannot find the declaration of element 'routeContext'.
See sample route snippet I wrote that worked for me: http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:osgi="http://camel.apache.org/schema/osgi"; xmlns:beans="http://www.springframework.org/schema/beans"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://camel.apache.org/schema/osgi http://camel.apache.org/schema/osgi/camel-osgi.xsd http://www.springframework.org/schema/osgi-compendium http://www.springframework.org/schema/osgi-compendium/spring-osgi-compendium.xsd http://www.springframework.org/schema/osgi http://www.springframework.org/schema/osgi/spring-osgi.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd";> http://camel.apache.org/schema/spring";> java.lang.Exception true -- View this message in context: http://camel.465427.n5.nabble.com/Cannot-find-the-declaration-of-element-routeContext-tp2851604p3261545.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to get exchange Id from spring camel context
Thanks for the response. I realised I could get it that way later but I am working with ServiceMix 4.1 which comes with camel 2.2 by default and that expression will not be evaluated except it is 2.3 and above. I need the exchange Id so that I can persist an original (the first exchange id for a consumer endpoint) exchange id across different endpoints (processor endpoints, and provider endpoints) in different camel context. I already extended the camel trace to persist traces into a database but there is no correlation id for same message across different endpoints, hence it is difficult to trace a message from a consumer endpoint downstream the provider endpoint. Rgds. -- View this message in context: http://camel.465427.n5.nabble.com/Re-How-to-get-exchange-Id-from-spring-camel-context-tp3225295p3227667.html Sent from the Camel - Users mailing list archive at Nabble.com.
How to get exchange Id from spring camel context
Hi, How can I get the exchange Id from a spring camel context? Can I do this from Simple expression, if yes, what header value do I get it from? Regards. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-get-exchange-Id-from-spring-camel-context-tp3219377p3219377.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Cannot find the declaration of element 'routeContext'.
Thanks, That worked. -- View this message in context: http://camel.465427.n5.nabble.com/Cannot-find-the-declaration-of-element-routeContext-tp2851604p2851660.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Cannot find the declaration of element 'routeContext'.
Thanks for the quick response.
I added the following namespace and I put routeContext in a beans root
element
http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:osgi="http://camel.apache.org/schema/osgi";
xmlns:beans="http://www.springframework.org/schema/beans";
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
http://camel.apache.org/schema/osgi
http://camel.apache.org/schema/osgi/camel-osgi.xsd
http://www.springframework.org/schema/osgi-compendium
http://www.springframework.org/schema/osgi-compendium/spring-osgi-compendium.xsd
http://www.springframework.org/schema/osgi
http://www.springframework.org/schema/osgi/spring-osgi.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd";>
http://camel.apache.org/schema/spring";>
And I still have the following errors:
Offending resource: URL
[bundle://224.0:0/META-INF/spring/camel-context.xml]; nested exception is
org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line
17 in XML document from OSGi
resource[file:///D:/progress/apache-servicemix-4.3.0-fuse-00-00/data/routes/routes.xml|bnd.id=224|bnd.sym=processor-bundle]
is invalid; nested exception is org.xml.sax.SAXParseException:
cvc-complex-type.2.4.b: The content of element 'routeContext' is not
complete. One of '{"http://camel.apache.org/schema/spring":route}' is
expected.
--
View this message in context:
http://camel.465427.n5.nabble.com/Cannot-find-the-declaration-of-element-routeContext-tp2851604p2851631.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Cannot find the declaration of element 'routeContext'.
Hi, I keep getting this error when I try to start camel application. Offending resource: URL [bundle://224.0:0/META-INF/spring/camel-context.xml]; nested exception is org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 2 in XML document from OSGi resource[file:///D:/progress/apache-servicemix-4.3.0-fuse-00-00/data/routes/routes.xml|bnd.id=224|bnd.sym=as-bundle] is invalid; nested exception is org.xml.sax.SAXParseException: cvc-elt.1: Cannot find the declaration of element 'routeContext'. See my config below: routes.xml http://camel.apache.org/schema/spring";> camelContext.xml http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:osgi="http://camel.apache.org/schema/osgi"; xmlns:beans="http://www.springframework.org/schema/beans"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://camel.apache.org/schema/osgi http://camel.apache.org/schema/osgi/camel-osgi.xsd http://www.springframework.org/schema/osgi-compendium http://www.springframework.org/schema/osgi-compendium/spring-osgi-compendium.xsd http://www.springframework.org/schema/osgi http://www.springframework.org/schema/osgi/spring-osgi.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd";> http://camel.apache.org/schema/spring"; trace="true"> What could be wrong? -- View this message in context: http://camel.465427.n5.nabble.com/Cannot-find-the-declaration-of-element-routeContext-tp2851604p2851604.html Sent from the Camel - Users mailing list archive at Nabble.com.
Importing routes from another file or camel context
Is it possible to import a file, which have routes definition or bean definitions, into a camel application to be re-used. I am not sure there is something of this nature in camel, if there I will appreciate any pointer to how it can be easily achieved. This is something I just thought of and the use case will make a lot of sense when routes are re-used or when one is going to have multiple routes that will be too big for one file. Many thanks -- View this message in context: http://camel.465427.n5.nabble.com/Importing-routes-from-another-file-or-camel-context-tp2840254p2840254.html Sent from the Camel - Users mailing list archive at Nabble.com.
How to implement (dynamic) rule engine with camel.
Hi all, I was just wondering what would be the best way to use camel to create routes for an application that is highly dynamic. When I say dynamic I mean, routing of message can change depending on use case. I'd like to make this change without shutting down the camel (routing) application (which is a sort of a rule engine). This means, when I have a new use case, I 'd like to possible edit a scripting file and expect when next a message arrives, the new rules are loaded and evaluated which restarting the bundle. This means, if I have endpoint A, B, C, D, E, F The first use case can be: A -> D -> E -> F The second use case: A -> B -> C -> F Adding the second use case should require a restart of the camel application. Is there anything that can do this today in camel. I think this is some like a rule engine. I hope my scenario is clear enough. Please, let me know if there is anything unclear. Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-implement-dynamic-rule-engine-with-camel-tp2837427p2837427.html Sent from the Camel - Users mailing list archive at Nabble.com.
Network of Brokers, Consumers not getting messages from queue
Hi,
I have followed the article on activemq website on how to set up network of
brokers.
My brokers are able to talk to themselves using the
DiscoveryNetworkConnector.
Below is the output of my activemq log:
Network connection between vm://default#16 and
tcp:///broker2ip:61616(default) has been established.
However, I cant receive messages send from borker1 (tcp://localhost:61616)
to broker2ip (which the consumer is conencted).
Why is that?
Here is my producer client config
${local-broker-url}
and this is how I create my endpoint in camelcontext
and here is my consumer client config
${local-broker-url}
and this is how I create my endpoint in camelcontext
Regards.
--
View this message in context:
http://camel.465427.n5.nabble.com/Network-of-Brokers-Consumers-not-getting-messages-from-queue-tp2807781p2807781.html
Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Network of Brokers, Consumers not getting messages from queue
Hi,
I have followed the article on activemq website on how to set up network of
brokers.
My brokers are able to talk to themselves using the
DiscoveryNetworkConnector.
Below is the output of my activemq log:
Network connection between vm://default#16 and
tcp:///broker2ip:61616(default) has been established.
However, I cant receive messages send from borker1 (tcp://localhost:61616)
to broker2ip (which the consumer is conencted).
Why is that?
Here is my producer client config
${local-broker-url}
and this is how I create my endpoint in camelcontext
and here is my consumer client config
${local-broker-url}
and this is how I create my endpoint in camelcontext
Regards.
--
View this message in context:
http://camel.465427.n5.nabble.com/Network-of-Brokers-Consumers-not-getting-messages-from-queue-tp2806330p2806330.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to use unique queue for different camel-vm endpoint
Thanks. My oversight, my bad. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-use-unique-queue-for-different-camel-vm-endpoint-tp2799194p2799495.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to use unique queue for different camel-vm endpoint
Its the simple pipeline pattern. I have differnt osgi bundles (camel application), which are exposed as endpoints to Servicemix as vm endpoints. Each of them do a specific function. I am just calling each function in a sequential order. e.g. endpoint A - is a REST protocol consumer endpoint B - is a functional component that verifies order (it listens on the ESB using the vm component) endpoint c - is a functional component that processes order (it listens on the ESB using the vm component) endpoint D- is a service provider (it listens on the ESB using the vm component) so, when A receive a request over REST, it sends 2 endpoint B through vm, and B forwards to C and C to D through vm as well. The problem is, when D returns a response, both B, C gets the response from D and returns, instead of C only to get a response from D and B to get response from C. Regards. But the problem is, when C fin -- View this message in context: http://camel.465427.n5.nabble.com/How-to-use-unique-queue-for-different-camel-vm-endpoint-tp2799194p2799251.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to use unique queue for different camel-vm endpoint
What version of Camel are you using? camel 2.2.0 Have you actually looked at the SEDA/VM documentation which has a warn about using multiple VM/SEDA queues? http://camel.apache.org/seda http://camel.apache.org/vm I read those pages before making this post and I didnt see any such thing about multiple VM/SEDA queue. MultipleConsumers is not enabled by default (according to the doc), and so I did not expect messages to be sent to multiple consumers. Kindly point me in the right direction if I have used this component the wrong way. Regards. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-use-unique-queue-for-different-camel-vm-endpoint-tp2799194p2799245.html Sent from the Camel - Users mailing list archive at Nabble.com.
How to use unique queue for different camel-vm endpoint
Hi Guys, I am working on a project that requires using multple camel-vm endpoints. See an example of my flow: camelContext-vm-endpoint 1 = A camelContext-vm-endpoint 2 = B camelContext-vm-endpoint 3 = C When I send a message from A -> B -> C when C returns with a response, the response is sent to A and B simultaneously as well i.e. instead of only C to get the response, and then send its response to B and B sends to A in that order, all A,B,&C gets the response at once. How can I avoid this? Regards. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-use-unique-queue-for-different-camel-vm-endpoint-tp2799194p2799194.html Sent from the Camel - Users mailing list archive at Nabble.com.
