route and output in attached text file*
${body}
${body}
ok
"Entered in Route Id: ${routeId}"\n
Please let me know if you want more details regarding this issue
--
Thanks,
Sachin
2020-01-24 20:21:28.100 INFO 178632 --- [ile://D:%5Cin_1] ding from File or
Queu
Can you try using adding all your response in a list in your aggregation
strategy. It works for me like below:
AggregationStrategy surnameAggregator = new AggregationStrategy() {
@SuppressWarnings("unchecked")
public Exchange aggregate(Exchange oldExchange, Exchange
newExch
Have you tried using xs:anytype as your payload type?
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-create-a-generic-SOAP-consumer-tp5731741p5731860.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Actually it worked with component scanning and even to add more if we keep
all processors in normal way after multicast and parallel processing, that
works too.
from("direct:endpoint")
multicast().
.parallelProcessing()
.process(processor1)
Thanks Diether, yeah i am using spring with package scanning with component
and service annotations. That will be great if it's so simple.
--
View this message in context:
http://camel.465427.n5.nabble.com/Processors-in-parallel-mode-tp5731613p5731631.html
Sent from the Camel - Users mailing li
I will try it..Thanks
--
View this message in context:
http://camel.465427.n5.nabble.com/Processors-in-parallel-mode-tp5731613p5731621.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Thanks for reply.
Yeah i can do that but only constraint is that i have so many processors and
it doesnt make much sense to convert them to routes. Is there any other way
i can run my processors concurrently?
--
View this message in context:
http://camel.465427.n5.nabble.com/Processors-in-para
Hi ,
When we set parallel processing in a route, do all processors run in
parallel or in sequence?
MY requirement is that i have 5-6 processors in my route and i want then to
be executed in parallel even for a single message, how can i achieve this?
from("direct:endpoint")
.thrott
Netty works on Boss-Worker thread concept, where for each sub sequent
connection request netty assigns a Boss thread which internally creates a
new worker thread for each request. By default no of worker thread are (2
*no of core in your machine) ,Post camel-netty 2.9.1 it's expose worker
thread pr
Hi, I am using PAYLOAD mode so no need of service classes. Below is my CXF
endpoint configuration:
Endpoint[cxf:///ws/CDSCompactService/CDSCompactService?wsdlURL=Systems/webServices/webServices/Summit/WsdlFiles/CDSCompactService.wsdl&serviceName={http://mustservice.summit}CDSCompactService&portNam
Hello All,
I am facing below problem while exposing cxf web service using contract
first approach. My tech stack is camel 2.9.1 with cxf 2.4.2.
if the WSDL contains nested XSD includes with relative paths such as ../,
the path to those includes that is built from their relative path is built
inco
That i have already tried, it just gives you the data without xml elements
and attributes. Might need to see the difference between XML utils
toString() implementation to that of XMLConvertors' one.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-CXF-strips-all-the-xml-
Strange, jut to let you know guys, it works with toString method of
org.apache.cxf.helpers.XMLUtils inspite of
org.apache.camel.converter.jaxp.XmlConverter.
FYI:
CxfPayload resPayload =
exchange.getOut().getBody(CxfPayload.class);
List inElements = resPayload.getBody();
String response =XMLUtils.
I have faced this problem for another endpoint also, but this time for
response. As clearly i can see exchange contains response message but while
converting it with xmlconvertor it returns "".
Simple converting it to string gives me reponse string like :
String response = exchange.getOut().getBod
This is first processsor of my route where i am trying to unmarshall request
message.
class CxfMessageToXMLString implements Processor {
@SuppressWarnings("unchecked")
@Override
public void process(Exchange exchange) throws Exception {
Hi, PFB the route code:
from(uri).threads(numberOfThreads).routeId(routeId).
// transacted("PROPAGATION_REQUIRED").
setProperty("nodeName").simple(nodeName)// node
name
.process(new
CxfMessageToXMLStr
XmlConverter converter = new XmlConverter();
String documentString =
converter.toString(inElements.get(0).cloneNode(true), exchange);
May be i am something really weird here, but i seems to struck here as i
need request xml to pass it further.
Regards
Sachi
Yes Willem, it works with "http://schemas.xmlsoap.org/soap/http"; and not
the "http://schemas.xmlsoap.org/soap/http/";.
Should we raise JIRA in CXF?
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-CXF-web-services-are-not-available-tp5720790p5720845.html
Sent from
Yes Willem, i tried that and it works perfectly fine. But as you said it's
workaround not a solution, since i have to change all my client's wsdl
files.
I have posted same concern in cxf site, let's see.
Many thanks to confirm my workaround.
--
View this message in context:
http://camel.46542
I have tried Camel 2.9.1 with cxf 2.5.4, still the StackOverflow persists. I
checked the SoapTransportFactory class) of
cxf-rt-bindings-soap-2.5.4-.jar, it also supports only below namespaces.
"http://schemas.xmlsoap.org/wsdl/soap/";
"http://schemas.xmlsoap.org/wsdl/http";
"http://schem
Thanks i will try that, but now i got it working with a workaround. It
definitely looks an issue to me.
As CXF 2.4 ( SoapTransportFactory class) only supposrts below namespaces.
"http://schemas.xmlsoap.org/wsdl/soap/";
"http://schemas.xmlsoap.org/wsdl/http";
"http://schemas.xmlsoap.org/wsdl
Hi Willem,
Thanks for your quick reply, i modified my endpoint to have cxf:/// in both
the routes, but now at camel startup i am getting below error in infinite
loop.
Caused by: java.lang.StackOverflowError
at
java.util.concurrent.ConcurrentHashMap$Segment.get(ConcurrentHashMap.java:350)
Thanks for the reply. I will try both the options. Hope it works
--
View this message in context:
http://camel.465427.n5.nabble.com/Filtering-of-mbeans-in-mbean-server-of-camel-tp4726520p4748940.html
Sent from the Camel - Users mailing list archive at Nabble.com.
I have configured camel jmx to combine with my application's jmx console by
doing the below configuration in camel-context.xml
I am successful in doing this.
This is how it is getting displayed in my application's jmx console(see
below).
My requirement is to filter on required type and show o
sible.
Regards
Sachin
--
View this message in context:
http://camel.465427.n5.nabble.com/To-set-client-authentication-false-in-SSL-communication-using-Camel-netty-2-6-tp4654878p4654878.html
Sent from the Camel - Users mailing list archive at Nabble.com.
a new connection and a new
request to a port, i have gone through all the documention but not clear.
what is the purpose of this max pool size here?
Regards
Sachin
--
View this message in context:
http://camel.465427.n5.nabble.com/Multiple-worker-threads-are-been-spawned-in-camel-netty-end
We have a requirement to send a message from our application, which is
basically a java bean to a JMS Queue.
Since "A bean: endpoint cannot be defined as the input to the route",
according to the definition, like to know how do we route message.
--
View this message in context:
http://camel.4654
Yes I have tried transactedInOut= true option.
Transaction is not getting committed anywhere. :(
--
View this message in context:
http://camel.465427.n5.nabble.com/Request-Response-with-Websphere-MQ-with-JTA-tp4513041p4519986.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi,
I am trying to achieve JMS request response scenario in XA with websphere
and websphere mq.
I am not using routes. I am using JmsProducer..process(ExchangePattern
exchange) with exchangePattern set to InOut. Since JMS will not send any
messages until a commit is performed, the server side wo
oesnt fulfill my
scenario.
I have to get same socket object, so that i can write my response back.
Please guide me.
Regards
Sachin
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-with-Netty-strange-requirement-tp4450979p4457745.html
Sent from the Camel - Users mailing
am of that socket, as my client cant read from
exchange, neither they can use any decoder.
Is there any way, i get access to socket object in processor class from
exchange object? Please guide me.
Regards
Sachin
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-with-Netty-st
FYI I am already using LengthFieldPrepender for encoding which will add the
length header to my messages, correct me i am wrong.
And LengthFieldBasedFrameDecoder for decoding purpose.
And i am not using any route fetaures of camel as of now, i am using only
endpoints defined in camel-context.xml
Hi,
I debugged the netty source code and came to know while sending message from
java client it causes problems in some decoding.
It goes to decode method of LengthFieldBasedFrameDecoder class where the
Frame length it fetched from Channel buffer exceeds the maxFrameLength,
hence returning null.
i
33 matches
Mail list logo