Class TestChannelBinderConfiguration<T>

java.lang.Object
org.springframework.cloud.stream.binder.test.TestChannelBinderConfiguration<T>
Type Parameters:
T - binding type
@Configuration(proxyBeanMethods=false) @ConditionalOnMissingBean(org.springframework.cloud.stream.binder.Binder.class) @Import(org.springframework.cloud.stream.config.BinderFactoryAutoConfiguration.class) @EnableIntegration public class TestChannelBinderConfiguration<T> extends Object
Binder configuration backed by Spring Integration. Please see TestChannelBinder for more details.
Author:
Oleg Zhurakousky, David Turanski, Soby Chacko
See Also:

  • Field Details

  • Constructor Details

    • TestChannelBinderConfiguration

      public TestChannelBinderConfiguration()

  • Method Details

    • getCompleteConfiguration

      public static Class<?>[] getCompleteConfiguration(Class<?>... additionalConfigurationClasses)
      Utility operation to return an array of configuration classes where function definitions are provided. Typically used for tests that do not rely on creating an SCSt boot application, yet require full Binder configuration.
      Parameters:
      additionalConfigurationClasses - config classes to be added to the default config
      Returns:
      an array of configuration classes

    • applicationContextRunner

      public static org.springframework.boot.test.context.runner.ApplicationContextRunner applicationContextRunner(Class<?>... additionalConfigurationClasses)
      Create an ApplicationContextRunner with user configuration using getCompleteConfiguration(Class...).
      Parameters:
      additionalConfigurationClasses - config classes to be added to the default config
      Returns:
      the ApplicationContextRunner

    • sourceDestination

      @Bean public InputDestination sourceDestination()

    • targetDestination

      @Bean public OutputDestination targetDestination()

    • springIntegrationChannelBinder

      @Bean public org.springframework.cloud.stream.binder.Binder<T, ? extends org.springframework.cloud.stream.binder.ConsumerProperties, ? extends org.springframework.cloud.stream.binder.ProducerProperties> springIntegrationChannelBinder(TestChannelBinderProvisioner provisioner)

    • springIntegrationProvisioner

      @Bean public TestChannelBinderProvisioner springIntegrationProvisioner()

    • observationRegistry

      @Bean @ConditionalOnMissingBean public io.micrometer.observation.ObservationRegistry observationRegistry()