@Test public void validateMessageReader() { MessageReader reader = commonBeans.messageReader("some_path"); assertThat(reader).isInstanceOf(SqsMessageReader.class); }
@Bean(name = "sqsMessageReader") public MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl) { return new SqsMessageReader.Builder(queueUrl).build(); }
CommonBeans { @Bean(name = "sqsMessageReader") public MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl) { return new SqsMessageReader.Builder(queueUrl).build(); } }
CommonBeans { @Bean(name = "sqsMessageReader") public MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl) { return new SqsMessageReader.Builder(queueUrl).build(); }  }
CommonBeans { @Bean(name = "sqsMessageReader") public MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl) { return new SqsMessageReader.Builder(queueUrl).build(); }  @Bean EnumMap<LifecycleEventType, SchedulerService> schedulerServiceMap(List<SchedulerService> schedulerServices); @Bean(name = "sqsMessageReader") MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl); @Bean(name = "retryingMessageReader") MessageReader retryingMessageReader(@Qualifier("sqsMessageReader") MessageReader messageReader); @Bean(name = "unreferencedHousekeepingPathGenerator") HousekeepingEntityGenerator unreferencedHousekeepingPathGenerator(
      @Value("${properties.beekeeper.default-cleanup-delay}") String cleanupDelay); @Bean(name = "unreferencedHousekeepingPathMessageEventHandler") MessageEventHandler unreferencedHousekeepingPathMessageEventHandler(
      @Qualifier("unreferencedHousekeepingPathGenerator") HousekeepingEntityGenerator generator); @Bean(name = "expiredHousekeepingMetadataGenerator") HousekeepingEntityGenerator expiredHousekeepingMetadataGenerator(
      @Value("${properties.beekeeper.default-expiration-delay}") String cleanupDelay); @Bean(name = "expiredHousekeepingMetadataMessageEventHandler") MessageEventHandler expiredHousekeepingMetadataMessageEventHandler(
      @Qualifier("expiredHousekeepingMetadataGenerator") HousekeepingEntityGenerator generator); @Bean BeekeeperEventReader eventReader(
      @Qualifier("retryingMessageReader") MessageReader messageReader,
      @Qualifier("unreferencedHousekeepingPathMessageEventHandler") MessageEventHandler unreferencedHousekeepingPathMessageEventHandler,
      @Qualifier("expiredHousekeepingMetadataMessageEventHandler") MessageEventHandler expiredHousekeepingMetadataMessageEventHandler
  ); }
CommonBeans { @Bean(name = "sqsMessageReader") public MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl) { return new SqsMessageReader.Builder(queueUrl).build(); }  @Bean EnumMap<LifecycleEventType, SchedulerService> schedulerServiceMap(List<SchedulerService> schedulerServices); @Bean(name = "sqsMessageReader") MessageReader messageReader(@Value("${properties.apiary.queue-url}") String queueUrl); @Bean(name = "retryingMessageReader") MessageReader retryingMessageReader(@Qualifier("sqsMessageReader") MessageReader messageReader); @Bean(name = "unreferencedHousekeepingPathGenerator") HousekeepingEntityGenerator unreferencedHousekeepingPathGenerator(
      @Value("${properties.beekeeper.default-cleanup-delay}") String cleanupDelay); @Bean(name = "unreferencedHousekeepingPathMessageEventHandler") MessageEventHandler unreferencedHousekeepingPathMessageEventHandler(
      @Qualifier("unreferencedHousekeepingPathGenerator") HousekeepingEntityGenerator generator); @Bean(name = "expiredHousekeepingMetadataGenerator") HousekeepingEntityGenerator expiredHousekeepingMetadataGenerator(
      @Value("${properties.beekeeper.default-expiration-delay}") String cleanupDelay); @Bean(name = "expiredHousekeepingMetadataMessageEventHandler") MessageEventHandler expiredHousekeepingMetadataMessageEventHandler(
      @Qualifier("expiredHousekeepingMetadataGenerator") HousekeepingEntityGenerator generator); @Bean BeekeeperEventReader eventReader(
      @Qualifier("retryingMessageReader") MessageReader messageReader,
      @Qualifier("unreferencedHousekeepingPathMessageEventHandler") MessageEventHandler unreferencedHousekeepingPathMessageEventHandler,
      @Qualifier("expiredHousekeepingMetadataMessageEventHandler") MessageEventHandler expiredHousekeepingMetadataMessageEventHandler
  );  }