File tree Expand file tree Collapse file tree
billboard-aggregate/src/test/java/org/apache/camel/example/billboard
kafka/src/test/java/org/apache/camel/example/kafka
netty-custom-correlation/src/main/java/org/apache/camel/example/netty
resume-api-cassandraql/src/main/java/org/apache/camel/example/resume/cassandra/main
resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/main
resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized
aws-secrets-manager-reloading/src/main/java/org/apache/camel/example
aws-secrets-manager/src/main/java/org/apache/camel/example Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2424import org .apache .camel .AggregationStrategy ;
2525import org .apache .camel .CamelContext ;
2626import org .apache .camel .Exchange ;
27- import org .apache .camel .ExtendedCamelContext ;
2827import org .apache .camel .Message ;
2928import org .apache .camel .builder .RouteBuilder ;
3029import org .apache .camel .component .mock .MockEndpoint ;
Original file line number Diff line number Diff line change 2525import org .apache .camel .test .infra .kafka .services .KafkaService ;
2626import org .apache .camel .test .infra .kafka .services .KafkaServiceFactory ;
2727import org .apache .camel .test .junit6 .CamelTestSupport ;
28- import org .junit .jupiter .api .BeforeEach ;
2928import org .junit .jupiter .api .Test ;
3029import org .junit .jupiter .api .extension .RegisterExtension ;
3130
Original file line number Diff line number Diff line change 1818
1919import org .apache .camel .BindToRegistry ;
2020import org .apache .camel .Configuration ;
21- import org .apache .camel .LoggingLevel ;
2221import org .apache .camel .builder .RouteBuilder ;
2322import org .apache .camel .component .netty .DefaultChannelHandlerFactory ;
2423import org .apache .camel .main .Main ;
Original file line number Diff line number Diff line change 2525import org .apache .camel .example .resume .strategies .kafka .KafkaUtil ;
2626import org .apache .camel .main .Main ;
2727import org .apache .camel .processor .resume .kafka .KafkaResumeStrategyConfigurationBuilder ;
28- import org .apache .camel .processor .resume .kafka .SingleNodeKafkaResumeStrategy ;
2928
3029public class MainApp {
3130 public static void main (String [] args ) {
Original file line number Diff line number Diff line change 2222
2323import org .apache .camel .builder .RouteBuilder ;
2424import org .apache .camel .component .caffeine .resume .CaffeineCache ;
25- import org .apache .camel .example .resume .strategies .kafka .KafkaUtil ;
2625import org .apache .camel .example .resume .strategies .kafka .file .LargeFileRouteBuilder ;
2726import org .apache .camel .main .Main ;
28- import org .apache .camel .processor .resume .kafka .SingleNodeKafkaResumeStrategy ;
2927
3028/**
3129 * A Camel Application
Original file line number Diff line number Diff line change 1616 */
1717package org .apache .camel .example .resume .fileset .clusterized .main ;
1818
19- import org .apache .camel .CamelContext ;
2019import org .apache .camel .builder .RouteBuilder ;
2120import org .apache .camel .component .zookeeper .cluster .ZooKeeperClusterService ;
2221import org .apache .camel .example .resume .fileset .clusterized .strategies .ClusterizedLargeDirectoryRouteBuilder ;
Original file line number Diff line number Diff line change 2424import org .apache .camel .component .caffeine .resume .CaffeineCache ;
2525import org .apache .camel .example .resume .strategies .kafka .KafkaUtil ;
2626import org .apache .camel .processor .resume .kafka .KafkaResumeStrategyConfigurationBuilder ;
27- import org .apache .camel .resume .cache .ResumeCache ;
2827import org .apache .camel .support .resume .Resumables ;
2928import org .slf4j .Logger ;
3029import org .slf4j .LoggerFactory ;
Original file line number Diff line number Diff line change 1616 */
1717package org .apache .camel .example ;
1818
19- import org .apache .camel .component .aws .secretsmanager .vault .CloudTrailReloadTriggerTask ;
19+ import java .time .Instant ;
20+
2021import org .apache .camel .main .Main ;
2122import org .slf4j .Logger ;
2223import org .slf4j .LoggerFactory ;
23- import org .apache .camel .spi .ContextReloadStrategy ;
24- import software .amazon .awssdk .auth .credentials .ProfileCredentialsProvider ;
25- import software .amazon .awssdk .regions .Region ;
26- import software .amazon .awssdk .services .cloudtrail .CloudTrailClient ;
27- import software .amazon .awssdk .services .cloudtrail .model .*;
28-
29- import java .time .Instant ;
30- import java .util .List ;
31- import java .util .concurrent .Executors ;
32- import java .util .concurrent .ScheduledExecutorService ;
33- import java .util .concurrent .TimeUnit ;
3424
3525/**
3626 * Main class that boot the Camel application
Original file line number Diff line number Diff line change 1717package org .apache .camel .example ;
1818
1919import org .apache .camel .builder .RouteBuilder ;
20- import org .apache .camel .component .aws .secretsmanager .SecretsManagerConstants ;
2120
2221public class MyRouteBuilder extends RouteBuilder {
2322
Original file line number Diff line number Diff line change 1717package org .apache .camel .example ;
1818
1919import org .apache .camel .builder .RouteBuilder ;
20- import org .apache .camel .component .aws .secretsmanager .SecretsManagerConstants ;
2120
2221public class MyRouteBuilder extends RouteBuilder {
2322
You can’t perform that action at this time.
0 commit comments