HI, All
I have an sftp consumer and I need to use privateKey as consumer option,
the use case is I need to read this key from a vault and pass it as a
byte[] in the option parameter. Besides using @BindToRegistry is there any
other way i can pass privateKey=byte[] while building the route in java.
Hi Sherwin,
I used the SftpConfiguration object to configure it for the endpoint, here is
the code:
public Endpoint sftpEndpoint() {
SftpEndpoint endpoint = context.getEndpoint(sftpUrl,
SftpEndpoint.class);
SftpConfiguration config = endpoint.getConfiguration();
I am getting ClassCastException while trying to execute camel route
from("timer://messageSplitterTest?repeatCount=1")
.process(exchange -> {
Message message = exchange.getMessage();
List ongoingMessages = new ArrayList<>();
for (int i = 0; i < 10; i++)
You have 2 splits, so you need and end before the end choice
On Fri, Jul 26, 2019 at 10:51 AM sujin sr wrote:
>
> I am getting ClassCastException while trying to execute camel route
>
> from("timer://messageSplitterTest?repeatCount=1")
> .process(exchange -> {
> Message
Thanks Claus. After adding end before endchoice my route is working now.
.to("stream:out")
.end()
.endChoice()
My understanding about end & endchoice is that, end() will close the
choice() clause, endchoice() will close the when() clause. Then why do
we need another end() before endChoice in
Hello,
I have multiple sequential queues in InOut pattern, each queue leads to one
processor.
If a processor takes too much time for a treatment, I would like that the
request-reply detects a timeout and send a timeout exception.
The timeout with "*CamelJmsRequestTimeout*" works but only for the
Writing my problem helps me to figure out how to solve it:
the message in q1 is injected from Spring and no queue for reply was
defined. I changed the exchange pattern of the q1 to InOnly, and now it
works.
Le ven. 26 juil. 2019 à 14:46, Damien Nicolas a
écrit :
> Hello,
> I have multiple
Hmmm actually, if I add a queue, it just move the problem. Any idea?
Le ven. 26 juil. 2019 à 14:46, Damien Nicolas a
écrit :
> Hello,
> I have multiple sequential queues in InOut pattern, each queue leads to
> one processor.
> If a processor takes too much time for a treatment, I would like
