in aws/main-endpointdsl-aws2/aws2-eventbridge-creator/src/main/java/org/apache/camel/example/MyRouteBuilder.java [33:49]
public void configure() throws Exception {
from(timer("fire").repeatCount("1"))
.setHeader(EventbridgeConstants.RULE_NAME, constant("s3-events-rule"))
.to(aws2Eventbridge("default")
.operation(EventbridgeOperations.putRule)
.eventPatternFile("file:src/main/resources/eventpattern.json"))
.process(exchange -> {
exchange.getMessage().setHeader(EventbridgeConstants.RULE_NAME, "s3-events-rule");
Target target = Target.builder().id("sqs-queue").arn("arn:aws:sqs:eu-west-1:780410022472:camel-connector-test").build();
List<Target> targets = new ArrayList<>();
targets.add(target);
exchange.getMessage().setHeader(EventbridgeConstants.TARGETS, targets);
})
.to(aws2Eventbridge("default")
.operation(EventbridgeOperations.putTargets))
.log("All set, enjoy!");
}