SpringCloud/spring-cloud-contract
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename (again) StubMessages -> MessageVerifier

Browse Source 
It's not a stub, it's just a wrapper around the underlying
messaging framework.
This commit is contained in:
Dave Syer
2016-07-19 11:52:01 +01:00
parent 7cdf36127e
commit 2143574868
30 changed files with 78 additions and 77 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -2,6 +2,7 @@
#*
*#
.#*
.factorypath
.classpath
.project
.settings/

6
docs/src/main/asciidoc/verifier/messaging.adoc
View File

@@ -39,17 +39,17 @@ You have to provide as a dependency the messaging module that matches your provi
testCompile "org.springframework.cloud:spring-cloud-contract-verifier-integration"
----
and then add `@AutoConfigureStubMessages` to your test, e.g.
and then add `@AutoConfigureMessageVerifier` to your test, e.g.
[source,java,indent=0]
----
@RunWith(SpringTestRunner.class)
@SpringBootTest
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public static class MessagingContractTests {
@Autowired
private StubMessages exchange;
private MessageVerifier verifier;
...
}
----

8
samples/samples-messaging-camel/src/test/groovy/com/example/CamelMessagingApplicationSpec.groovy
View File

@@ -24,8 +24,8 @@ import org.junit.BeforeClass
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.boot.test.context.SpringBootContextLoader
import org.springframework.cloud.contract.spec.Contract
import org.springframework.cloud.contract.verifier.messaging.StubMessages
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierObjectMapper;
import org.springframework.test.annotation.DirtiesContext
import org.springframework.test.context.ContextConfiguration
@@ -42,11 +42,11 @@ import com.toomuchcoding.jsonassert.JsonAssertion
// Context configuration would end up in base class
@ContextConfiguration(classes = [CamelMessagingApplication], loader = SpringBootContextLoader)
@DirtiesContext
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public class CamelMessagingApplicationSpec extends Specification {
// ALL CASES
@Inject StubMessages<Message> contractVerifierMessaging
@Inject MessageVerifier<Message> contractVerifierMessaging
ContractVerifierObjectMapper contractVerifierObjectMapper = new ContractVerifierObjectMapper()
@BeforeClass

8
samples/samples-messaging-integration/src/test/groovy/com/example/IntegrationMessagingApplicationSpec.groovy
View File

@@ -21,8 +21,8 @@ import javax.inject.Inject
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.boot.test.context.SpringBootContextLoader
import org.springframework.cloud.contract.spec.Contract
import org.springframework.cloud.contract.verifier.messaging.StubMessages
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierObjectMapper;
import org.springframework.messaging.Message
import org.springframework.test.annotation.DirtiesContext
@@ -36,11 +36,11 @@ import com.toomuchcoding.jsonassert.JsonAssertion
// Context configuration would end up in base class
@ContextConfiguration(classes = [IntegrationMessagingApplication], loader = SpringBootContextLoader)
@DirtiesContext
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public class IntegrationMessagingApplicationSpec extends Specification {
// ALL CASES
@Inject StubMessages<Message<?>> contractVerifierMessaging
@Inject MessageVerifier<Message<?>> contractVerifierMessaging
ContractVerifierObjectMapper contractVerifierObjectMapper = new ContractVerifierObjectMapper()
def "should work for triggered based messaging"() {

8
samples/samples-messaging-spring/src/test/groovy/com/example/SpringApplicationSpec.groovy
View File

@@ -22,8 +22,8 @@ import org.junit.BeforeClass
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.boot.test.context.SpringBootContextLoader
import org.springframework.cloud.contract.spec.Contract
import org.springframework.cloud.contract.verifier.messaging.StubMessages
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierObjectMapper;
import org.springframework.messaging.Message;
import org.springframework.test.annotation.DirtiesContext
@@ -41,11 +41,11 @@ import com.toomuchcoding.jsonassert.JsonAssertion
// Context configuration would end up in base class
@ContextConfiguration(classes = [SpringMessagingApplication], loader = SpringBootContextLoader)
@DirtiesContext
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public class SpringApplicationSpec extends Specification {
// ALL CASES
@Inject StubMessages<Message<?>> contractVerifierMessaging
@Inject MessageVerifier<Message<?>> contractVerifierMessaging
ContractVerifierObjectMapper contractVerifierObjectMapper = new ContractVerifierObjectMapper()
@BeforeClass

8
samples/samples-messaging-stream/src/test/groovy/com/example/StreamMessagingApplicationSpec.groovy
View File

@@ -22,8 +22,8 @@ import org.springframework.beans.factory.annotation.Autowired
import org.springframework.boot.test.IntegrationTest
import org.springframework.boot.test.context.SpringBootContextLoader
import org.springframework.cloud.contract.spec.Contract
import org.springframework.cloud.contract.verifier.messaging.StubMessages
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierObjectMapper;
import org.springframework.messaging.Message;
import org.springframework.test.annotation.DirtiesContext
@@ -41,11 +41,11 @@ import com.toomuchcoding.jsonassert.JsonAssertion
@ContextConfiguration(classes = [StreamMessagingApplication], loader = SpringBootContextLoader)
@DirtiesContext
@IntegrationTest("debug=true")
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public class StreamMessagingApplicationSpec extends Specification {
// ALL CASES
@Inject StubMessages<Message<?>> contractVerifierMessaging
@Inject MessageVerifier<Message<?>> contractVerifierMessaging
ContractVerifierObjectMapper contractVerifierObjectMapper = new ContractVerifierObjectMapper()
def "should work for triggered based messaging"() {

4
samples/standalone/stream-source/src/test/java/com/example/source/SensorSourceTestBase.java
View File

@@ -19,7 +19,7 @@ package com.example.source;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages;
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/**
@@ -31,7 +31,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
*/
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = ContractVerifierSampleStreamSourceApplication.class, properties="spring.cloud.stream.bindings.output.destination=sensor-data")
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public abstract class SensorSourceTestBase {
@Autowired

8
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-stream/src/test/groovy/org/springframework/cloud/contract/stubrunner/messaging/stream/StreamStubRunnerSpec.groovy
View File

@@ -28,8 +28,8 @@ import org.springframework.boot.test.context.SpringBootContextLoader
import org.springframework.cloud.contract.spec.Contract
import org.springframework.cloud.contract.stubrunner.StubFinder
import org.springframework.cloud.contract.stubrunner.spring.AutoConfigureStubRunner
import org.springframework.cloud.contract.verifier.messaging.StubMessages
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier;
import org.springframework.cloud.stream.annotation.EnableBinding
import org.springframework.cloud.stream.messaging.Sink
import org.springframework.cloud.stream.messaging.Source
@@ -46,11 +46,11 @@ import spock.lang.Specification
@ContextConfiguration(classes = Config, loader = SpringBootContextLoader)
@IntegrationTest("debug=true")
@AutoConfigureStubRunner
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
class StreamStubRunnerSpec extends Specification {
@Autowired StubFinder stubFinder
@Autowired StubMessages<Message<?>> messaging
@Autowired MessageVerifier<Message<?>> messaging
def setup() {
// ensure that message were taken from the queue

8
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/BatchStubRunnerFactory.java
View File

@@ -16,7 +16,7 @@
package org.springframework.cloud.contract.stubrunner;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpStubMessages;
/**
@@ -29,13 +29,13 @@ public class BatchStubRunnerFactory {
private final StubRunnerOptions stubRunnerOptions;
private final StubDownloader stubDownloader;
private final StubMessages contractVerifierMessaging;
private final MessageVerifier contractVerifierMessaging;
public BatchStubRunnerFactory(StubRunnerOptions stubRunnerOptions) {
this(stubRunnerOptions, new AetherStubDownloader(stubRunnerOptions), new NoOpStubMessages());
}
public BatchStubRunnerFactory(StubRunnerOptions stubRunnerOptions, StubMessages contractVerifierMessaging) {
public BatchStubRunnerFactory(StubRunnerOptions stubRunnerOptions, MessageVerifier contractVerifierMessaging) {
this(stubRunnerOptions, new AetherStubDownloader(stubRunnerOptions), contractVerifierMessaging);
}
@@ -43,7 +43,7 @@ public class BatchStubRunnerFactory {
this(stubRunnerOptions, stubDownloader, new NoOpStubMessages());
}
public BatchStubRunnerFactory(StubRunnerOptions stubRunnerOptions, StubDownloader stubDownloader, StubMessages contractVerifierMessaging) {
public BatchStubRunnerFactory(StubRunnerOptions stubRunnerOptions, StubDownloader stubDownloader, MessageVerifier contractVerifierMessaging) {
this.stubRunnerOptions = stubRunnerOptions;
this.stubDownloader = stubDownloader;
this.contractVerifierMessaging = contractVerifierMessaging;

4
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/StubRunner.java
View File

@@ -23,7 +23,7 @@ import java.util.Collection;
import java.util.Map;
import org.springframework.cloud.contract.spec.Contract;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpStubMessages;
/**
@@ -52,7 +52,7 @@ public class StubRunner implements StubRunning {
public StubRunner(StubRunnerOptions stubRunnerOptions, String repositoryPath,
StubConfiguration stubsConfiguration,
StubMessages<?> contractVerifierMessaging) {
MessageVerifier<?> contractVerifierMessaging) {
this.stubsConfiguration = stubsConfiguration;
this.stubRunnerOptions = stubRunnerOptions;
this.stubRepository = new StubRepository(new File(repositoryPath));

6
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/StubRunnerExecutor.java
View File

@@ -32,7 +32,7 @@ import org.springframework.cloud.contract.spec.internal.DslProperty;
import org.springframework.cloud.contract.spec.internal.Headers;
import org.springframework.cloud.contract.spec.internal.OutputMessage;
import org.springframework.cloud.contract.stubrunner.AvailablePortScanner.PortCallback;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpStubMessages;
import org.springframework.cloud.contract.verifier.util.BodyExtractor;
@@ -45,11 +45,11 @@ public class StubRunnerExecutor implements StubFinder {
private static final Logger log = LoggerFactory.getLogger(StubRunnerExecutor.class);
private final AvailablePortScanner portScanner;
private final StubMessages<?> contractVerifierMessaging;
private final MessageVerifier<?> contractVerifierMessaging;
private StubServer stubServer;
public StubRunnerExecutor(AvailablePortScanner portScanner,
StubMessages<?> contractVerifierMessaging) {
MessageVerifier<?> contractVerifierMessaging) {
this.portScanner = portScanner;
this.contractVerifierMessaging = contractVerifierMessaging;
}

6
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/StubRunnerFactory.java
View File

@@ -21,7 +21,7 @@ import java.util.ArrayList;
import java.util.Collection;
import java.util.Map;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
/**
* Factory of StubRunners. Basing on the options and passed collaborators downloads the
@@ -31,11 +31,11 @@ public class StubRunnerFactory {
private final StubRunnerOptions stubRunnerOptions;
private final StubDownloader stubDownloader;
private final StubMessages<?> contractVerifierMessaging;
private final MessageVerifier<?> contractVerifierMessaging;
public StubRunnerFactory(StubRunnerOptions stubRunnerOptions,
StubDownloader stubDownloader,
StubMessages<?> contractVerifierMessaging) {
MessageVerifier<?> contractVerifierMessaging) {
this.stubRunnerOptions = stubRunnerOptions;
this.stubDownloader = stubDownloader;
this.contractVerifierMessaging = contractVerifierMessaging;

6
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/server/StubRunnerBackupAutoConfiguration.java
View File

@@ -17,7 +17,7 @@
package org.springframework.cloud.contract.stubrunner.server;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierMessaging;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpStubMessages;
import org.springframework.context.annotation.Bean;
@@ -31,13 +31,13 @@ public class StubRunnerBackupAutoConfiguration {
@Bean
@ConditionalOnMissingBean
public StubMessages<?> contractVerifierMessageExchange() {
public MessageVerifier<?> contractVerifierMessageExchange() {
return new NoOpStubMessages();
}
@Bean
public ContractVerifierMessaging<Object> contractVerifierMessaging(
StubMessages<Object> exchange) {
MessageVerifier<Object> exchange) {
return new ContractVerifierMessaging<Object>(exchange);
}

4
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/spring/AutoConfigureStubRunner.java
View File

@@ -23,7 +23,7 @@ import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages;
import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier;
/**
* @author Dave Syer
@@ -33,7 +33,7 @@ import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureS
@Retention(RetentionPolicy.RUNTIME)
@Documented
@ImportAutoConfiguration
@AutoConfigureStubMessages
@AutoConfigureMessageVerifier
public @interface AutoConfigureStubRunner {
}

4
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/spring/StubRunnerConfiguration.java
View File

@@ -28,7 +28,7 @@ import org.springframework.cloud.contract.stubrunner.StubDownloader;
import org.springframework.cloud.contract.stubrunner.StubRunner;
import org.springframework.cloud.contract.stubrunner.StubRunnerOptions;
import org.springframework.cloud.contract.stubrunner.StubRunnerOptionsBuilder;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.noop.NoOpStubMessages;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@@ -44,7 +44,7 @@ import org.springframework.core.io.Resource;
public class StubRunnerConfiguration {
@Autowired(required = false)
private StubMessages<?> contractVerifierMessaging;
private MessageVerifier<?> contractVerifierMessaging;
@Autowired(required = false)
private StubDownloader stubDownloader;
@Autowired

4
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner/src/test/groovy/org/springframework/cloud/contract/stubrunner/StubRunnerExecutorSpec.groovy
View File

@@ -21,7 +21,7 @@ import groovy.json.JsonOutput
import java.util.concurrent.TimeUnit
import org.springframework.cloud.contract.stubrunner.util.StubsParser
import org.springframework.cloud.contract.verifier.messaging.StubMessages
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
import spock.lang.Specification
@@ -99,7 +99,7 @@ class StubRunnerExecutorSpec extends Specification {
}
}
private class AssertingStubMessages implements StubMessages<Object> {
private class AssertingStubMessages implements MessageVerifier<Object> {
@Override
public void send(Object message, String destination) {

4
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-camel/src/main/java/org/springframework/cloud/contract/verifier/messaging/camel/CamelStubMessages.java
View File

@@ -28,7 +28,7 @@ import org.apache.camel.impl.DefaultExchange;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.stereotype.Component;
/**
@@ -36,7 +36,7 @@ import org.springframework.stereotype.Component;
*/
@Component
public class CamelStubMessages implements
StubMessages<Message> {
MessageVerifier<Message> {
private static final Logger log = LoggerFactory.getLogger(
CamelStubMessages.class);

8
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-camel/src/main/java/org/springframework/cloud/contract/verifier/messaging/camel/ContractVerifierCamelConfiguration.java
View File

@@ -19,7 +19,7 @@ package org.springframework.cloud.contract.verifier.messaging.camel;
import org.apache.camel.CamelContext;
import org.apache.camel.Message;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
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;
@@ -34,14 +34,14 @@ import org.springframework.context.annotation.Configuration;
public class ContractVerifierCamelConfiguration {
@Bean
StubMessages<Message> contractVerifierMessageExchange(
MessageVerifier<Message> contractVerifierMessageExchange(
CamelContext context) {
return new CamelStubMessages(context);
}
@Bean
public ContractVerifierMessaging<Message> contractVerifierMessaging(
StubMessages<Message> exchange) {
MessageVerifier<Message> exchange) {
return new ContractVerifierCamelHelper(exchange);
}
}
@@ -49,7 +49,7 @@ public class ContractVerifierCamelConfiguration {
class ContractVerifierCamelHelper extends ContractVerifierMessaging<Message> {
public ContractVerifierCamelHelper(
StubMessages<Message> exchange) {
MessageVerifier<Message> exchange) {
super(exchange);
}

2
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-camel/src/main/resources/META-INF/spring.factories
View File

@@ -1,3 +1,3 @@
# Auto Configuration
org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages=\
org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier=\
org.springframework.cloud.contract.verifier.messaging.camel.ContractVerifierCamelConfiguration

8
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-integration/src/main/java/org/springframework/cloud/contract/verifier/messaging/integration/ContractVerifierIntegrationConfiguration.java
View File

@@ -17,7 +17,7 @@
package org.springframework.cloud.contract.verifier.messaging.integration;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
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;
@@ -34,21 +34,21 @@ import org.springframework.messaging.Message;
public class ContractVerifierIntegrationConfiguration<T> {
@Bean
public StubMessages<Message<?>> contractVerifierMessageExchange(
public MessageVerifier<Message<?>> contractVerifierMessageExchange(
ApplicationContext applicationContext) {
return new SpringIntegrationStubMessages(applicationContext);
}
@Bean
public ContractVerifierMessaging<Message<?>> contractVerifierMessaging(
StubMessages<Message<?>> exchange) {
MessageVerifier<Message<?>> exchange) {
return new ContractVerifierHelper(exchange);
}
}
class ContractVerifierHelper extends ContractVerifierMessaging<Message<?>> {
public ContractVerifierHelper(StubMessages<Message<?>> exchange) {
public ContractVerifierHelper(MessageVerifier<Message<?>> exchange) {
super(exchange);
}

4
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-integration/src/main/java/org/springframework/cloud/contract/verifier/messaging/integration/SpringIntegrationStubMessages.java
View File

@@ -22,7 +22,7 @@ import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.context.ApplicationContext;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
@@ -34,7 +34,7 @@ import org.springframework.stereotype.Component;
*/
@Component
public class SpringIntegrationStubMessages implements
StubMessages<Message<?>> {
MessageVerifier<Message<?>> {
private static final Logger log = LoggerFactory.getLogger(
SpringIntegrationStubMessages.class);

2
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-integration/src/main/resources/META-INF/spring.factories
View File

@@ -1,3 +1,3 @@
# Auto Configuration
org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages=\
org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier=\
org.springframework.cloud.contract.verifier.messaging.integration.ContractVerifierIntegrationConfiguration

2
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/StubMessages.java → spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/MessageVerifier.java
View File

@@ -26,7 +26,7 @@ import java.util.concurrent.TimeUnit;
*
* @author Marcin Grzejszczak
*/
public interface StubMessages<M> {
public interface MessageVerifier<M> {
/**
* Sends the {@link ContractVerifierMessage} to the given destination.
*/

2
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/boot/AutoConfigureStubMessages.java → spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/boot/AutoConfigureMessageVerifier.java
View File

@@ -32,6 +32,6 @@ import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
@Retention(RetentionPolicy.RUNTIME)
@Documented
@ImportAutoConfiguration
public @interface AutoConfigureStubMessages {
public @interface AutoConfigureMessageVerifier {
}

6
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/internal/ContractVerifierMessaging.java
View File

@@ -18,7 +18,7 @@ package org.springframework.cloud.contract.verifier.messaging.internal;
import java.util.Map;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
/**
* @author Dave Syer
@@ -26,9 +26,9 @@ import org.springframework.cloud.contract.verifier.messaging.StubMessages;
*/
public class ContractVerifierMessaging<M> {
private StubMessages<M> exchange;
private MessageVerifier<M> exchange;
public ContractVerifierMessaging(StubMessages<M> exchange) {
public ContractVerifierMessaging(MessageVerifier<M> exchange) {
this.exchange = exchange;
}

6
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/noop/NoOpContractVerifierAutoConfiguration.java
View File

@@ -18,7 +18,7 @@ package org.springframework.cloud.contract.verifier.messaging.noop;
import org.springframework.boot.autoconfigure.AutoConfigureOrder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierMessaging;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@@ -33,14 +33,14 @@ public class NoOpContractVerifierAutoConfiguration {
@Bean
@ConditionalOnMissingBean
public StubMessages<?> contractVerifierMessageExchange() {
public MessageVerifier<?> contractVerifierMessageExchange() {
return new NoOpStubMessages();
}
@Bean
@ConditionalOnMissingBean
public ContractVerifierMessaging<?> contractVerifierMessaging(
StubMessages<Object> exchange) {
MessageVerifier<Object> exchange) {
return new ContractVerifierMessaging<Object>(exchange);
}

4
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-messaging-core/src/main/java/org/springframework/cloud/contract/verifier/messaging/noop/NoOpStubMessages.java
View File

@@ -19,12 +19,12 @@ package org.springframework.cloud.contract.verifier.messaging.noop;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
/**
* @author Marcin Grzejszczak
*/
public class NoOpStubMessages implements StubMessages<Object> {
public class NoOpStubMessages implements MessageVerifier<Object> {
@Override
public void send(Object message, String destination) {
}

8
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-stream/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/ContractVerifierStreamAutoConfiguration.java
View File

@@ -18,7 +18,7 @@ package org.springframework.cloud.contract.verifier.messaging.stream;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
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;
@@ -36,14 +36,14 @@ import org.springframework.messaging.Message;
public class ContractVerifierStreamAutoConfiguration {
@Bean
StubMessages<Message<?>> contractVerifierMessageExchange(
MessageVerifier<Message<?>> contractVerifierMessageExchange(
ApplicationContext applicationContext) {
return new StreamStubMessages(applicationContext);
}
@Bean
public ContractVerifierMessaging<?> contractVerifierMessagingConverter(
StubMessages<Message<?>> exchange) {
MessageVerifier<Message<?>> exchange) {
return new ContractVerifierHelper(exchange);
}
}
@@ -51,7 +51,7 @@ public class ContractVerifierStreamAutoConfiguration {
class ContractVerifierHelper extends ContractVerifierMessaging<Message<?>> {
public ContractVerifierHelper(
StubMessages<Message<?>> exchange) {
MessageVerifier<Message<?>> exchange) {
super(exchange);
}

4
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-stream/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java
View File

@@ -22,7 +22,7 @@ import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.contract.verifier.messaging.StubMessages;
import org.springframework.cloud.contract.verifier.messaging.MessageVerifier;
import org.springframework.cloud.stream.config.BindingProperties;
import org.springframework.cloud.stream.config.ChannelBindingServiceProperties;
import org.springframework.cloud.stream.test.binder.MessageCollector;
@@ -33,7 +33,7 @@ import org.springframework.messaging.MessageChannel;
/**
* @author Marcin Grzejszczak
*/
public class StreamStubMessages implements StubMessages<Message<?>> {
public class StreamStubMessages implements MessageVerifier<Message<?>> {
private static final Logger log = LoggerFactory.getLogger(StreamStubMessages.class);

2
spring-cloud-contract-verifier/spring-cloud-contract-verifier-messaging/spring-cloud-contract-verifier-stream/src/main/resources/META-INF/spring.factories
View File

@@ -1,3 +1,3 @@
# Auto Configuration
org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureStubMessages=\
org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier=\
org.springframework.cloud.contract.verifier.messaging.stream.ContractVerifierStreamAutoConfiguration