hello,
we recently replaced seda with disruptor and are currently learning how it
works. Yesterday we had some problems in the system, and the disruptor threw
exceptions saying
java.lang.IllegalStateException: Disruptors ringbuffer was full
at
org.apache.camel.component.disruptor.Disruptor
ok, thanks for the answer. I ended up doing the following. Seems to be
working ok.
HttpComponent http4Component = camelContext.getComponent("http4",
HttpComponent.class);
http4Component.setHttpClientConfigurer(new
HttpClientSocketTimeoutConfigurer());
HttpComponent https4Component = camelContext.
thank you, Willem,
so the code suggested would actually set the SO_TIMEOUT on the http-client?
I can not seem to get it to work, but will try further to try to figure it
out.
I also notice the HttpComponent.setConnectionTimeToLive(). Would that
accomplish the same behaviour?
best regard, Per Jorg
I could use the code below (as suggested in
http://camel.apache.org/http4.html), but seems like any calls on the
HttpClient are deprecated in HttpClient 4.3. Any non-deprecated suggestions?
HttpComponent httpComponent = getContext().getComponent("http4",
HttpComponent.class);
httpComponent.setHttp
hello,
we have the following entry in our route:
.to(routeConfig.getSupplierUri())
where supplierUri could be
(1) https4:foo.com/MetaSearchService_v1.asmx
(2) https4:bar.com/service?username=foo
etc. (we configure around 30 of these routes)
What we would like to do, is to set a global soTimeout
hello,
I was wondering about the use of the DirtiesContext-annotation at the
class-level. According to http://camel.apache.org/spring-testing.html, it
"forces Spring Testing to automatically reload the CamelContext after each
test method - this ensures that the tests don't clash with each other".
R
hello,
we are using http4 with camel 2.12.1, posting soap to an external party.
However, the external party seems to exaggerate(?) the usage of REST and
return a status code 500 when our request is not supported. When using e.g.
postman in chrome, I can see that a response is given with the 500 whi
great, thank you :-)
--
View this message in context:
http://camel.465427.n5.nabble.com/wireTap-how-to-put-a-map-in-newExchangeBody-tp5737340p5737343.html
Sent from the Camel - Users mailing list archive at Nabble.com.
hello,
I have a map with two entries which I would like to use as the new body in a
wireTap
.wireTap("log:foo").newExchangeBody(myMap).end()
I managed doing this by writing a custom Expression, but there must be an
easier way of doing this?
.newExchangeBody(new Expression() {
@Override
public T
great, thank you very much!
--
View this message in context:
http://camel.465427.n5.nabble.com/placeholder-in-an-endpoint-tp5733698p5733702.html
Sent from the Camel - Users mailing list archive at Nabble.com.
I'm trying to do
.to("${in.header.JMSReplyTo}")
but can not get it to work. Is there any way to easily fetch the Exchange
headers and use them in the ProcessorDefinition?
--
View this message in context:
http://camel.465427.n5.nabble.com/placeholder-in-an-endpoint-tp5733698.html
Sent from th
hello,
is it possible to use a splitter on an InputStream? I receive a big XML-file
via an HttpResponse.getEntity().getContent() and I have used SAX to parse
that stream and split it into smaller units. It works fairly well, but since
Camel has a split() which is designed to solve exactly that prob
Thank you for the answers! Advisory topics seems to be just what we were
looking for. I will dive into this and post my experiences here when I find
out more about it.
cheers,
pj
--
View this message in context:
http://camel.465427.n5.nabble.com/Register-client-when-connecting-to-a-topic-tp573
thank you, Stephan. Your answer makes sense. I think we will use topic +
inOnly and handle the responses in a different route. The number of
subscribers could be as high as 50, so a topic seems to be the solution.
You also say that "Camel had no way to determine what n is and how many
answers to e
hello,
when using an ActiveMQ topic with Camel (2.11.0), is there a way to make
Camel dynamically aware of the clients subscribing to the topic? We are
striving for loose coupling and our ideal scenario would be like this
1) Camel starts a topic, which is not durable
2) A hitherto unknown subscrib
hello,
we are using Camel 2.11.0 with the following route
from("activemq:incoming").inOut("activemq:topic:integrations").to("direct:storage").end()
my question is simply if this makes sense? We love the idea of using InOut
MEP and letting Camel generate temporary reply-queues. We have e.g. 10 JMS
hello,
I'm in the process of integrating a number of external parties into a Flight
search service. However, I am not sure that our defined routes are optimal.
Could someone here do a sanity check? That would be highly appreciated!
Requirements:
- send async requests to 20-30 external flight serv
I think your solution, since you are using 2.10.4, is to use the
mockEndpointsAndSkip available in Camel 2.10 and onwards. When you mock
endpoints in previous versions, the original enpoints are still active; i.e.
both your mocks and your unmocked endpoints will receive the messages. I
guess that i
great answer, thank you Dan.
/pj
--
View this message in context:
http://camel.465427.n5.nabble.com/Dependency-to-jaxb-impl-tp5722030p5722036.html
Sent from the Camel - Users mailing list archive at Nabble.com.
hello,
I see that camel-core, camel-jms and camel-spring transitively depends on
jaxb-impl. What would be the reason for that?
This causes some problems when using jax-ws.
java.lang.ClassCastException: com.sun.xml.bind.v2.runtime.JAXBContextImpl
cannot be cast to com.sun.xml.internal.bind.api.JA
ok, the solution was quite simple by using the charset as a parameter to
convertBodyTo
.convertBodyTo(String.class, com.google.common.base.Charsets.UTF_8.name())
--
View this message in context:
http://camel.465427.n5.nabble.com/UTF-8-and-TypeConversionException-tp5717996p5718032.html
Sent fro
hello,
I have an XML which is UTF-8 encoded (according to itself, at least). The
XML (unfortunately) contains a Triple DES encrypted password, which is
stored in a database as VARCHAR (encoded in UTF-8 according to the DBA).
When Camel (2.10) receives this message, I get an exception and the messag
hello,
I just noticed that InvalidPayloadException is deprecated in 2.10.0. Reading
the source code, the only hint is "// TODO: We should remove this class in
Camel 3.0, and just rely on the other exceptions for type conversion issues"
So what do you suggest to use instead of the InvalidPayloadExc
I ended up doing
.split().method("splitterBean", "splitWithParents").aggregationStrategy(new
UseLatestAggregationStrategy())
where my splitterBean solves 1) as mentioned in the original post and the
use of UseLatestAggregationStrategy solves 2) as mentioned in the original
post. I have no idea w
hello helpful forum,
I have the following XML
data 1...
data 2...
and the following setup
.split().tokenizeXML("y")
I have a couple of questions
*1*) I would like to split this into two messages:
data 1...
and
data 2...
thank you, that worked perfectly.
--
View this message in context:
http://camel.465427.n5.nabble.com/Split-how-to-leave-message-untouched-tp5714734p5714749.html
Sent from the Camel - Users mailing list archive at Nabble.com.
if the filter() Predicate returns false, I assume the processing stops there?
I would like to go beyond the split() and carry on with the .convertBodyTo()
etc. in case the filter() returns false.
I tried something like
from(incomingQueue)
.choice()
.when().xpath(UPDATE_XPATH)
.split().tokenizeXML(
hello,
I split messages using
from(incomingQueue)
.startupOrder(1)
*.split().tokenizeXML("update", "dbStream")*
.convertBodyTo(Document.class)
.choice()
.when().xpath(SUBSCRIPTION_XPATH)
.to(AGGREGATE_MESSAGES)
.otherwise()
.to(PRODUCERS)
.end();
however, when the XML does not contain neither n
28 matches
Mail list logo