Changes class to use to check presence of Spring Cloud Stream

This commit is contained in:
spencergibb
2022-01-20 13:14:07 -05:00
parent ccfa6ec19d
commit 0b136e3783
2 changed files with 4 additions and 4 deletions

View File

@@ -25,7 +25,7 @@ import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierMessage;
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierMessaging;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpContractVerifierAutoConfiguration;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.binder.Binder;
import org.springframework.cloud.stream.binder.test.InputDestination;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
@@ -37,7 +37,7 @@ import org.springframework.util.Assert;
* @author Marcin Grzejszczak
*/
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(EnableBinding.class)
@ConditionalOnClass(Binder.class)
@ConditionalOnProperty(name = "stubrunner.stream.enabled", havingValue = "true", matchIfMissing = true)
@AutoConfigureBefore(NoOpContractVerifierAutoConfiguration.class)
public class ContractVerifierStreamAutoConfiguration {

View File

@@ -23,7 +23,7 @@ import org.springframework.boot.test.context.FilteredClassLoader;
import org.springframework.boot.test.context.runner.ApplicationContextRunner;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifierSender;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpStubMessages;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.binder.Binder;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.kafka.core.KafkaTemplate;
@@ -41,7 +41,7 @@ public class AutoConfigureMessageVerifierTests {
public void shouldConfigureForNoOpWhenMissingImplementation() {
this.contextRunner.withClassLoader(
new FilteredClassLoader(org.apache.camel.Message.class, org.springframework.messaging.Message.class,
JmsTemplate.class, KafkaTemplate.class, RabbitTemplate.class, EnableBinding.class))
JmsTemplate.class, KafkaTemplate.class, RabbitTemplate.class, Binder.class))
.run((context) -> {
assertThat(context.getBeansOfType(MessageVerifierSender.class)).hasSize(1);
assertThat(context.getBeansOfType(NoOpStubMessages.class)).hasSize(1);