Я пытаюсь реализовать переплет для Bigquery в Spring Cloud Stream. < /p>
Полный код приложения доступен на Github. Возвращает BigQueryBinder < /code> Следующий способ < /p>
Код: Выделить всё
@Configuration @EnableConfigurationProperties({ BigQueryConfiguration.class })
public class BigQueryBinderConfiguration {
@Autowired BigQueryConfiguration configuration;
@Bean
BigQueryBinder bigQueryMessageChannelBinder(BigQueryConfiguration configuration, BigQueryProvisioningProvider provisioningProvider) {
return new BigQueryBinder(configuration, provisioningProvider);
}
@Bean BigQueryProvisioningProvider provisioningProvider() {
return new BigQueryProvisioningProvider(configuration);
}
}
< /code>
Моя проблема заключается в том, что при этом мои другие связующие (кролик и кафка) больше не распознаются. < /p>
Мой протокол тестирования заключается в следующем: Я запускаю свое приложение и проверяю интерфейс Admin RabbitMQ, если мое приложение регистрируется в качестве потребителя. Это не тот случай, когда этот код неуместен. Отладка указывает на то, что вызов this.context.getbeansoftype (binder.class); Подробнее здесь: https://stackoverflow.com/questions/549 ... t-a-binder