Disruptor - ringbuffer full. How to measure?

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

Re: How to configure http client?

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

Re: How to configure http client?

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 =

How to configure http client?

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

Re: How to configure http client?

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);

DirtiesContext vs just restarting context

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.

HTTP: how to handle status code 500?

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

wireTap: how to put a map in newExchangeBody?

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 T

Re: wireTap: how to put a map in newExchangeBody?

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.

placeholder in an endpoint?

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 the

Re: placeholder in an endpoint?

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.

split an InputStream?

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

Register client when connecting to a topic?

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

RE: InOut and JMS topic, does it make sense?

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

Re: Register client when connecting to a topic?

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:

InOut and JMS topic, does it make sense?

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

Design question: multicaster, request-reply and InOut

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

Re: inflight and pending exchanges during shutdown in a test

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

Dependency to jaxb-impl

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

Re: Dependency to jaxb-impl

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.

UTF-8 and TypeConversionException

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

Re: UTF-8 and TypeConversionException

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

InvalidPayloadException deprecated in 2.10.0

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

Re: Split: how to include parents in XML and prevent original message?

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 why

Split: how to include parents in XML and prevent original message?

hello helpful forum, I have the following XML x myAttr=123 y data 1... /y y data 2... /y /x and the following setup .split().tokenizeXML(y) I have a couple of questions *1*) I would like to split this into two messages: x myAttr=123 y data 1...

Split: how to leave message untouched?

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

Re: Split: how to leave message untouched?

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)

Re: Split: how to leave message untouched?

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.