如何在Apache Camel中设置进程标头

import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

public class CamelHeaderExample {
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();

        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct:start")
                    .process(exchange -> {
                        // 设置进程标头
                        exchange.getIn().setHeader("customHeader", "Hello, Camel!");
                    })
                    .to("log:headerLogger")
                    .process(exchange -> {
                        // 读取进程标头
                        String headerValue = exchange.getIn().getHeader("customHeader", String.class);
                        System.out.println("Custom Header Value: " + headerValue);
                    });
            }
        });

        context.start();
        Thread.sleep(5000);
        context.stop();
    }
}