I am working on a code in which one processor is like
public void process(Exchange exchange) throws Exception
{
exchange.getIn().setHeader("AMQ_PASSWORD",
exchange.getMessage().getBody(io.fabric8.kubernetes.api.model.Secret.class).getData().get("amq-password"));
}
I thought to simplify this with following code in route
...
.to("kubernetes-secrets:///?kubernetesClient=#kubernetesClient&operation=getSecret")
.setHeader("amq_pass", simple("
${body.getData.get[amq-password]} "))
or
.setHeader("amq_pass", simple("
${bodyAs(io.fabric8.kubernetes.api.model.Secret).getData.get[amq-password]}
"))
...
But all tries leads to following error
[org.apa.cam.qua.mai.CamelMainRuntime] (Quarkus Main Thread) Failed to
start application: org.apache.camel.FailedToCreateRouteException: Failed to
create route nats-pub at: >>> Set
Header[nats_user, simple{ ${body.getData.get('amq-password')} }] <<<
in route: Route(nats-pub)[From[timer://ipc?repeatCount=1&delay=60000] ...
because of No language could be found for: bean