Hello All,
I am using camel RestDSL to get Json and conver it to pojo by
.post().type(Schema.class)
but i got below exception
org.apache.camel.InvalidPayloadException: No body available of type:
java.io.InputStream but has value: < *srroy i need to hide package name
here* >Schema
below is the s
For some component, I could set key and value at the exchange's in or out's
header instead of
using the component's option at the endpoint .
For me, it is not very clearly documented, which options could be set at
in/out /header
set option at endpoint URI
from(xxx) .inOut().to("activemq:queue:fo
JDK are you using?
>From the stack trace, it looks like you cannot cast the
com.ibm.mq.jms.MQSession to com.ibm.mq.jms.MQQueueSession.
I think you need to check the client code for more information.
Willem Jiang
Twitter: willemjiang
Weibo: 姜宁willem
On Fri, Oct 18, 2019 at 11:51 PM Wang Yan <
Hello All,
I am using micrometer to measure time for route A and route B
it works , I also want to measure total time for routeA and routeB since
data flow is from routeA -> routeB. but it does not work. Below is the
snippet of my code
any hints or suggestions are more than welcome!
from("amq:
ack trace, it looks like you cannot cast the
com.ibm.mq.jms.MQSession to com.ibm.mq.jms.MQQueueSession.
I think you need to check the client code for more information.
Willem Jiang
Twitter: willemjiang
Weibo: 姜宁willem
On Fri, Oct 18, 2019 at 11:51 PM Wang Yan <[hidden email]
<htt
I have problem , camel is always sending MQRFH2 headers to target
WebsphereMQ queue
I used below code try to solve the problem but i got
Setup of JMS message listener invoker failed for destination
- trying to recover. Cause: class com.ibm.mq.jms.MQSession cannot be cast
to class com.ibm.mq.jms.M
has sent the exchange to, hence
> I
> think you would see this information after a `to` route. However I am not
> 100% sure though.
>
> On Wed, 28 Aug 2019 at 07:38, Wang Yan <[hidden email]
> <http:///user/SendEmail.jtp?type=node&node=5841999&i=0>&g
Hello all,
OnException block , the TechnicalException will be caught, this
exception could come
from Route A or Route B , my question is , Is it possible for on Exception block
to figure out where the TechnicalException is originated from ? for
example from which Route or from which Endpoint?
[via Camel] <
ml+s465427n5841561...@n5.nabble.com> wrote:
> Yes you need camel-sjms2-starter since you use that component.
>
>
> On Sat, Aug 3, 2019 at 9:38 AM Wang Yan <[hidden email]
> <http:///user/SendEmail.jtp?type=node&node=5841561&i=0>> wrote:
>
>
@Claus,
For example when i use activemq + camel+springboot
there are two starters camel-activemq-starter and
spring-boot-starter-activemq
do i need both of them? or just spring-boot-starter-activemq ?
Thanks and Rgds
On Mon, Aug 19, 2019 at 9:27 PM W.Y [via Camel] <
ml+s465427n5841412...@n5.na
I am currently using camel + Springboot for my project
I also want to use camel sjms2 component
my question is
I already used camel-spring-boot-starter in project's dependency for
springboot auto configuration.
Do I also need to add camel-sjms2-starter in dependency as well?
My gut feeling is
ml+s465427n5840375...@n5.nabble.com> wrote:
> You need to use the -starter JARs also for other components.
>
> On Sat, Aug 3, 2019 at 9:38 AM Wang Yan <[hidden email]
> <http:///user/SendEmail.jtp?type=node&node=5840375&i=0>> wrote:
>
> >
> > I am currently u
I am currently using camel + Springboot for my project
I also want to use camel sjms2 component
my question is
I already used camel-spring-boot-starter in project's dependency for
springboot auto configuration.
Do I also need to add camel-sjms2-starter in dependency as well?
My gut feeling is
@ Claus
Thanks for your quick reply. i used exchange.getMessage(), it does not work
it prints out below information , what i expected result should be "Error
happened , please contact Admin"
###
This page contains the following errors:
error on line 1 at column 1: Docum
According to document (
https://camel.apache.org/using-getin-or-getout-methods-on-exchange.html),
when we modify body of exchange, we should use exchange.getIn().setBody()
instead of exchange.getOut().setBody()
It ususally works. but for OnException block, it does not work , I have to
use exchange
Dear All,
In my current project, we need camel jetty http2 support at the server
I find the below post which related to my question, could anyone give
me some hints where or what code should be modified to enable camel
jetty component to support http2 feature?
https://stackoverflow.com/questions/
I used below example to select message.
although it can send matched message to toqueue
but not matched messages are also dequeued
What I want to achieve is only matched messages will be
selected and sent to toqueue .
Any suggestion or hints how to do this with camel filter?
from("activemq:queue:
Hello All,
As you can see, I am able to getException here in processor , but not able
to get exception message via ${exception.message}
any hints or suggestions are more than welcome !
.doCatch(java.lang.Exception.class)
.process(exchange->{
Throwable ex=exchange.getPropert
I have a problem , my cxf-ssl.xml setting for httpj-engine is working when
it runs as l springboot camel application.
but it failed at JUnitTest with below error , It seem SpringContext could
corretly import resource for ssl cxf setting during
JUnitTest. (CamelSpringBootRunner)
Caused by:
org.sp
)
>
>
.to("https4://:/MutualAuthentication/MutuallySecuredServlet?sslContextParameters=sslContextParameters");
On Mon, Apr 1, 2019 at 7:03 PM Wang Yan <[hidden email]
<http:///user/SendEmail.jtp?type=node&node=5832635&i=0>> wrote:
> httpclient calling your route ove
putRecord.read(InputRecord.java:503)
~[?:1.8.0_101]
>>> at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:973)
>>> ~[?:1.8.0_101]
>>> at
>>>
sun.security.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1375)
>>> ~[?:1.8.0_101]
>>> at
>>
ndpoint option is true should do the trick.
Not sure if it relates to basic authentication on the remote host.
Willem Jiang
Twitter: willemjiang
Weibo: 姜宁willem
On Sat, Mar 30, 2019 at 2:05 PM Wang Yan <[hidden email]
<http:///user/SendEmail.jtp?type=node&node=5832524&i=0>> wr
You could do something like this to set SSL for Http4
private void configureSslForHttp4(){
KeyStoreParameters ksp = new KeyStoreParameters();
ksp.setResource(keystoreLocation);
ksp.setPassword(keystorePassword);
TrustManagersParameters tmp = new TrustManagersParameters();
tmp.setKeyStore(ksp);
SSL
You could do something like this to set SSL for Http4
private void configureSslForHttp4(){
KeyStoreParameters ksp = new KeyStoreParameters();
ksp.setResource(keystoreLocation);
ksp.setPassword(keystorePassword);
TrustManagersParameters tmp = new TrustManagersParameters();
tmp.setKeyStore(ksp);
SSL
I found the solution. it works for me, if you have better way, feel free to
share
private String proxy(String url) throws IOException {
CredentialsProvider provider = new BasicCredentialsProvider();
UsernamePasswordCredentials credentials = new
UsernamePasswordCredentials("USERNAME", "PASSWOR
I used below code as proxy to download wsdl file from remote webservice,
but it does not work. only get html back instead of wsdl file
http://realserverhostname:8090/webservice?wsdl&bridgeEndpoint=true&throwExceptionOnFailure=false"/>
Ps:
Of couse using browser I am able to o
; not loaded because
@ConditionalOnClass did not find required classes
'com.arjuna.ats.jta.UserTransaction',
'org.jboss.tm.XAResourceRecoveryRegistry'
-- Forwarded message -
From: Wang Yan
Date: Thu, Mar 7, 2019 at 9:46 PM
Subject: I could not use .transacted() in camel route with SpringBoot
I could not use .transacted() in camel route with SpringBoot, got exception
No bean could be found in the registry of type: PlatformTransactionManager"
Is it expected behavior for SpringBoot+Camel setup?
below is example of the code
https://github.com/apache/camel/blob/master/components/camel-sp
Hello All,
based on below document
if handle =false the message will be propagated to caller when exception
happened
if handle=true, the message will not be propagated to caller but somewhere
else as you can
define . is my understanding correct?
http://camel.apache.org/dead-letter-channel.html
Th
tyHTTPDestination.retrieveEngine(JettyHTTPDestination.java:134)
~[cxf-rt-transports-http-jetty-3.2.7.jar!/:3.2.7
at
org.apache.cxf.transport.http_jetty.JettyHTTPDestination.finalizeConfig(JettyHTTPDestination.java:166)
~[cxf-rt-transports-http-jetty-3.2.7.jar!/:3.2.7
-- Forwarded mess
ngine(JettyHTTPDestination.java:134)
~[cxf-rt-transports-http-jetty-3.2.7.jar!/:3.2.7
at
org.apache.cxf.transport.http_jetty.JettyHTTPDestination.finalizeConfig(JettyHTTPDestination.java:166)
~[cxf-rt-transports-http-jetty-3.2.7.jar!/:3.2.7
-- Forwarded message -
From: Wang Yan
My CXF Endpoint Provider need to using https.
I found setting like below should work, but i did not found how to do it in
JAVADSL
because my route is JAVADSL
Any hints are more than welcome!
I want to intercept cxf endpoint in my own method instead of using default
interceptor of cxf, but it seems not working
It is not invoked at all.
Did I do something wrong? any idea or suugestions?
interceptFrom("cxf://*")
.process(new Processor() {
public void process(Exchange exchange) {
count++
load multiple route xml files - ASF JIRA
When I use SpringDSL , i want to load two route files
For Example route1.xml and route2.xml
If I put two files in same directory like below , it is working
camel.springboot.xmlRoutes: file :directory/*.xml
If I put two files into different directorie
problems, you can resume the build with
the command
-- Forwarded message -----
From: Wang Yan
Date: Wed, Dec 19, 2018 at 3:12 PM
Subject: where and when to get release 2.22.3?
To:
We reported a bug which is fixed on 2.22.3
My Question is
When the fix version 2.22.3 will be availa
We reported a bug which is fixed on 2.22.3
My Question is
When the fix version 2.22.3 will be available ?
or Where could I download the bug fix release 2.22.3 now?
Thanks!
What is different to createProducerTemplate via AutoConfigure and
EndPointInject
in SpringBoot ? are the both way correct?
via EndpointInject I could create multiple instance of
ProducerTemplate, but via Autoconfig I could only create one
ProducerTemplate instace
it seems only support keyword classpath but not file
camel.springboot.xmlRoutes: classpath:camel/*.xml
-- Forwarded message -
From: Wang Yan
Date: Wed, Dec 5, 2018 at 11:11 AM
Subject: Fwd: using springdsl instead of javadsl with file path
To:
it does not work got
it does not work got exception as below
#camel xmlroute scan
camel.springboot.xmlRoutes: on
camel.springboot.xmlRoutes: file:camel/*.xml
Caused by: java.lang.IllegalStateException: duplicate key:
camel.springboot.xmlRoutes
-- Forwarded message -
From: Wang Yan
Date: Tue, Nov
it does not work got exception as below
#camel xmlroute scan
camel.springboot.xmlRoutes: on
camel.springboot.xmlRoutes: file:camel/*.xml
Caused by: java.lang.IllegalStateException: duplicate key:
camel.springboot.xmlRoutes
-- Forwarded message -
From: Wang Yan
Date: Tue, Nov
If I use the auto configured ProducerTemplate, how could I get multiple
different ProducerTemplate instances?
for example I need use producer template send different exchanges to
different endpoints
in this case, Do i need different producer template instances? if yes how ?
Auto-Configured Consume
If I use the auto configured ProducerTemplate, how could I get multiple
different ProducerTemplate instances?
for example I need use producer template send different exchanges to
different endpoints
in this case, Do i need different producer template instances? if yes how ?
Any suggestions ?
Auto-
Currently I am reading the document http://camel.apache.org/ldap.html
and try to configure SSL for LDAP , I did not find how or where the bean
ldapserver refers to the bean customSocketFactory.
Any suggestions or hints are more than weclome!
http://www.osgi.org/xmlns/blueprint/v1.0.0";
i already got reply from to uri which is mock soap service (external soap
provider)
but why i could not see it in log with ${out.body}
i think soap is InOut exchangepattern, it should have out.body always
my code example looks like below
Any hints are more than welcome!
http://{{soap.ip}}:{{soap.
when i use SpringDSL under SpringBoot, i should only use routes in xml
not camelContext, since springboot will take care of cameContext
when i convert my javaDSL to below SpringDSL
the to uri cxf endpoint below does not work , it used to work with javadsl
http://localhost:/mock_service?dat
using springdsl instead of javadsl, below is the example from camel website,
is it possible to use file instead of classpath for configuration? for example
camel.springboot.xmlRoutes = file:/com/foo/routes/*.xml
any suggestions and hints are more than welcome!
// turn off
camel.springboot.xmlRo
i simple put .throwException(new Exception("error happened")), then looks
like camel route convert exception to soapfault automatically.
i even did not handlefault on route.
On Thu, Nov 15, 2018 at 9:28 PM Wang Yan wrote:
> Hello all,
>
> how to throw soap fault from othe
Hello all,
how to throw soap fault from otherwise clause? if no expected operationname
found.
any suggestions?
from(SOAP_ENDPOINT_OUT_URI )
.choice()
.when(simple("${in.headers.operationName} == 'getcity'"))
.to(SOAP_ENDPOINT_MOCK_CITY)
.when(simple("${in.headers.operationName} == 'getcountry'"))
Hey All,
I need to use consumertemplate to search message
i did something like below. but i have two concerns
1) it could not search particular message based on messageid
2) i just want to search or browse message, i dont want to digest it
any suggestions or hints are more than welcome!
@Over
MESSAGE dataformat, camel-cxf component doesn't read the
> message, so it makes sense that you cannot operationName header.
>
> Willem Jiang
>
> Twitter: willemjiang
> Weibo: 姜宁willem
>
> On Fri, Oct 26, 2018 at 4:07 PM Wang Yan <[hidden email]
> &l
when i use
from(SOAP_ENDPOINT_IN_URI +
"&dataFormat=CXF_MESSAGE").removeHeaders("CamelHttp*")
I can get operationName by ${in.headers.operationName}
but I could not get operationName when useing
dataFormat=MESSAGE
from(SOAP_ENDPOINT_IN_URI + "&dataFormat=MESSAGE").
any idea or suggestion ?
I have two routes in camel, route1 will send soap request to route2
What I am expecting route1 will get reponse from route2
But Altough route2 can send response (i see it in log ), but route1 could
not get it.
Any idea ? how to let route1 get response from route2?
route1
// SOAP_InBound -> XQuer
I want to use simple to read and print out file content. but it reads file
and only print out file name instead of content.
why ? Did I did something wrong? Any suggestion and ideas are more than
welcome!
from(SOAP_ENDPOINT + "&dataFormat=CXF_MESSAGE")
.log(LoggingLevel.INFO, "# SOAP REQUEST
In Apache camel I need to extract a xml element and pass it to xquery as
element(), but i have strange error. Any idea and suggesions are more than
welcome!
Camel code:
from(SOAP_ENDPOINT_IN_URI + "&dataFormat=CXF_MESSAGE")
.setHeader("CMDRequest", XPathBuilder.xpath("//*[local-name() =
'CMDRequ
I need to get element called CMDRequest from soapenv:Envelope,then save it
at header variable for next step
but i got exception
org.apache.cxf.interceptor.Fault:
org.apache.camel.NoTypeConversionAvailableException: No type converter
available to convert from type:
com.sun.xml.internal.messaging.s
camel soap endpoint only using wsdl , not using serviceClass , is it
possbile?
private static final String SOAP_ENDPOINT_URI = "cxf://
http://0.0.0.0:9009/create?serviceClass=com.xyz.CreateService";;
I tried like below, but it does not work, it looks like the endpoint really
expecting serviceClas
is transaction (required) by default enabled for the route sending message
from one jms endpoint to another endpoint like below
from("activemq:queue:foo").to("activemq:queue:bar");
or i have to explicitly do like below ?
Policy requried = bean(SpringTransactionPolicy.class,
"PROPAGATION_REQUIRE
mp;i=0>> wrote:
>
> Hello,
> the versions are listed in the issue[1], until we release if you need
> this fix the only way you can get it is if you use the snapshot
> versions.
>
> Mixing two different versions of Camel will probably lead to more issues.
>
> zora
1:40 PM
Subject: Re: o.a.c.i.DefaultCamelBeanPostProcessor : No CamelContext
defined yet so cannot inject into bean:
To: nono
Hi,
this was recently fixed with CAMEL-12087[1]
zoran
[1] https://issues.apache.org/jira/browse/CAMEL-12087
On Wed, Oct 10, 2018 at 9:50 AM, Wang Yan <[hidden em
CamelContext
defined yet so cannot inject into bean:
To: nono
Hi,
none of those versions are released, you can grab a -SNAPSHOT version
from the Apache repository at:
https://repository.apache.org/content/groups/public/
zoran
On Thu, Oct 11, 2018 at 3:03 PM, Wang Yan <[hidden email]
<http:/
pache.org/jira/browse/CAMEL-12087
>
> On Wed, Oct 10, 2018 at 9:50 AM, Wang Yan <[hidden email]
> <http:///user/SendEmail.jtp?type=node&node=5824590&i=0>> wrote:
>
> > Hello All,
> >
> > I am running Apache Camel as SpringBoot application
&g
Hello All,
I am running Apache Camel as SpringBoot application
Everything is ok. but when i start it, I saw a warning No CamelContext
defined yet
but actually in my Route i could get it , and it is also initialized, i
used log to check and trace it
Then Version
2.22.0
2.0.4.RELE
Hello All,
I am running Apache Camel as SpringBoot application
Everything is ok. but when i start it, I saw a warning
* o.a.c.i.DefaultCamelBeanPostProcessor: No CamelContext defined yet so
cannot inject into bean:
org.apache.camel.converter.jaxb.FallbackTypeConverter*
*Then I add **CamelCo
My Pojo is complex, consisting of other Pojos
i create BindyFixedLengthDataFormat instance like below
when i unmarshal with BindyFixedLengthDataFormat for
fix length file i got error --- content is not allowed in prolog.
Any hints are more than welcome!
BindyFixedLengthDataFormat bindy = new
Bi
if my Pojo is complex, consisting of other Pojos
How should i create BindyFixedLengthDataFormat instance?
It seems i need create for 3 pojos but i could only create one like below
BindyFixedLengthDataFormat bindy = new
BindyFixedLengthDataFormat(com.mypackage.Order.class);
public class Orde
Thanks , it works now
Hello All,
As below shown, my logging are using two methods log and to, how to use
one method to make this below code tidier?
Any hints are more than welcome !
Thanks and Rgds
from("file:inputdir?moveFailed=.error").convertBodyTo(String.class).to("xquery:myxquery.xq")
.log("## Monitoring
In my camel route has below route , which send file input to xquery to
generate file output. as below shown
# camel route ##
from("file:src/data?moveFailed=.error").
to("xquery:myxquery.xq").to("file:target/output");
My problem is myxquery.xq file it has a function w
I try to save soap request (jaxb payload) to file as xml payload in apache
camel via below code, but it failed. anyone know how to do it? Any hints
will be more than welcome!
public class CamelRouteBuilder extends RouteBuilder {
private static final String SOAP_ENDPOINT_URI =
"cxf://http://lo
69 matches
Mail list logo
