Hi,
I think there might be a small bug when invoking KafkaHeaderFilterStrategy.
KafkaProducer.java calls:
headerFilterStrategy.applyFilterToExternalHeaders(entry.getKey(),
entry.getValue(), exchange)
KafkaConsumer.java calls:
headerFilterStrategy.applyFilterToCamelHeaders(header.key(),
header.val
Hi
I'm using camel-rabbit 2.21.1 and want to
create an exclusive consumer. I've tried using the exclusive=true
option but that creates an exclusive queue which may only be accessed
by the current connection and is deleted when that connection closes.
I want to be able to lock an existing durable q
Hi,
I have a context scoped onCompletion() that sends to RabbitMQ. When Camel
is shutdown it doesn't close the connection to RabbitMQ. If the
onCompletion() is route scoped the connection is closed.
This test shows the problem. I expect the SendProcessor to be shutdown when
the CamelContext is shu
