Merge branch 'pact-message-provider'

Author: thombergs

pact/pact-message-consumer/src/main/java/io/reflectoring/MessageConsumerConfiguration.java

@@ -47,13 +47,13 @@ public SimpleMessageListenerContainer container(ConnectionFactory connectionFact
 	}
 
 	@Bean
-	public MessageListenerAdapter listenerAdapter(StringMessageConsumer stringMessageConsumer) {
-		return new MessageListenerAdapter(stringMessageConsumer, "consumeStringMessage");
+	public MessageListenerAdapter listenerAdapter(UserCreatedMessageConsumer userCreatedMessageConsumer) {
+		return new MessageListenerAdapter(userCreatedMessageConsumer, "consumeStringMessage");
 	}
 
 	@Bean
-	public StringMessageConsumer eventReceiver(ObjectMapper objectMapper) {
-		return new StringMessageConsumer(objectMapper);
+	public UserCreatedMessageConsumer eventReceiver(ObjectMapper objectMapper) {
+		return new UserCreatedMessageConsumer(objectMapper);
 	}
 
 }

pact/pact-message-consumer/src/main/java/io/reflectoring/StringMessageConsumer.java renamed to pact/pact-message-consumer/src/main/java/io/reflectoring/UserCreatedMessageConsumer.java

@@ -13,13 +13,13 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class StringMessageConsumer {
+public class UserCreatedMessageConsumer {
 
-  private Logger logger = LoggerFactory.getLogger(StringMessageConsumer.class);
+  private Logger logger = LoggerFactory.getLogger(UserCreatedMessageConsumer.class);
 
   private ObjectMapper objectMapper;
 
-  public StringMessageConsumer(ObjectMapper objectMapper) {
+  public UserCreatedMessageConsumer(ObjectMapper objectMapper) {
     this.objectMapper = objectMapper;
   }
 
@@ -31,7 +31,7 @@ public void consumeStringMessage(String messageString) throws IOException {
     if(!violations.isEmpty()){
       throw new ConstraintViolationException(violations);
     }
-    // do something with the message
+    // pass message into business use case
   }
 
 }

pact/pact-message-consumer/src/test/java/io/reflectoring/StringMessageConsumerTest.java renamed to pact/pact-message-consumer/src/test/java/io/reflectoring/UserCreatedMessageConsumerTest.java

@@ -17,16 +17,16 @@
 
 @RunWith(SpringRunner.class)
 @SpringBootTest
-public class StringMessageConsumerTest {
+public class UserCreatedMessageConsumerTest {
 
 	@Rule
 	public MessagePactProviderRule mockProvider = new MessagePactProviderRule(this);
 	private byte[] currentMessage;
 
 	@Autowired
-	private StringMessageConsumer stringMessageConsumer;
+	private UserCreatedMessageConsumer userCreatedMessageConsumer;
 
-	@Pact(state = "provider is up and running", provider = "userservice", consumer = "userclient")
+	@Pact(provider = "userservice", consumer = "userclient")
 	public MessagePact userCreatedMessagePact(MessagePactBuilder builder) {
 		PactDslJsonBody body = new PactDslJsonBody();
 		body.stringType("messageUuid");
@@ -46,7 +46,7 @@ public MessagePact userCreatedMessagePact(MessagePactBuilder builder) {
 	@Test
 	@PactVerification("userCreatedMessagePact")
 	public void verifyCreatePersonPact() throws IOException {
-		stringMessageConsumer.consumeStringMessage(new String(this.currentMessage));
+		userCreatedMessageConsumer.consumeStringMessage(new String(this.currentMessage));
 	}
 
 	/**

pact/pact-message-provider/.gitignore

@@ -0,0 +1,25 @@
+.gradle
+/build/
+!gradle/wrapper/gradle-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+nbproject/private/
+build/
+nbbuild/
+dist/
+nbdist/
+.nb-gradle/

pact/pact-message-provider/README.md

@@ -0,0 +1,15 @@
+# Consumer-Driven-Contract Test for a Spring Boot Provider
+ 
+This repo contains an example of consumer-driven-contract testing for a Spring
+Boot API provider. The corresponding consumer to the contract is
+implemented in the module `pact-angular`.
+
+The contract is created and verified with [Pact](https://docs.pact.io/).
+
+Before running the build, you need to follow the instructions on the [consumer-side](../pact-angular/)
+to create the consumer-driven contract file (pact file).
+
+## Running the application
+
+The interesting part in this code base is the class `UserControllerProviderTest`.
+You can run the tests with `gradlew test` on Windows or `./gradlew test` on Unix.

pact/pact-message-provider/application.yml

@@ -0,0 +1,11 @@
+spring:
+  datasource:
+    url: jdbc:h2:mem:AZ;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE
+    driverClassName: org.h2.Driver
+    username: sa
+    password:
+  h2:
+    console:
+      enabled: true
+
+logging.level.org.hibernate.SQL: OFF

pact/pact-message-provider/build.gradle

@@ -0,0 +1,35 @@
+buildscript {
+    repositories {
+        mavenCentral()
+    }
+    dependencies {
+        classpath("org.springframework.boot:spring-boot-gradle-plugin:${springboot_version}")
+    }
+}
+
+apply plugin: 'java'
+apply plugin: 'eclipse'
+apply plugin: 'org.springframework.boot'
+apply plugin: 'io.spring.dependency-management'
+
+version = '0.0.1-SNAPSHOT'
+sourceCompatibility = 1.8
+
+repositories {
+    mavenLocal()
+    mavenCentral()
+}
+
+dependencies {
+    compile('org.springframework.boot:spring-boot-starter-data-jpa')
+    compile('org.springframework.boot:spring-boot-starter-web')
+    compile('org.springframework.boot:spring-boot-starter-amqp')
+    compile('com.h2database:h2:1.4.196')
+    compileOnly('org.projectlombok:lombok')
+    testCompile("au.com.dius:pact-jvm-provider-junit_2.12:${pact_version}")
+    testCompile('org.springframework.boot:spring-boot-starter-test')
+}
+
+bootRun {
+    jvmArgs = ["-Xdebug", "-Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005"]
+}

pact/pact-message-provider/gradle.properties

@@ -0,0 +1,2 @@
+springboot_version=2.0.4.RELEASE
+pact_version=3.5.20

pact/pact-message-provider/gradle/wrapper/gradle-wrapper.jar

@@ -0,0 +1,5 @@
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.2-bin.zip