in 01-basic/Routing.java [33:53]
public void configure() throws Exception {
from("timer:java?period=3000")
.id("generator")
.bean(this, "generateRandomItem({{items}})")
.choice()
.when().simple("${body.startsWith('{{priority-marker}}')}")
.transform().body(String.class, item -> item.substring(priorityMarker.length()))
.to("direct:priorityQueue")
.otherwise()
.to("direct:standardQueue");
from("direct:standardQueue")
.id("standard")
.log("Standard item: ${body}");
from("direct:priorityQueue")
.id("priority")
.log("!!Priority item: ${body}");
}