Весенний ботинок на верблюде

Мне нужно проверить маршруты Camel в приложении Spring Boot. Я имею основной загрузочный класс Spring со всеми необходимыми bean-компонентами, объявленными в нем. Я использую CamelSpringJUnit4ClassRunner.class. Добавлен мой основной класс загрузки Spring в @ContextConfiguration, так как он содержит все конфигурации. У меня нет отдельного класса конфигурации.

Я автоматически подключил CamelContext в своем тестовом классе:

@Autowired
CamelContext camelContext;

Но тест не проходит с ошибкой:

Вызывается: org.springframework.beans.factory.NoSuchBeanDefinitionException:

Недоступен квалифицируемый компонент типа org.apache.camel.CamelContext: ожидается, что по крайней мере 1 компонент будет выбран в качестве кандидата для автоматической передачи.

Аннотации зависимостей: {@org.springframework.beans.factory.annotation.Autowired(обязательно =true)}

1 ответ

Решение

Попробуйте использовать CamelSpringBootRunner.class в качестве бегуна и добавить @SpringBootTest аннотация к тестовому классу.

Пример из репозитория Camel

ОБНОВЛЕНИЕ (на основе вашего комментария)

Если вы измените свой класс начальной загрузки на SpringBootTestContextBootstrapper тогда должно работать:

@BootstrapWith(SpringBootTestContextBootstrapper.class)

Эквивалентная конфигурация, как у вас, но в этом случае вам не нужно добавлять ContextConfiguration и BootstrapWith аннотация:

@RunWith(CamelSpringBootRunner.class)
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
@MockEndpoints("log:*")
@DisableJmx(false)
@SpringBootTest(classes = MyClass.class) 

Просто включите @EnableAutoConfiguration, он будет работать

С Camel 3.1 Spring Boot 2.2.5 и JUnit5, а также с настройкой свойств тестового приложения:

@CamelSpringBootTest
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@TestPropertySource(properties = "spring.cloud.consul.enabled=false")
public class CamelRouteTest {

  @Autowired
  private TestRestTemplate restTemplate;

  @Autowired
  private CamelContext camelContext;

  @EndpointInject("mock:bean:userService")
  private MockEndpoint mockUserService;

  private User user;

  @BeforeEach
  public void setUp() throws Exception {
    AdviceWithRouteBuilder.adviceWith(camelContext, "getUsersRoute", a -> {
      a.mockEndpointsAndSkip("bean:userService*");
    });

    user = new User();
    user.setId(1);
    user.setName("Jane");

    mockUserService.returnReplyBody(constant(new User[] {user}));
  }

  @Test
  public void callsRestWithMock() {
    ResponseEntity<User[]> response = restTemplate.getForEntity("/rest/users", User[].class);
    assertThat(response.getStatusCode()).isEqualTo(HttpStatus.OK);
    User[] s = response.getBody();
    assertThat(s).contains(user);
  }

  @Test
  public void callsDirectRouteWithMock() throws Exception {
    User[] users = DefaultFluentProducerTemplate.on(camelContext)
        .to("direct:getusers")
        .request(User[].class);
    assertThat(users).contains(user);
  }

  @Test
  public void camelStarts() {
    assertEquals(ServiceStatus.Started, camelContext.getStatus());
    assertThat(camelContext.getRoutes()).hasSizeGreaterThan(0);
  }
}

Предполагая RouteBuilder:

@Component
public class CamelRouter extends RouteBuilder {

  @Value("${server.port}")
  private int serverPort;

  @Override
  public void configure() throws Exception {
    restConfiguration()
        .contextPath("/rest")
        .component("servlet")
        .apiContextPath("/api-doc")
        .port(serverPort)
        .bindingMode(RestBindingMode.json)
        .dataFormatProperty("prettyPrint", "true");

    rest("/users")
        .consumes("application/json")
        .produces("application/json")
        .get()
        .outType(User[].class).to("direct:getusers");

    from("direct:getusers").routeId("getUsersRoute")
        .log("Get users")
        .to("bean:userService?method=listUsers");
  }
}

и application.yml:

camel:
  component:
    servlet:
      mapping:
        context-path: /rest/*
  springboot:
    name: MyCamel
Другие вопросы по тегам