Getting following error while running :mvn clean install -Dtest=false
An Ant BuildException has occured: java.lang.NoClassDefFoundError:
org/apache/xml/serializer/ExtendedContentHandler:
org.apache.xml.serializer.ExtendedContentHandler
Which dependency is creating problem? Searched a bit on googl
My route is like this:
from(rabbitmq).
to(redisLockerProcessor).
to(processor1).
to(ahc://http:).to(processor2)
.to(redisLockReleaseProcessor)
I am using redisson library which stores thread id which took the lock in
redis. But in redisLockReleaseProcessor it is throwing exception that thread
id
Got it working now. Re read the documentation and found that we have to send
List> for bulk index and Map for
single index. For single index automatically the request was getting
converted to Map.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-elasticsearch-bulk-api-n
Hi,
I was experimenting with camel elasticsearch component. I was sending
following request to elasticsearch with INDEX operation. It is working as
expected.
{
"entityId":"test",
"userId":"test",
"timestamp":"2014-12-06 15:59:48",
"xyz":"test",
}
Now I changed the about request to a Lis
Hi,
What is the correct way to use different aggregation strategy in camel
depending on some header? Is the following way fine or is there any other
cleaner approach to do this?
from("direct:start")
.choice()
.when(header("foo").equalTo("bar"))
.aggregate(header("id"), new
B
illemjiang
> Weibo: 姜宁willem
>
>
>
> On September 4, 2014 at 2:12:55 AM, umang ([hidden email]
> <http://user/SendEmail.jtp?type=node&node=5756036&i=0>) wrote:
>
> > I was trying to test camel integration with kafka as explained here
> > (https:/
I was trying to test camel integration with kafka as explained here
(https://github.com/ipolyzos/camel-kafka/wiki)
Following is my code
public class KafkaTest {
public static void main(String args[]) throws Exception {
CamelContext context = new DefaultCamelContext();
