renamed package

# Conflicts:
#	build-all.sh

.gitignore

@@ -0,0 +1,3 @@
+**/.idea/
+**/*.iml
+

.idea/libraries/Gradle__org_projectlombok_lombok_1_16_20.xml

@@ -1,11 +0,0 @@
-<component name="libraryTable">
-  <library name="Gradle: org.projectlombok:lombok:1.16.20">
-    <CLASSES>
-      <root url="jar://$USER_HOME$/.gradle/caches/modules-2/files-2.1/org.projectlombok/lombok/1.16.20/ac76d9b956045631d1561a09289cbf472e077c01/lombok-1.16.20.jar!/" />
-    </CLASSES>
-    <JAVADOC />
-    <SOURCES>
-      <root url="jar://$USER_HOME$/.gradle/caches/modules-2/files-2.1/org.projectlombok/lombok/1.16.20/69ebf81bb97bdb3c9581c171762bb4929cb5289c/lombok-1.16.20-sources.jar!/" />
-    </SOURCES>
-  </library>
-</component>

.idea/modules/spring-boot-testing.iml

@@ -1,13 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<module external.linked.project.id=":spring-boot:spring-boot-testing" external.linked.project.path="$MODULE_DIR$/../../spring-boot/spring-boot-testing" external.root.project.path="$MODULE_DIR$/../.." external.system.id="GRADLE" external.system.module.group="reflectoring.io" external.system.module.version="0.0.1-SNAPSHOT" type="JAVA_MODULE" version="4">
-  <component name="NewModuleRootManager" inherit-compiler-output="true">
-    <exclude-output />
-    <content url="file://$MODULE_DIR$/../../spring-boot/spring-boot-testing">
-      <excludeFolder url="file://$MODULE_DIR$/../../spring-boot/spring-boot-testing/.gradle" />
-      <excludeFolder url="file://$MODULE_DIR$/../../spring-boot/spring-boot-testing/build" />
-      <excludeFolder url="file://$MODULE_DIR$/../../spring-boot/spring-boot-testing/out" />
-    </content>
-    <orderEntry type="inheritedJdk" />
-    <orderEntry type="sourceFolder" forTests="false" />
-  </component>
-</module>

.travis.yml

@@ -1,5 +1,5 @@
 before_install:
- - chmod +x gradlew
+ - chmod +x build-all.sh
  - |
    if ! git diff --name-only $TRAVIS_COMMIT_RANGE | grep -qvE '(.md)|^(LICENSE)'
    then
@@ -7,7 +7,12 @@ before_install:
      exit
    fi
 
+install: skip
+
+script:
+  - ./build-all.sh
+
 language: java
 
 jdk:
-  - oraclejdk8
+  - oraclejdk11

README.md

@@ -2,7 +2,20 @@
 
 [![Travis CI Status](https://travis-ci.org/thombergs/code-examples.svg?branch=master)](https://travis-ci.org/thombergs/code-examples)
 
-This repo contains example projects which show how to use different java technologies.
+This repo contains example projects which show how to use different (not only) Java technologies.
 The examples are usually accompanied by a blog post on [https://reflectoring.io](https://reflectoring.io).
 
-See the READMEs in each subdirectory of this repo for more information. 
+See the READMEs in each subdirectory of this repo for more information on each module.
+
+## Java Modules
+All Java modules require **Java 11** to compile and run.
+
+### Building with Gradle
+
+Each module should be an independent build and can be built by calling `./gradlew clean build` in the module directory. 
+
+All modules are listed in [build-all.sh](build-all.sh) to run in the CI pipeline.
+
+### Non-Java Modules
+
+Some folders contain non-Java projects. For those, refer to the README within the module folder.

aws/aws-hello-world/.gitignore

@@ -0,0 +1,32 @@
+HELP.md
+.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**
+!**/src/test/**
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+out/
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/

aws/aws-hello-world/Dockerfile

@@ -0,0 +1,5 @@
+FROM openjdk:8-jdk-alpine
+ARG JAR_FILE=build/libs/*.jar
+COPY ${JAR_FILE} app.jar
+ENTRYPOINT ["java","-jar","/app.jar"]
+EXPOSE 8080

aws/aws-hello-world/build.gradle

@@ -0,0 +1,24 @@
+plugins {
+	id 'org.springframework.boot' version '2.2.4.RELEASE'
+	id 'io.spring.dependency-management' version '1.0.9.RELEASE'
+	id 'java'
+}
+
+group = 'io.reflectoring'
+version = '0.0.1-SNAPSHOT'
+sourceCompatibility = '1.8'
+
+repositories {
+	mavenCentral()
+}
+
+dependencies {
+	implementation 'org.springframework.boot:spring-boot-starter-web'
+	testImplementation('org.springframework.boot:spring-boot-starter-test') {
+		exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
+	}
+}
+
+test {
+	useJUnitPlatform()
+}

aws/aws-hello-world/gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,5 @@
-#Sun Jul 30 16:58:54 CEST 2017
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.0.1-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-4.2-all.zip

aws/aws-hello-world/gradlew

@@ -0,0 +1,172 @@
+#!/usr/bin/env sh
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn () {
+    echo "$*"
+}
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+  NONSTOP* )
+    nonstop=true
+    ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Escape application args
+save () {
+    for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+    echo " "
+}
+APP_ARGS=$(save "$@")
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong
+if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then
+  cd "$(dirname "$0")"
+fi
+
+exec "$JAVACMD" "$@"

aws/aws-hello-world/settings.gradle

@@ -0,0 +1 @@
+rootProject.name = 'aws-hello-world'

aws/aws-hello-world/src/main/java/io/reflectoring/awshelloworld/AwsHelloWorldApplication.java

@@ -0,0 +1,13 @@
+package io.reflectoring.awshelloworld;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class AwsHelloWorldApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(AwsHelloWorldApplication.class, args);
+	}
+
+}

aws/aws-hello-world/src/main/java/io/reflectoring/awshelloworld/HelloWorldController.java

@@ -0,0 +1,14 @@
+package io.reflectoring.awshelloworld;
+
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class HelloWorldController {
+
+  @GetMapping("/hello")
+  public String helloWorld(){
+    return "Hello AWS!";
+  }
+
+}

aws/aws-hello-world/src/main/resources/application.properties

@@ -0,0 +1 @@
+

aws/aws-hello-world/src/test/java/io/reflectoring/awshelloworld/AwsHelloWorldApplicationTests.java

@@ -0,0 +1,13 @@
+package io.reflectoring.awshelloworld;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class AwsHelloWorldApplicationTests {
+
+	@Test
+	void contextLoads() {
+	}
+
+}

aws/cloudformation/ecs-in-two-public-subnets/ecs-in-two-public-subnets.drawio

@@ -0,0 +1 @@
+<mxfile modified="2020-04-30T21:28:18.347Z" host="app.diagrams.net" agent="5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.149 Safari/537.36" etag="X9Eef2gSXNvxkCnmY-_0" version="13.0.4" type="device"><diagram id="Ht1M8jgEwFfnCIfOTk4-" name="Page-1">7Vpbb+o4EP41PC7K/fLIrWcr9UiVWO05+4RM4garIc4aU6C/fseJc7ND6ekB9nQXVKmZsTMez3yf7TEM7Ml6/4WhfPWVxjgdWEa8H9jTgWWZphXCP6E5lBrPcEpFwkgsOzWKOXnFUmlI7ZbEeNPpyClNOcm7yohmGY54R4cYo7tutyeadkfNUYI1xTxCqa79RmK+qublhU3D75gkKzl0YPllwxpVneVMNisU011LZc8G9oRRysun9X6CUxG8Ki7le3dHWmvHGM74e15Y4cjav97736avy2fP+Rr/vVj+Vjn3gtKtnPGfjxPpMD9UUcgpyXgRSXcMf/DSxBi40DIR0tByFYUq+12FqUvCRlehyn5XYarmTWV8U3WwpdCkjnlDGd9oOQh/9phueUoyPKkxZ4AyYSgmkIsJTSkDXUYziN54xdcpSCY87laE43mOIhHVHfAFdE804xL1plXJMvDiHUBNLp7X+0QQbIh2G2eYMLrNiyHvAfe9rYuXPBKvc0afceXSwLItJwhMRwxE0lRx9QUzTgD6o5QkwiqnYhAkpRQ/cWER/CdZ8lBIU9uQPreGGI3G/jgAfYw2KxzL8EicwRB4fxTBZs0LWFAwXWPODtClesGTaJVrSQXeXUNMO5S6VYuTjiGVSC4GSW264Qs8SMr8AH3MUKPP43aZkkjQZ7vMML9R6fNTaYOjLSP8sGg6zwteSXffRzLQz8I7e+adj2n1OOdmmm0pTLPCoR1obKsZ2Gab6ZkFSC5COPvGtxvf/vt8c4Buftj6uL8A90xfI99sMgfFHLMXAshQqddzxNBS5468SeC1Q2oezZcKMCU7talzJMTvJsTvXf9MuycHVnip04arxX9geamA7hIeEvEwynNYDREnwK2qjVWNDxTFuhZogLIIs6oFXKvNaSntXT46bKhS94CWOH2kG1L4Yk+XlHO6PsnFCBIEvnQWn56FxB6iZqaLFCa2WFbz0JaBOzdwbef4OncGvMAZs4MX0w+GgQ6Yqmps48W3LgSX4DRc7kWwi13TQ2uRhmy5yYuIqCj5gjjeocMnAwmR81sk0v1+bHgXxUa9SrSw4esL+lWxodct5VL+B9o8vy+f6tZoW3difC2OIsZ+MDPa/JsSBobKlGeUiQioeZka7gQ2nJ4d46n4XAFRp843aJOX4Xgie+FH/4GH4Q3dsgiXx50xiH0HHxxtzgO2utatwGb07lx+z8blX6xKdm5o+3+gzXL/fbRZeo2oYQzHCa6CKxBBE5qhdNZo25nBWTwSN8kivymNnoUqXRZyleYCOYjxqp/cPODNO5LWO5R29nXcsSeQCmVOFtfggtizw/e28JcQoKqT4nTfbpwe2tIjZgTiKNDVKk7EfN9OMYSnAM5bgZWbBkw0wfzUwUPHTPvgXOGG4RSOcC9d5/ogIc09imq+wV+owM9Uap9yTvKl9t24YsdU6i9bvTEs56wZKgBaT/EnMOvdMPsRzJ6Eons1KFrqUvhhLAYKFs0rY1Ev8z8ZFveEf6/GhucWEkFqgCiEQ0u44NLpvhOu5UnpKng1TfXKyfgYXq1Tho7gFXIt6sm6m7yoPeqw7fYT7JhfWv/QUehSenBe8vQV3TfyXIU84dW4Y1ff+9VfjzjDIDDqj2LwvUxyHLdr1hOn6aNmfxFemc41eKVfWLx1mfUp76isH7+dqn9T0nwtUv1KxT7TxaaS7MDvu7vyw6FUtks81zlOrCMlHojNL2JK8DS/K7Jn/wA=</diagram></mxfile>

aws/cloudformation/ecs-in-two-public-subnets/network.yml

@@ -0,0 +1,247 @@
+AWSTemplateFormatVersion: '2010-09-09'
+Description: A network stack for deploying containers in AWS ECS.
+  This stack creates a VPC with two public subnets and a loadbalancer to balance traffic between those subnets.
+  Derived from a template at https://github.com/nathanpeck/aws-cloudformation-fargate.
+Resources:
+
+  VPC:
+    Type: AWS::EC2::VPC
+    Properties:
+      CidrBlock: '10.0.0.0/16'
+
+  PublicSubnetOne:
+    Type: AWS::EC2::Subnet
+    Properties:
+      AvailabilityZone:
+        Fn::Select:
+          - 0
+          - Fn::GetAZs: {Ref: 'AWS::Region'}
+      VpcId: !Ref 'VPC'
+      CidrBlock: '10.0.1.0/24'
+      MapPublicIpOnLaunch: true
+
+  PublicSubnetTwo:
+    Type: AWS::EC2::Subnet
+    Properties:
+      AvailabilityZone:
+        Fn::Select:
+          - 1
+          - Fn::GetAZs: {Ref: 'AWS::Region'}
+      VpcId: !Ref 'VPC'
+      CidrBlock: '10.0.2.0/24'
+      MapPublicIpOnLaunch: true
+
+  InternetGateway:
+    Type: AWS::EC2::InternetGateway
+
+  GatewayAttachement:
+    Type: AWS::EC2::VPCGatewayAttachment
+    Properties:
+      VpcId: !Ref 'VPC'
+      InternetGatewayId: !Ref 'InternetGateway'
+
+  PublicRouteTable:
+    Type: AWS::EC2::RouteTable
+    Properties:
+      VpcId: !Ref 'VPC'
+
+  PublicSubnetOneRouteTableAssociation:
+    Type: AWS::EC2::SubnetRouteTableAssociation
+    Properties:
+      SubnetId: !Ref PublicSubnetOne
+      RouteTableId: !Ref PublicRouteTable
+
+  PublicSubnetTwoRouteTableAssociation:
+    Type: AWS::EC2::SubnetRouteTableAssociation
+    Properties:
+      SubnetId: !Ref PublicSubnetTwo
+      RouteTableId: !Ref PublicRouteTable
+
+  PublicRoute:
+    Type: AWS::EC2::Route
+    DependsOn: GatewayAttachement
+    Properties:
+      RouteTableId: !Ref 'PublicRouteTable'
+      DestinationCidrBlock: '0.0.0.0/0'
+      GatewayId: !Ref 'InternetGateway'
+
+  PublicLoadBalancerSecurityGroup:
+    Type: AWS::EC2::SecurityGroup
+    Properties:
+      GroupDescription: Access to the public facing load balancer
+      VpcId: !Ref 'VPC'
+      SecurityGroupIngress:
+        # Allow access to ALB from anywhere on the internet
+        - CidrIp: 0.0.0.0/0
+          IpProtocol: -1
+
+  PublicLoadBalancer:
+    Type: AWS::ElasticLoadBalancingV2::LoadBalancer
+    Properties:
+      Scheme: internet-facing
+      Subnets:
+        # The load balancer is placed into the public subnets, so that traffic
+        # from the internet can reach the load balancer directly via the internet gateway
+        - !Ref PublicSubnetOne
+        - !Ref PublicSubnetTwo
+      SecurityGroups: [!Ref 'PublicLoadBalancerSecurityGroup']
+
+  DummyTargetGroupPublic:
+    Type: AWS::ElasticLoadBalancingV2::TargetGroup
+    Properties:
+      HealthCheckIntervalSeconds: 6
+      HealthCheckPath: /
+      HealthCheckProtocol: HTTP
+      HealthCheckTimeoutSeconds: 5
+      HealthyThresholdCount: 2
+      Name: "no-op"
+      Port: 80
+      Protocol: HTTP
+      UnhealthyThresholdCount: 2
+      VpcId: !Ref 'VPC'
+
+  PublicLoadBalancerListener:
+    Type: AWS::ElasticLoadBalancingV2::Listener
+    DependsOn:
+      - PublicLoadBalancer
+    Properties:
+      DefaultActions:
+        - TargetGroupArn: !Ref 'DummyTargetGroupPublic'
+          Type: 'forward'
+      LoadBalancerArn: !Ref 'PublicLoadBalancer'
+      Port: 80
+      Protocol: HTTP
+
+  ECSCluster:
+    Type: AWS::ECS::Cluster
+
+  ECSSecurityGroup:
+    Type: AWS::EC2::SecurityGroup
+    Properties:
+      GroupDescription: Access to the ECS containers
+      VpcId: !Ref 'VPC'
+
+  ECSSecurityGroupIngressFromPublicALB:
+    Type: AWS::EC2::SecurityGroupIngress
+    Properties:
+      Description: Ingress from the public ALB
+      GroupId: !Ref 'ECSSecurityGroup'
+      IpProtocol: -1
+      SourceSecurityGroupId: !Ref 'PublicLoadBalancerSecurityGroup'
+
+  ECSSecurityGroupIngressFromSelf:
+    Type: AWS::EC2::SecurityGroupIngress
+    Properties:
+      Description: Ingress from other containers in the same security group
+      GroupId: !Ref 'ECSSecurityGroup'
+      IpProtocol: -1
+      SourceSecurityGroupId: !Ref 'ECSSecurityGroup'
+
+  ECSRole:
+    Type: AWS::IAM::Role
+    Properties:
+      AssumeRolePolicyDocument:
+        Statement:
+          - Effect: Allow
+            Principal:
+              Service: [ecs.amazonaws.com]
+            Action: ['sts:AssumeRole']
+      Path: /
+      Policies:
+        - PolicyName: ecs-service
+          PolicyDocument:
+            Statement:
+              - Effect: Allow
+                Action:
+                  # Rules which allow ECS to attach network interfaces to instances
+                  # on your behalf in order for awsvpc networking mode to work right
+                  - 'ec2:AttachNetworkInterface'
+                  - 'ec2:CreateNetworkInterface'
+                  - 'ec2:CreateNetworkInterfacePermission'
+                  - 'ec2:DeleteNetworkInterface'
+                  - 'ec2:DeleteNetworkInterfacePermission'
+                  - 'ec2:Describe*'
+                  - 'ec2:DetachNetworkInterface'
+
+                  # Rules which allow ECS to update load balancers on your behalf
+                  # with the information sabout how to send traffic to your containers
+                  - 'elasticloadbalancing:DeregisterInstancesFromLoadBalancer'
+                  - 'elasticloadbalancing:DeregisterTargets'
+                  - 'elasticloadbalancing:Describe*'
+                  - 'elasticloadbalancing:RegisterInstancesWithLoadBalancer'
+                  - 'elasticloadbalancing:RegisterTargets'
+                Resource: '*'
+
+  ECSTaskExecutionRole:
+    Type: AWS::IAM::Role
+    Properties:
+      AssumeRolePolicyDocument:
+        Statement:
+          - Effect: Allow
+            Principal:
+              Service: [ecs-tasks.amazonaws.com]
+            Action: ['sts:AssumeRole']
+      Path: /
+      Policies:
+        - PolicyName: AmazonECSTaskExecutionRolePolicy
+          PolicyDocument:
+            Statement:
+              - Effect: Allow
+                Action:
+                  # Allow the ECS Tasks to download images from ECR
+                  - 'ecr:GetAuthorizationToken'
+                  - 'ecr:BatchCheckLayerAvailability'
+                  - 'ecr:GetDownloadUrlForLayer'
+                  - 'ecr:BatchGetImage'
+
+                  # Allow the ECS tasks to upload logs to CloudWatch
+                  - 'logs:CreateLogStream'
+                  - 'logs:PutLogEvents'
+                Resource: '*'
+
+Outputs:
+  ClusterName:
+    Description: The name of the ECS cluster
+    Value: !Ref 'ECSCluster'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'ClusterName' ] ]
+  ExternalUrl:
+    Description: The url of the external load balancer
+    Value: !Join ['', ['http://', !GetAtt 'PublicLoadBalancer.DNSName']]
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'ExternalUrl' ] ]
+  ECSRole:
+    Description: The ARN of the ECS role
+    Value: !GetAtt 'ECSRole.Arn'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'ECSRole' ] ]
+  ECSTaskExecutionRole:
+    Description: The ARN of the ECS role
+    Value: !GetAtt 'ECSTaskExecutionRole.Arn'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'ECSTaskExecutionRole' ] ]
+  PublicListener:
+    Description: The ARN of the public load balancer's Listener
+    Value: !Ref PublicLoadBalancerListener
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'PublicListener' ] ]
+  VPCId:
+    Description: The ID of the VPC that this stack is deployed in
+    Value: !Ref 'VPC'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'VPCId' ] ]
+  PublicSubnetOne:
+    Description: Public subnet one
+    Value: !Ref 'PublicSubnetOne'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'PublicSubnetOne' ] ]
+  PublicSubnetTwo:
+    Description: Public subnet two
+    Value: !Ref 'PublicSubnetTwo'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'PublicSubnetTwo' ] ]
+  ECSSecurityGroup:
+    Description: A security group used to allow ECS containers to receive traffic
+    Value: !Ref 'ECSSecurityGroup'
+    Export:
+      Name: !Join [ ':', [ !Ref 'AWS::StackName', 'ECSSecurityGroup' ] ]

aws/cloudformation/ecs-in-two-public-subnets/service.yml

@@ -0,0 +1,133 @@
+AWSTemplateFormatVersion: '2010-09-09'
+Description: Deploy a service on AWS Fargate, hosted in two public subnets and accessible via a public load balancer.
+  Derived from a template at https://github.com/nathanpeck/aws-cloudformation-fargate.
+Parameters:
+  StackName:
+    Type: String
+    Description: The name of the networking stack that
+      these resources are put into.
+  ServiceName:
+    Type: String
+    Description: A human-readable name for the service.
+  HealthCheckPath:
+    Type: String
+    Default: /health
+    Description: Path to perform the healthcheck on each instance.
+  HealthCheckIntervalSeconds:
+    Type: Number
+    Default: 5
+    Description: Number of seconds to wait between each health check.
+  ImageUrl:
+    Type: String
+    Description: The url of a docker image that will handle incoming traffic.
+  ContainerPort:
+    Type: Number
+    Default: 80
+    Description: The port number the application inside the docker container
+      is binding to.
+  ContainerCpu:
+    Type: Number
+    Default: 256
+    Description: How much CPU to give the container. 1024 is 1 CPU.
+  ContainerMemory:
+    Type: Number
+    Default: 512
+    Description: How much memory in megabytes to give the container.
+  Path:
+    Type: String
+    Default: "*"
+    Description: A path on the public load balancer that this service
+      should be connected to.
+  DesiredCount:
+    Type: Number
+    Default: 2
+    Description: How many copies of the service task to run.
+
+Resources:
+
+  TargetGroup:
+    Type: AWS::ElasticLoadBalancingV2::TargetGroup
+    Properties:
+      HealthCheckIntervalSeconds: !Ref 'HealthCheckIntervalSeconds'
+      HealthCheckPath: !Ref 'HealthCheckPath'
+      HealthCheckProtocol: HTTP
+      HealthCheckTimeoutSeconds: 5
+      HealthyThresholdCount: 2
+      TargetType: ip
+      Name: !Ref 'ServiceName'
+      Port: !Ref 'ContainerPort'
+      Protocol: HTTP
+      UnhealthyThresholdCount: 2
+      VpcId:
+        Fn::ImportValue:
+          !Join [':', [!Ref 'StackName', 'VPCId']]
+
+  LoadBalancerRule:
+    Type: AWS::ElasticLoadBalancingV2::ListenerRule
+    Properties:
+      Actions:
+        - TargetGroupArn: !Ref 'TargetGroup'
+          Type: 'forward'
+      Conditions:
+        - Field: path-pattern
+          Values: [!Ref 'Path']
+      ListenerArn:
+        Fn::ImportValue:
+          !Join [':', [!Ref 'StackName', 'PublicListener']]
+      Priority: 1
+
+  TaskDefinition:
+    Type: AWS::ECS::TaskDefinition
+    Properties:
+      Family: !Ref 'ServiceName'
+      Cpu: !Ref 'ContainerCpu'
+      Memory: !Ref 'ContainerMemory'
+      NetworkMode: awsvpc
+      RequiresCompatibilities:
+        - FARGATE
+      ExecutionRoleArn:
+        Fn::ImportValue:
+          !Join [':', [!Ref 'StackName', 'ECSTaskExecutionRole']]
+      ContainerDefinitions:
+        - Name: !Ref 'ServiceName'
+          Cpu: !Ref 'ContainerCpu'
+          Memory: !Ref 'ContainerMemory'
+          Image: !Ref 'ImageUrl'
+          PortMappings:
+            - ContainerPort: !Ref 'ContainerPort'
+          LogConfiguration:
+            LogDriver: 'awslogs'
+            Options:
+              awslogs-group: !Ref 'ServiceName'
+              awslogs-region: !Ref AWS::Region
+              awslogs-stream-prefix: !Ref 'ServiceName'
+
+  Service:
+    Type: AWS::ECS::Service
+    DependsOn: LoadBalancerRule
+    Properties:
+      ServiceName: !Ref 'ServiceName'
+      Cluster:
+        Fn::ImportValue:
+          !Join [':', [!Ref 'StackName', 'ClusterName']]
+      LaunchType: FARGATE
+      DeploymentConfiguration:
+        MaximumPercent: 200
+        MinimumHealthyPercent: 50
+      DesiredCount: !Ref 'DesiredCount'
+      NetworkConfiguration:
+        AwsvpcConfiguration:
+          AssignPublicIp: ENABLED
+          SecurityGroups:
+            - Fn::ImportValue:
+                !Join [':', [!Ref 'StackName', 'ECSSecurityGroup']]
+          Subnets:
+            - Fn::ImportValue:
+                !Join [':', [!Ref 'StackName', 'PublicSubnetOne']]
+            - Fn::ImportValue:
+                !Join [':', [!Ref 'StackName', 'PublicSubnetTwo']]
+      TaskDefinition: !Ref 'TaskDefinition'
+      LoadBalancers:
+        - ContainerName: !Ref 'ServiceName'
+          ContainerPort: !Ref 'ContainerPort'
+          TargetGroupArn: !Ref 'TargetGroup'

build-all.sh

@@ -0,0 +1,101 @@
+#!/bin/bash
+
+MAIN_DIR=$PWD
+
+build_gradle_module() {
+  MODULE_PATH=$1
+  echo ""
+  echo "+++"
+  echo "+++ BUILDING MODULE $MODULE_PATH"
+  echo "+++"
+  cd $MODULE_PATH && {
+    chmod +x gradlew
+    ./gradlew clean build
+    if [ $? -ne 0 ]
+    then
+      echo ""
+      echo "+++"
+      echo "+++ BUILDING MODULE $MODULE_PATH FAILED"
+      echo "+++"
+      exit 1
+    else
+      echo ""
+      echo "+++"
+      echo "+++ BUILDING MODULE $MODULE_PATH SUCCESSFUL"
+      echo "+++"
+    fi
+    cd $MAIN_DIR
+  }
+}
+
+build_maven_module() {
+  MODULE_PATH=$1
+  echo ""
+  echo "+++"
+  echo "+++ BUILDING MODULE $MODULE_PATH"
+  echo "+++"
+  cd $MODULE_PATH && {
+    chmod +x mvnw
+    ./mvnw clean package
+    if [ $? -ne 0 ]
+    then
+      echo ""
+      echo "+++"
+      echo "+++ BUILDING MODULE $MODULE_PATH FAILED"
+      echo "+++"
+      exit 1
+    else
+      echo ""
+      echo "+++"
+      echo "+++ BUILDING MODULE $MODULE_PATH SUCCESSFUL"
+      echo "+++"
+    fi
+    cd $MAIN_DIR
+  }
+}
+
+build_maven_module "spring-boot/dependency-injection"
+build_maven_module "spring-boot/spring-boot-openapi"
+build_maven_module "spring-boot/data-migration/liquibase"
+build_gradle_module "spring-boot/boundaries"
+build_gradle_module "spring-boot/argumentresolver"
+build_gradle_module "spring-data/spring-data-jdbc-converter"
+build_gradle_module "solid"
+build_gradle_module "spring-boot/data-migration/flyway"
+build_gradle_module "reactive"
+build_gradle_module "junit/assumptions"
+build_gradle_module "logging"
+build_gradle_module "pact/pact-feign-consumer"
+# currently disabled since the consumer build won't run
+# build_gradle_module "pact/pact-message-consumer"
+# build_gradle_module "pact/pact-message-producer"
+build_gradle_module "pact/pact-spring-provider"
+build_gradle_module "patterns"
+build_gradle_module "spring-boot/conditionals"
+build_gradle_module "spring-boot/configuration"
+build_gradle_module "spring-boot/mocking"
+build_gradle_module "spring-boot/modular"
+build_gradle_module "spring-boot/paging"
+build_gradle_module "spring-boot/rabbitmq-event-brokering"
+build_gradle_module "spring-boot/spring-boot-logging"
+build_gradle_module "spring-boot/spring-boot-testing"
+build_gradle_module "spring-boot/starter"
+build_gradle_module "spring-boot/startup"
+build_gradle_module "spring-boot/static"
+build_gradle_module "spring-boot/validation"
+build_gradle_module "spring-boot/profiles"
+build_gradle_module "spring-boot/password-encoding"
+build_gradle_module "spring-boot/testcontainers"
+build_gradle_module "spring-cloud/feign-with-spring-data-rest"
+build_gradle_module "spring-cloud/sleuth-downstream-service"
+build_gradle_module "spring-cloud/sleuth-upstream-service"
+build_gradle_module "spring-cloud/spring-cloud-contract-consumer"
+build_gradle_module "spring-cloud/spring-cloud-contract-provider"
+build_gradle_module "spring-data/spring-data-rest-associations"
+build_gradle_module "spring-data/spring-data-rest-springfox"
+build_gradle_module "tools/jacoco"
+
+echo ""
+echo "+++"
+echo "+++ ALL MODULES SUCCESSFUL"
+echo "+++"

junit/assumptions/build.gradle

@@ -7,7 +7,7 @@ buildscript {
 apply plugin: 'java'
 
 version = '0.0.1-SNAPSHOT'
-sourceCompatibility = 1.8
+sourceCompatibility = 11
 
 repositories {
 	mavenLocal()
@@ -23,3 +23,6 @@ dependencies {
 	testCompile 'junit:junit:4.12'
 }
 
+test {
+	useJUnitPlatform()
+}

junit/assumptions/gradle/wrapper/gradle-wrapper.properties

@@ -2,4 +2,4 @@ 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
+distributionUrl=https\://services.gradle.org/distributions/gradle-5.6.4-bin.zip

logging/gradle/wrapper/gradle-wrapper.properties

@@ -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.10.1-bin.zip

logging/src/test/java/io/reflectoring/logging/TruncatedLoggerConverter.java

@@ -1,27 +0,0 @@
-package io.reflectoring.logging;
-
-import java.util.stream.Collectors;
-import java.util.stream.Stream;
-
-import ch.qos.logback.classic.pattern.LoggerConverter;
-import ch.qos.logback.classic.spi.ILoggingEvent;
-
-public class TruncatedLoggerConverter extends LoggerConverter {
-
-	@Override
-	public String convert(ILoggingEvent event) {
-		String maxLengthString = getFirstOption();
-		int maxLength = Integer.parseInt(maxLengthString);
-		String loggerName = super.convert(event);
-		if (loggerName.length() <= maxLength) {
-			return loggerName + generateSpaces(maxLength - loggerName.length());
-		} else {
-			return "..." + loggerName.substring(loggerName.length() - maxLength + 3);
-		}
-	}
-
-	private String generateSpaces(int count) {
-		return Stream.generate(() -> " ").limit(count).collect(Collectors.joining());
-	}
-
-}

logging/src/test/java/io/reflectoring/logging/TruncatedThreadConverter.java

@@ -1,28 +0,0 @@
-package io.reflectoring.logging;
-
-import java.util.stream.Collectors;
-import java.util.stream.Stream;
-
-import ch.qos.logback.classic.pattern.ClassicConverter;
-import ch.qos.logback.classic.spi.ILoggingEvent;
-
-public class TruncatedThreadConverter extends ClassicConverter {
-
-	@Override
-	public String convert(ILoggingEvent event) {
-		String maxLengthString = getFirstOption();
-		int maxLength = Integer.parseInt(maxLengthString);
-		String threadName = event.getThreadName();
-
-		if (threadName.length() <= maxLength) {
-			return threadName + generateSpaces(maxLength - threadName.length());
-		} else {
-			return "..." + threadName.substring(threadName.length() - maxLength + 3);
-		}
-	}
-
-	private String generateSpaces(int count) {
-		return Stream.generate(() -> " ").limit(count).collect(Collectors.joining());
-	}
-
-}

logging/src/test/resources/logback.xml

@@ -10,7 +10,7 @@
     <!-- Appender to log to console -->
     <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
         <encoder>
-            <pattern>%d{yyyy-MM-dd} | %d{HH:mm:ss.SSS} | %truncatedThread{20} | %5p | %truncatedLogger{25} | %12(ID: %8mdc{id}) | %m%n</pattern>
+            <pattern>%d{yyyy-MM-dd} | %d{HH:mm:ss.SSS} | %-20.20thread | %5p | %-25.25logger{25} | %12(ID: %8mdc{id}) | %m%n</pattern>
             <charset>utf8</charset>
         </encoder>
     </appender>

pact/pact-angular/README.md

@@ -4,6 +4,9 @@ This example project shows how to setup an Angular application to use [Pact](htt
 in order to create Pact files from a consumer test and validate the
 a consumer against the Pact.
 
+## Relevant Blog Post
+[Creating a Consumer-Driven Contract with Angular and Pact](https://reflectoring.io/consumer-driven-contracts-with-angular-and-pact/)
+
 ## Key Files
 
 * [`user.service.ts`](src/app/user.service.ts): Angular service that calls a REST

pact/pact-feign-consumer/application.yml

@@ -1,5 +0,0 @@
-userservice:
-  ribbon:
-    eureka:
-      enabled: false
-    listOfServers: localhost:8080

pact/pact-feign-consumer/build.gradle

@@ -1,5 +1,3 @@
-apply plugin: 'org.springframework.boot'
-
 buildscript {
     repositories {
         mavenLocal()
@@ -10,18 +8,56 @@ buildscript {
     }
 }
 
+plugins {
+    id "au.com.dius.pact" version "3.5.20"
+}
+
+apply plugin: 'java'
+apply plugin: 'org.springframework.boot'
+apply plugin: 'io.spring.dependency-management'
+
+version '1.0.0.SNAPSHOT'
 
 repositories {
     mavenLocal()
     jcenter()
 }
 
-dependencies {
+dependencyManagement {
-    compile("org.springframework.boot:spring-boot-starter-data-jpa:${springboot_version}")
+    imports {
-    compile("org.springframework.boot:spring-boot-starter-web:${springboot_version}")
+        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springcloud_version}"
-    compile("org.springframework.cloud:spring-cloud-starter-feign:1.4.1.RELEASE")
+    }
-    compile('com.h2database:h2:1.4.196')
-    testCompile('org.codehaus.groovy:groovy-all:2.4.6')
-    testCompile("au.com.dius:pact-jvm-consumer-junit_2.11:3.5.2")
-    testCompile("org.springframework.boot:spring-boot-starter-test:${springboot_version}")
 }
+
+dependencies {
+    compile('org.springframework.boot:spring-boot-starter-data-jpa')
+    compile('org.springframework.boot:spring-boot-starter-web')
+    compile('org.springframework.cloud:spring-cloud-starter-openfeign')
+    compile('org.springframework.cloud:spring-cloud-starter-netflix-ribbon')
+    compile('com.h2database:h2:1.4.196')
+
+    // add jaxb since it's no longer available in Java 11
+    runtime('javax.xml.bind:jaxb-api:2.3.1')
+
+    // add javassist >= 3.23.1-GA since earlier versions are broken in Java 11
+    // see https://github.com/jboss-javassist/javassist/issues/194
+    runtime('org.javassist:javassist:3.23.1-GA')
+
+    testCompile('org.codehaus.groovy:groovy-all:2.4.6')
+    testCompile("au.com.dius:pact-jvm-consumer-junit5_2.12:${pact_version}")
+    testCompile('org.springframework.boot:spring-boot-starter-test')
+    testRuntimeOnly( 'org.junit.jupiter:junit-jupiter-engine:5.1.0')
+}
+
+pact {
+    publish {
+        pactDirectory = 'target/pacts'
+        pactBrokerUrl = 'TODO'
+        pactBrokerUsername = 'TODO'
+        pactBrokerPassword = 'TODO'
+    }
+}
+
+test {
+    useJUnitPlatform()
+}

pact/pact-feign-consumer/gradle.properties

@@ -1,2 +1,3 @@
-springboot_version=1.5.9.RELEASE
+springboot_version=2.0.4.RELEASE
-verifier_version=1.2.2.RELEASE
+springcloud_version=Finchley.SR1
+pact_version=3.5.20

pact/pact-feign-consumer/gradle/wrapper/gradle-wrapper.properties

@@ -2,4 +2,4 @@ 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
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.1-bin.zip

pact/pact-feign-consumer/src/main/java/io/reflectoring/ConsumerApplication.java

@@ -2,10 +2,12 @@ package io.reflectoring;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.netflix.feign.EnableFeignClients;
+import org.springframework.cloud.netflix.ribbon.RibbonClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
 @SpringBootApplication
 @EnableFeignClients
+@RibbonClient(name = "userservice", configuration = RibbonConfiguration.class)
 public class ConsumerApplication {
 
 	public static void main(String[] args) {

pact/pact-feign-consumer/src/main/java/io/reflectoring/RibbonConfiguration.java

@@ -0,0 +1,15 @@
+package io.reflectoring;
+
+import com.netflix.client.config.IClientConfig;
+import com.netflix.loadbalancer.IRule;
+import com.netflix.loadbalancer.RandomRule;
+import org.springframework.context.annotation.Bean;
+
+public class RibbonConfiguration {
+
+	@Bean
+	public IRule ribbonRule(IClientConfig config) {
+		return new RandomRule();
+	}
+
+}

pact/pact-feign-consumer/src/main/java/io/reflectoring/UserClient.java

@@ -1,6 +1,6 @@
 package io.reflectoring;
 
-import org.springframework.cloud.netflix.feign.FeignClient;
+import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;

pact/pact-feign-consumer/src/test/java/io/reflectoring/UserServiceConsumerTest.java

@@ -1,83 +1,88 @@
 package io.reflectoring;
 
 import au.com.dius.pact.consumer.Pact;
-import au.com.dius.pact.consumer.PactProviderRuleMk2;
-import au.com.dius.pact.consumer.PactVerification;
 import au.com.dius.pact.consumer.dsl.PactDslJsonBody;
 import au.com.dius.pact.consumer.dsl.PactDslWithProvider;
+import au.com.dius.pact.consumer.junit5.PactConsumerTestExt;
+import au.com.dius.pact.consumer.junit5.PactTestFor;
 import au.com.dius.pact.model.RequestResponsePact;
-import org.junit.Rule;
+import org.junit.jupiter.api.Test;
-import org.junit.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
-import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
-import static org.assertj.core.api.Assertions.assertThat;
+import org.springframework.web.client.RestTemplate;
 
-@RunWith(SpringRunner.class)
+import static org.assertj.core.api.Assertions.*;
-@SpringBootTest(properties = {
+
-        // overriding provider address
+@ExtendWith(PactConsumerTestExt.class)
-        "userservice.ribbon.listOfServers: localhost:8888"
+@ExtendWith(SpringExtension.class)
+@PactTestFor(providerName = "userservice", port = "8888")
+@SpringBootTest({
+				// overriding provider address
+				"userservice.ribbon.listOfServers: localhost:8888"
 })
-public class UserServiceConsumerTest {
+class UserServiceConsumerTest {
 
-  @Rule
+	@Autowired
-  public PactProviderRuleMk2 stubProvider = new PactProviderRuleMk2("userservice", "localhost", 8888, this);
+	private UserClient userClient;
 
-  @Autowired
+	@Pact(state = "provider accepts a new person", provider = "userservice", consumer = "userclient")
-  private UserClient userClient;
+	RequestResponsePact createPersonPact(PactDslWithProvider builder) {
 
-  @Pact(state = "provider accepts a new person", provider = "userservice", consumer = "userclient")
+		// @formatter:off
-  public RequestResponsePact createPersonPact(PactDslWithProvider builder) {
+		return builder
-    return builder
+						.given("provider accepts a new person")
-            .given("provider accepts a new person")
+						.uponReceiving("a request to POST a person")
-            .uponReceiving("a request to POST a person")
+							.path("/user-service/users")
-            .path("/user-service/users")
+							.method("POST")
-            .method("POST")
+						.willRespondWith()
-            .willRespondWith()
+							.status(201)
-            .status(201)
+							.matchHeader("Content-Type", "application/json")
-            .matchHeader("Content-Type", "application/json")
+							.body(new PactDslJsonBody()
-            .body(new PactDslJsonBody()
+											.integerType("id", 42))
-                    .integerType("id", 42))
+						.toPact();
-            .toPact();
+		// @formatter:on
-  }
+	}
 
-  @Pact(state = "person 42 exists", provider = "userservice", consumer = "userclient")
+	@Pact(state = "person 42 exists", provider = "userservice", consumer = "userclient")
-  public RequestResponsePact updatePersonPact(PactDslWithProvider builder) {
+	RequestResponsePact updatePersonPact(PactDslWithProvider builder) {
-    return builder
+		// @formatter:off
-            .given("person 42 exists")
+		return builder
-            .uponReceiving("a request to PUT a person")
+						.given("person 42 exists")
-            .path("/user-service/users/42")
+						.uponReceiving("a request to PUT a person")
-            .method("PUT")
+						  .path("/user-service/users/42")
-            .willRespondWith()
+						  .method("PUT")
-            .status(200)
+						.willRespondWith()
-            .matchHeader("Content-Type", "application/json")
+						  .status(200)
-            .body(new PactDslJsonBody()
+						  .matchHeader("Content-Type", "application/json")
-                    .stringType("firstName", "Zaphod")
+						  .body(new PactDslJsonBody()
-                    .stringType("lastName", "Beeblebrox"))
+											.stringType("firstName", "Zaphod")
-            .toPact();
+											.stringType("lastName", "Beeblebrox"))
-  }
+						.toPact();
+		// @formatter:on
+	}
 
 
-  @Test
+	@Test
-  @PactVerification(fragment = "createPersonPact")
+	@PactTestFor(pactMethod = "createPersonPact")
-  public void verifyCreatePersonPact() {
+	void verifyCreatePersonPact() {
-    User user = new User();
+		User user = new User();
-    user.setFirstName("Zaphod");
+		user.setFirstName("Zaphod");
-    user.setLastName("Beeblebrox");
+		user.setLastName("Beeblebrox");
-    IdObject id = userClient.createUser(user);
+		IdObject id = userClient.createUser(user);
-    assertThat(id.getId()).isEqualTo(42);
+		assertThat(id.getId()).isEqualTo(42);
-  }
+	}
 
-  @Test
+	@Test
-  @PactVerification(fragment = "updatePersonPact")
+	@PactTestFor(pactMethod = "updatePersonPact")
-  public void verifyUpdatePersonPact() {
+	void verifyUpdatePersonPact() {
-    User user = new User();
+		User user = new User();
-    user.setFirstName("Zaphod");
+		user.setFirstName("Zaphod");
-    user.setLastName("Beeblebrox");
+		user.setLastName("Beeblebrox");
-    User updatedUser = userClient.updateUser(42L, user);
+		User updatedUser = userClient.updateUser(42L, user);
-    assertThat(updatedUser.getFirstName()).isEqualTo("Zaphod");
+		assertThat(updatedUser.getFirstName()).isEqualTo("Zaphod");
-    assertThat(updatedUser.getLastName()).isEqualTo("Beeblebrox");
+		assertThat(updatedUser.getLastName()).isEqualTo("Beeblebrox");
-  }
+	}
 
 }

pact/pact-feign-consumer/target/pacts/userclient-userservice.json

@@ -0,0 +1,115 @@
+{
+    "provider": {
+        "name": "userservice"
+    },
+    "consumer": {
+        "name": "userclient"
+    },
+    "interactions": [
+        {
+            "description": "a request to PUT a person",
+            "request": {
+                "method": "PUT",
+                "path": "/user-service/users/42"
+            },
+            "response": {
+                "status": 200,
+                "headers": {
+                    "Content-Type": "application/json"
+                },
+                "body": {
+                    "firstName": "Zaphod",
+                    "lastName": "Beeblebrox"
+                },
+                "matchingRules": {
+                    "body": {
+                        "$.firstName": {
+                            "matchers": [
+                                {
+                                    "match": "type"
+                                }
+                            ],
+                            "combine": "AND"
+                        },
+                        "$.lastName": {
+                            "matchers": [
+                                {
+                                    "match": "type"
+                                }
+                            ],
+                            "combine": "AND"
+                        }
+                    },
+                    "header": {
+                        "Content-Type": {
+                            "matchers": [
+                                {
+                                    "match": "regex",
+                                    "regex": "application/json"
+                                }
+                            ],
+                            "combine": "AND"
+                        }
+                    }
+                }
+            },
+            "providerStates": [
+                {
+                    "name": "person 42 exists"
+                }
+            ]
+        },
+        {
+            "description": "a request to POST a person",
+            "request": {
+                "method": "POST",
+                "path": "/user-service/users"
+            },
+            "response": {
+                "status": 201,
+                "headers": {
+                    "Content-Type": "application/json"
+                },
+                "body": {
+                    "id": 42
+                },
+                "matchingRules": {
+                    "header": {
+                        "Content-Type": {
+                            "matchers": [
+                                {
+                                    "match": "regex",
+                                    "regex": "application/json"
+                                }
+                            ],
+                            "combine": "AND"
+                        }
+                    },
+                    "body": {
+                        "$.id": {
+                            "matchers": [
+                                {
+                                    "match": "integer"
+                                }
+                            ],
+                            "combine": "AND"
+                        }
+                    }
+                }
+            },
+            "providerStates": [
+                {
+                    "name": "provider accepts a new person"
+                }
+            ]
+        }
+    ],
+    "metadata": {
+        "pactSpecification": {
+            "version": "3.0.0"
+        },
+        "pact-jvm": {
+            "version": "3.5.20"
+        }
+    }
+}

pact/pact-message-consumer/.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-consumer/README.md

@@ -0,0 +1,7 @@
+# Consumer-Driven-Contract Test for a Spring Boot Message Consumer
+
+This module shows how to use Pact to implement a contract test for a message provider.
+
+## Companion Articles
+[Testing a Spring Message Producer and Consumer against a Contract with Pact](https://reflectoring.io/cdc-pact-messages/)
+

pact/pact-message-consumer/application.yml

@@ -0,0 +1 @@
+spring.rabbitmq.connection-timeout=10

pact/pact-message-consumer/build.gradle

@@ -0,0 +1,43 @@
+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 = 11
+
+repositories {
+    mavenLocal()
+    mavenCentral()
+}
+
+dependencies {
+    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:1.18.2')
+
+    // add jaxb since it's no longer available in Java 11
+    runtime('javax.xml.bind:jaxb-api:2.3.1')
+
+    // add javassist >= 3.23.1-GA since earlier versions are broken in Java 11
+    // see https://github.com/jboss-javassist/javassist/issues/194
+    runtime('org.javassist:javassist:3.23.1-GA')
+    
+    testCompile("au.com.dius:pact-jvm-consumer-junit_2.12:${pact_version}")
+    testCompile("au.com.dius:pact-jvm-consumer-groovy_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-consumer/gradle.properties

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

pact/pact-message-consumer/gradle/wrapper/gradle-wrapper.properties

@@ -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-5.6.4-bin.zip

pact/pact-message-consumer/gradlew.bat

@@ -0,0 +1,84 @@
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

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

@@ -0,0 +1,15 @@
+package io.reflectoring;
+
+import org.springframework.amqp.rabbit.annotation.EnableRabbit;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.web.servlet.config.annotation.EnableWebMvc;
+
+@SpringBootApplication
+@EnableRabbit
+public class DemoApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(DemoApplication.class, args);
+	}
+}

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

@@ -0,0 +1,37 @@
+package io.reflectoring;
+
+
+import javax.validation.ConstraintViolation;
+import javax.validation.ConstraintViolationException;
+import javax.validation.Validation;
+import javax.validation.Validator;
+
+import java.io.IOException;
+import java.util.Set;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class MessageConsumer {
+
+  private Logger logger = LoggerFactory.getLogger(MessageConsumer.class);
+
+  private ObjectMapper objectMapper;
+
+  public MessageConsumer(ObjectMapper objectMapper) {
+    this.objectMapper = objectMapper;
+  }
+
+  public void consumeStringMessage(String messageString) throws IOException {
+    logger.info("Consuming message '{}'", messageString);
+    UserCreatedMessage message = objectMapper.readValue(messageString, UserCreatedMessage.class);
+    Validator validator = Validation.buildDefaultValidatorFactory().getValidator();
+    Set<ConstraintViolation<UserCreatedMessage>> violations = validator.validate(message);
+    if(!violations.isEmpty()){
+      throw new ConstraintViolationException(violations);
+    }
+    // pass message into business use case
+  }
+
+}

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

@@ -0,0 +1,60 @@
+package io.reflectoring;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
+import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class MessageConsumerConfiguration {
+
+	private static final String QUEUE_NAME = "myQueue";
+
+	private static final String EXCHANGE_NAME = "myExchange";
+
+	@Bean
+	public TopicExchange receiverExchange() {
+		return new TopicExchange(EXCHANGE_NAME);
+	}
+
+	@Bean
+	public Queue queue() {
+		return new Queue(QUEUE_NAME);
+	}
+
+	@Bean
+	public Binding binding(Queue eventReceivingQueue, TopicExchange receiverExchange) {
+		return BindingBuilder
+						.bind(eventReceivingQueue)
+						.to(receiverExchange)
+						.with("*.*");
+	}
+
+	@Bean
+	public SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
+																									MessageListenerAdapter listenerAdapter) {
+		SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
+		container.setConsumerStartTimeout(1000); // we don't want to wait in this example project
+		container.setConnectionFactory(connectionFactory);
+		container.setQueueNames(QUEUE_NAME);
+		container.setMessageListener(listenerAdapter);
+		return container;
+	}
+
+	@Bean
+	public MessageListenerAdapter listenerAdapter(MessageConsumer messageConsumer) {
+		return new MessageListenerAdapter(messageConsumer, "consumeStringMessage");
+	}
+
+	@Bean
+	public MessageConsumer eventReceiver(ObjectMapper objectMapper) {
+		return new MessageConsumer(objectMapper);
+	}
+
+}

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

@@ -0,0 +1,16 @@
+package io.reflectoring;
+
+import javax.validation.constraints.NotNull;
+
+import lombok.Data;
+
+@Data
+public class User {
+
+	@NotNull
+	private long id;
+
+	@NotNull
+	private String name;
+
+}

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

@@ -0,0 +1,16 @@
+package io.reflectoring;
+
+import javax.validation.constraints.NotNull;
+
+import lombok.Data;
+
+@Data
+public class UserCreatedMessage {
+
+	@NotNull
+	private String messageUuid;
+
+	@NotNull
+	private User user;
+
+}

pact/pact-message-consumer/src/test/java/io/reflectoring/MessageConsumerTest.java

@@ -0,0 +1,59 @@
+package io.reflectoring;
+
+import java.io.IOException;
+
+import au.com.dius.pact.consumer.MessagePactBuilder;
+import au.com.dius.pact.consumer.MessagePactProviderRule;
+import au.com.dius.pact.consumer.Pact;
+import au.com.dius.pact.consumer.PactVerification;
+import au.com.dius.pact.consumer.dsl.PactDslJsonBody;
+import au.com.dius.pact.model.v3.messaging.MessagePact;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class MessageConsumerTest {
+
+	@Rule
+	public MessagePactProviderRule mockProvider = new MessagePactProviderRule(this);
+	private byte[] currentMessage;
+
+	@Autowired
+	private MessageConsumer messageConsumer;
+
+	@Pact(provider = "userservice", consumer = "userclient")
+	public MessagePact userCreatedMessagePact(MessagePactBuilder builder) {
+		PactDslJsonBody body = new PactDslJsonBody();
+		body.stringType("messageUuid");
+		body.object("user")
+						.numberType("id", 42L)
+						.stringType("name", "Zaphod Beeblebrox")
+						.closeObject();
+
+		// @formatter:off
+		return builder
+						.expectsToReceive("a user created message")
+						.withContent(body)
+						.toPact();
+		// @formatter:on
+	}
+
+	@Test
+	@PactVerification("userCreatedMessagePact")
+	public void verifyCreatePersonPact() throws IOException {
+		messageConsumer.consumeStringMessage(new String(this.currentMessage));
+	}
+
+	/**
+	 * This method is called by the Pact framework.
+	 */
+	public void setMessage(byte[] message) {
+		this.currentMessage = message;
+	}
+
+}

pact/pact-message-consumer/target/pacts/userclient-userservice.json

@@ -0,0 +1,59 @@
+{
+    "consumer": {
+        "name": "userclient"
+    },
+    "provider": {
+        "name": "userservice"
+    },
+    "messages": [
+        {
+            "description": "a user created message",
+            "metaData": {
+                "Content-Type": "application/json; charset=UTF-8"
+            },
+            "contents": {
+                "messageUuid": "string",
+                "user": {
+                    "id": 42,
+                    "name": "Zaphod Beeblebrox"
+                }
+            },
+            "matchingRules": {
+                "body": {
+                    "$.messageUuid": {
+                        "matchers": [
+                            {
+                                "match": "type"
+                            }
+                        ],
+                        "combine": "AND"
+                    },
+                    "$.user.id": {
+                        "matchers": [
+                            {
+                                "match": "number"
+                            }
+                        ],
+                        "combine": "AND"
+                    },
+                    "$.user.name": {
+                        "matchers": [
+                            {
+                                "match": "type"
+                            }
+                        ],
+                        "combine": "AND"
+                    }
+                }
+            }
+        }
+    ],
+    "metadata": {
+        "pactSpecification": {
+            "version": "3.0.0"
+        },
+        "pact-jvm": {
+            "version": "3.5.20"
+        }
+    }
+}

pact/pact-message-producer/.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-producer/README.md

@@ -0,0 +1,3 @@
+# Consumer-Driven-Contract Test for a Spring Boot Message Provider
+
+This module shows how to use Pact to implement a contract test for a message provider.

pact/pact-message-producer/build.gradle

@@ -0,0 +1,46 @@
+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 = 11
+
+repositories {
+    mavenLocal()
+    mavenCentral()
+}
+
+dependencies {
+    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:1.18.2')
+
+    // add jaxb since it's no longer available in Java 11
+    runtime('javax.xml.bind:jaxb-api:2.3.1')
+
+    // add javassist >= 3.23.1-GA since earlier versions are broken in Java 11
+    // see https://github.com/jboss-javassist/javassist/issues/194
+    runtime('org.javassist:javassist:3.23.1-GA')
+
+    // overriding bytebuddy to newer version that supports Java 11
+    // see https://github.com/raphw/byte-buddy/issues/428
+    testCompile('net.bytebuddy:byte-buddy:1.9.12')
+
+    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-producer/gradle.properties

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

pact/pact-message-producer/gradle/wrapper/gradle-wrapper.properties

@@ -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.10.1-bin.zip

pact/pact-message-producer/gradlew

@@ -0,0 +1,172 @@
+#!/usr/bin/env sh
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn ( ) {
+    echo "$*"
+}
+
+die ( ) {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+  NONSTOP* )
+    nonstop=true
+    ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Escape application args
+save ( ) {
+    for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+    echo " "
+}
+APP_ARGS=$(save "$@")
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong
+if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then
+  cd "$(dirname "$0")"
+fi
+
+exec "$JAVACMD" "$@"

pact/pact-message-producer/gradlew.bat

@@ -0,0 +1,84 @@
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

pact/pact-message-producer/src/main/java/io/reflectoring/DemoApplication.java

@@ -0,0 +1,12 @@
+package io.reflectoring;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class DemoApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(DemoApplication.class, args);
+	}
+}

pact/pact-message-producer/src/main/java/io/reflectoring/MessageProducer.java

@@ -0,0 +1,31 @@
+package io.reflectoring;
+
+import java.io.IOException;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Takes a {@link UserCreatedMessage}, converts it to a {@link String} and sends it to be published.
+ */
+class MessageProducer {
+
+	private Logger logger = LoggerFactory.getLogger(MessageProducer.class);
+
+	private ObjectMapper objectMapper;
+
+	private MessagePublisher messagePublisher;
+
+	MessageProducer(ObjectMapper objectMapper, MessagePublisher messagePublisher) {
+		this.objectMapper = objectMapper;
+		this.messagePublisher = messagePublisher;
+	}
+
+	void produceUserCreatedMessage(UserCreatedMessage message) throws IOException {
+		String stringMessage = objectMapper.writeValueAsString(message);
+		messagePublisher.publishMessage(stringMessage, "user.created");
+		logger.info("Published message '{}'", stringMessage);
+	}
+
+}

pact/pact-message-producer/src/main/java/io/reflectoring/MessageProviderConfiguration.java

@@ -0,0 +1,36 @@
+package io.reflectoring;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@Configuration
+@EnableScheduling
+class MessageProviderConfiguration {
+
+	@Bean
+	TopicExchange topicExchange() {
+		return new TopicExchange("myExchange");
+	}
+
+
+	@Bean
+	MessageProducer messageProvider(ObjectMapper objectMapper, MessagePublisher publisher) {
+		return new MessageProducer(objectMapper, publisher);
+	}
+
+	@Bean
+	MessagePublisher messagePublisher(RabbitTemplate rabbitTemplate, TopicExchange topicExchange) {
+		return new MessagePublisher(rabbitTemplate, topicExchange);
+	}
+
+	@Bean
+	SendMessageJob job(MessageProducer messageProducer) {
+		return new SendMessageJob(messageProducer);
+	}
+
+
+}

pact/pact-message-producer/src/main/java/io/reflectoring/MessagePublisher.java

@@ -0,0 +1,24 @@
+package io.reflectoring;
+
+import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+
+/**
+ * Publishes a String message to RabbitMQ.
+ */
+class MessagePublisher {
+
+	private RabbitTemplate rabbitTemplate;
+
+	private TopicExchange topicExchange;
+
+	MessagePublisher(RabbitTemplate rabbitTemplate, TopicExchange topicExchange) {
+		this.rabbitTemplate = rabbitTemplate;
+		this.topicExchange = topicExchange;
+	}
+
+	void publishMessage(String message, String routingKey) {
+		rabbitTemplate.convertAndSend(topicExchange.getName(), routingKey, message);
+	}
+
+}

pact/pact-message-producer/src/main/java/io/reflectoring/SendMessageJob.java

@@ -0,0 +1,37 @@
+package io.reflectoring;
+
+import java.io.IOException;
+import java.util.Random;
+import java.util.UUID;
+
+import org.springframework.scheduling.annotation.Scheduled;
+
+class SendMessageJob {
+
+	private Random random = new Random();
+
+	private MessageProducer messageProducer;
+
+	SendMessageJob(MessageProducer messageProducer) {
+		this.messageProducer = messageProducer;
+	}
+
+	/**
+	 * This scheduled job simulates the "real" business logic that should produce messages.
+	 */
+	@Scheduled(fixedDelay = 1000)
+	void sendUserCreatedMessage() {
+		try {
+			UserCreatedMessage userCreatedMessage = UserCreatedMessage.builder()
+							.messageUuid(UUID.randomUUID().toString())
+							.user(User.builder()
+											.id(random.nextLong())
+											.name("Zaphpod Beeblebrox")
+											.build())
+							.build();
+			messageProducer.produceUserCreatedMessage(userCreatedMessage);
+		} catch (IOException e) {
+			throw new RuntimeException(e);
+		}
+	}
+}

pact/pact-message-producer/src/main/java/io/reflectoring/User.java

@@ -0,0 +1,18 @@
+package io.reflectoring;
+
+import javax.validation.constraints.NotNull;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+class User {
+
+	@NotNull
+	private long id;
+
+	@NotNull
+	private String name;
+
+}

pact/pact-message-producer/src/main/java/io/reflectoring/UserCreatedMessage.java

@@ -0,0 +1,18 @@
+package io.reflectoring;
+
+import javax.validation.constraints.NotNull;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+class UserCreatedMessage {
+
+	@NotNull
+	private String messageUuid;
+
+	@NotNull
+	private User user;
+
+}

pact/pact-message-producer/src/test/java/io/reflectoring/CustomAmqpTarget.java

@@ -0,0 +1,41 @@
+package io.reflectoring;
+
+import java.util.List;
+
+import au.com.dius.pact.model.Interaction;
+import au.com.dius.pact.model.ProviderState;
+import au.com.dius.pact.provider.ConsumerInfo;
+import au.com.dius.pact.provider.ProviderInfo;
+import au.com.dius.pact.provider.ProviderVerifier;
+import au.com.dius.pact.provider.junit.target.AmqpTarget;
+import org.jetbrains.annotations.NotNull;
+
+/**
+ * Custom implementation of {@link AmqpTarget} since with {@link AmqpTarget}
+ * I had classpath troubles (see https://github.com/DiUS/pact-jvm/issues/763).
+ * Use at own risk, since the implementation is not complete and may behave
+ * a little different that the original class.
+ */
+public class CustomAmqpTarget extends AmqpTarget {
+
+	public CustomAmqpTarget(List<String> packagesToScan) {
+		super(packagesToScan);
+	}
+
+	@NotNull
+	@Override
+	protected ProviderVerifier setupVerifier(Interaction interaction, ProviderInfo provider, ConsumerInfo consumer) {
+		ProviderVerifier verifier = new CustomProviderVerifier(getPackagesToScan());
+		setupReporters(verifier, provider.getName(), interaction.getDescription());
+		verifier.initialiseReporters(provider);
+		verifier.reportVerificationForConsumer(consumer, provider);
+
+		if (!interaction.getProviderStates().isEmpty()) {
+			for (ProviderState state : interaction.getProviderStates()) {
+				verifier.reportStateForInteraction(state.getName(), provider, consumer, true);
+			}
+		}
+		verifier.reportInteractionDescription(interaction);
+		return verifier;
+	}
+}

pact/pact-message-producer/src/test/java/io/reflectoring/CustomProviderVerifier.java

@@ -0,0 +1,62 @@
+package io.reflectoring;
+
+import java.lang.reflect.Method;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import au.com.dius.pact.model.Interaction;
+import au.com.dius.pact.model.v3.messaging.Message;
+import au.com.dius.pact.provider.ConsumerInfo;
+import au.com.dius.pact.provider.PactVerifyProvider;
+import au.com.dius.pact.provider.ProviderInfo;
+import au.com.dius.pact.provider.ProviderVerifier;
+import org.reflections.Reflections;
+import org.reflections.scanners.MethodAnnotationsScanner;
+import org.reflections.util.ConfigurationBuilder;
+
+public class CustomProviderVerifier extends ProviderVerifier {
+
+	private List<String> packagesToScan;
+
+	public CustomProviderVerifier(List<String> packagesToScan) {
+		this.packagesToScan = packagesToScan;
+	}
+
+	@Override
+	public boolean verifyResponseByInvokingProviderMethods(ProviderInfo providerInfo, ConsumerInfo consumer,
+																												 Object interaction, String interactionMessage, Map failures) {
+		try {
+
+			ConfigurationBuilder configurationBuilder = new ConfigurationBuilder()
+							.setScanners(new MethodAnnotationsScanner())
+							.forPackages(packagesToScan.toArray(new String[]{}));
+
+			Reflections reflections = new Reflections(configurationBuilder);
+			Set<Method> methodsAnnotatedWith = reflections.getMethodsAnnotatedWith(PactVerifyProvider.class);
+			Set<Method> providerMethods = methodsAnnotatedWith.stream()
+							.filter(m -> {
+								PactVerifyProvider annotation = m.getAnnotation(PactVerifyProvider.class);
+								return annotation.value().equals(((Interaction)interaction).getDescription());
+							})
+							.collect(Collectors.toSet());
+
+			if (providerMethods.isEmpty()) {
+				throw new RuntimeException("No annotated methods were found for interaction " +
+								"'${interaction.description}'. You need to provide a method annotated with " +
+								"@PactVerifyProvider(\"${interaction.description}\") that returns the message contents.");
+			} else {
+				if (interaction instanceof Message) {
+					verifyMessagePact(providerMethods, (Message) interaction, interactionMessage, failures);
+				} else {
+					throw new RuntimeException("only supports Message interactions!");
+				}
+			}
+		} catch (Exception e) {
+			throw new RuntimeException("verification failed", e);
+		}
+		return true;
+	}
+
+}

pact/pact-message-producer/src/test/java/io/reflectoring/UserCreatedMessageProviderTest.java

@@ -0,0 +1,53 @@
+package io.reflectoring;
+
+import java.io.IOException;
+import java.util.Collections;
+import java.util.UUID;
+
+import au.com.dius.pact.provider.PactVerifyProvider;
+import au.com.dius.pact.provider.junit.PactRunner;
+import au.com.dius.pact.provider.junit.Provider;
+import au.com.dius.pact.provider.junit.loader.PactFolder;
+import au.com.dius.pact.provider.junit.target.Target;
+import au.com.dius.pact.provider.junit.target.TestTarget;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.junit.runner.RunWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Mockito;
+import static org.mockito.Mockito.*;
+
+@RunWith(PactRunner.class)
+@Provider("userservice")
+@PactFolder("../pact-message-consumer/target/pacts")
+public class UserCreatedMessageProviderTest {
+
+	@TestTarget
+	public final Target target = new CustomAmqpTarget(Collections.singletonList("io.reflectoring"));
+
+	private MessagePublisher publisher = Mockito.mock(MessagePublisher.class);
+
+	private MessageProducer messageProducer = new MessageProducer(new ObjectMapper(), publisher);
+
+	@PactVerifyProvider("a user created message")
+	public String verifyUserCreatedMessage() throws IOException {
+		// given
+		doNothing().when(publisher).publishMessage(any(String.class), eq("user.created"));
+
+		// when
+		UserCreatedMessage message = UserCreatedMessage.builder()
+						.messageUuid(UUID.randomUUID().toString())
+						.user(User.builder()
+										.id(42L)
+										.name("Zaphod Beeblebrox")
+										.build())
+						.build();
+		messageProducer.produceUserCreatedMessage(message);
+
+		// then
+		ArgumentCaptor<String> messageCapture = ArgumentCaptor.forClass(String.class);
+		verify(publisher, times(1)).publishMessage(messageCapture.capture(), eq("user.created"));
+
+		// returning the message
+		return messageCapture.getValue();
+	}
+}

pact/pact-node-messages/.gitignore

@@ -0,0 +1,24 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+
+# testing
+/coverage
+
+# production
+/build
+
+# misc
+.DS_Store
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+.nyc_output/*
+coverage/*

pact/pact-node-messages/package.json

@@ -0,0 +1,17 @@
+{
+  "name": "pact-node-messages",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test:pact:consumer": "mocha src/consumer/*.spec.js --exit",
+    "test:pact:provider": "mocha src/provider/*.spec.js --exit",
+    "publish:pact": "node pact/publish.js"
+  },
+  "author": "Tom Hombergs",
+  "license": "MIT",
+  "devDependencies": {
+    "@pact-foundation/pact": "^7.0.3",
+    "mocha": "^5.2.0"
+  }
+}

pact/pact-node-messages/pact/publish.js

@@ -0,0 +1,12 @@
+let publisher = require('@pact-foundation/pact-node');
+let path = require('path');
+
+let opts = {
+    pactFilesOrDirs: [path.resolve(process.cwd(), 'pacts')],
+    pactBroker: 'https://adesso.pact.dius.com.au/',
+    pactBrokerUsername: process.env.PACT_USERNAME,
+    pactBrokerPassword: process.env.PACT_PASSWORD,
+    consumerVersion: '2.0.0'
+};
+
+publisher.publishPacts(opts).then(() => console.log("Pacts successfully published"));

pact/pact-node-messages/pacts/node-message-consumer-node-message-provider.json

@@ -0,0 +1,63 @@
+{
+  "consumer": {
+    "name": "node-message-consumer"
+  },
+  "provider": {
+    "name": "node-message-provider"
+  },
+  "messages": [
+    {
+      "description": "a hero created message",
+      "providerStates": [
+
+      ],
+      "contents": {
+        "id": 42,
+        "name": "Superman",
+        "superpower": "flying",
+        "universe": "DC"
+      },
+      "matchingRules": {
+        "body": {
+          "$.id": {
+            "matchers": [
+              {
+                "match": "type"
+              }
+            ]
+          },
+          "$.name": {
+            "matchers": [
+              {
+                "match": "type"
+              }
+            ]
+          },
+          "$.superpower": {
+            "matchers": [
+              {
+                "match": "type"
+              }
+            ]
+          },
+          "$.universe": {
+            "matchers": [
+              {
+                "match": "regex",
+                "regex": "^(DC|Marvel)$"
+              }
+            ]
+          }
+        }
+      },
+      "metaData": {
+        "content-type": "application/json"
+      }
+    }
+  ],
+  "metadata": {
+    "pactSpecification": {
+      "version": "3.0.0"
+    }
+  }
+}

pact/pact-node-messages/src/common/hero-created-event.js

@@ -0,0 +1,35 @@
+class HeroCreatedEvent {
+
+    constructor(name, superpower, universe, id) {
+        this.id = id;
+        this.name = name;
+        this.superpower = superpower;
+        this.universe = universe;
+    }
+
+    static validateUniverse(event) {
+        if (typeof event.universe !== 'string') {
+            throw new Error(`Hero universe must be a string! Invalid value: ${event.universe}`)
+        }
+    }
+
+    static validateSuperpower(event) {
+        if (typeof event.superpower !== 'string') {
+            throw new Error(`Hero superpower must be a string! Invalid value: ${event.superpower}`)
+        }
+    }
+
+    static validateName(event) {
+        if (typeof event.name !== 'string') {
+            throw new Error(`Hero name must be a string! Invalid value: ${event.name}`);
+        }
+    }
+
+    static validateId(event) {
+        if (typeof event.id !== 'number') {
+            throw new Error(`Hero id must be a number! Invalid value: ${event.id}`)
+        }
+    }
+}
+
+module.exports = HeroCreatedEvent;

pact/pact-node-messages/src/consumer/hero-event-handler.js

@@ -0,0 +1,15 @@
+const HeroCreatedEvent = require('../common/hero-created-event');
+
+exports.HeroEventHandler = {
+    handleHeroCreatedEvent: (message) => {
+
+        HeroCreatedEvent.validateId(message);
+        HeroCreatedEvent.validateName(message);
+        HeroCreatedEvent.validateSuperpower(message);
+        HeroCreatedEvent.validateUniverse(message);
+
+        // pass message into business logic
+        // note that the business logic should be mocked away for the contract test
+
+    }
+};

pact/pact-node-messages/src/consumer/hero-event-handler.spec.js

@@ -0,0 +1,35 @@
+const {MessageConsumerPact, Matchers, synchronousBodyHandler} = require('@pact-foundation/pact');
+const {HeroEventHandler} = require('./hero-event-handler');
+const path = require('path');
+
+describe("message consumer", () => {
+
+    const messagePact = new MessageConsumerPact({
+        consumer: "node-message-consumer",
+        provider: "node-message-provider",
+        dir: path.resolve(process.cwd(), "pacts"),
+        pactfileWriteMode: "update",
+        logLevel: "info",
+    });
+
+    describe("'hero created' message Handler", () => {
+
+        it("should accept a valid hero created message", (done) => {
+            messagePact
+                .expectsToReceive("a hero created message")
+                .withContent({
+                    id: Matchers.like(42),
+                    name: Matchers.like("Superman"),
+                    superpower: Matchers.like("flying"),
+                    universe: Matchers.term({generate: "DC", matcher: "^(DC|Marvel)$"})
+                })
+                .withMetadata({
+                    "content-type": "application/json",
+                })
+                .verify(synchronousBodyHandler(HeroEventHandler.handleHeroCreatedEvent))
+                .then(() => done(), (error) => done(error));
+        }).timeout(5000);
+
+    });
+
+});

pact/pact-node-messages/src/provider/hero-event-producer.js

@@ -0,0 +1,9 @@
+const HeroCreatedEvent = require('../common/hero-created-event');
+
+exports.CreateHeroEventProducer = {
+    produceHeroCreatedEvent: () => {
+        return new Promise((resolve, reject) => {
+            resolve(new HeroCreatedEvent("Superman", "Flying", "DC", 42));
+        });
+    }
+};

pact/pact-node-messages/src/provider/hero-event-producer.spec.js

@@ -0,0 +1,37 @@
+const {MessageProviderPact} = require('@pact-foundation/pact');
+const {CreateHeroEventProducer} = require('./hero-event-producer');
+const path = require('path');
+
+describe("message producer", () => {
+
+    const messagePact = new MessageProviderPact({
+        messageProviders: {
+            "a hero created message": () => CreateHeroEventProducer.produceHeroCreatedEvent(),
+        },
+        log: path.resolve(process.cwd(), "logs", "pact.log"),
+        logLevel: "info",
+        provider: "node-message-provider",
+
+        pactUrls: [path.resolve(process.cwd(), "pacts", "node-message-consumer-node-message-provider.json")],
+
+        // Pact seems not to load a pact file from a pact broker, so we have to make do with the local pact file
+        // see https://github.com/pact-foundation/pact-js/issues/248
+        // pactBrokerUrl: "https://adesso.pact.dius.com.au",
+        // pactBrokerUsername: process.env.PACT_USERNAME,
+        // pactBrokerPassword: process.env.PACT_PASSWORD,
+        // publishVerificationResult: true,
+        // providerVersion: '1.0.0',
+        tags: ['latest']
+    });
+
+    describe("'hero created' message producer", () => {
+
+        it("should create a valid hero created message", (done) => {
+            messagePact
+                .verify()
+                .then(() => done(), (error) => done(error));
+        }).timeout(5000);
+
+    });
+
+});

pact/pact-node-provider/.gitignore

@@ -0,0 +1,21 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+
+# testing
+/coverage
+
+# production
+/build
+
+# misc
+.DS_Store
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*

pact/pact-node-provider/README.md

@@ -0,0 +1,7 @@
+# Node Pact example
+
+This example project shows how to setup an Express server with Node and create
+a contract test for the provider side of a contract with Pact Node.   
+
+## Relevant Blog Post
+[Step By Step Tutorial for Implementing Consumer-Driven Contracts for a Node Express Server with Pact](https://reflectoring.io/pact-node-provider/)

pact/pact-node-provider/app.js

@@ -0,0 +1,29 @@
+const express = require('express');
+const path = require('path');
+const cookieParser = require('cookie-parser');
+const logger = require('morgan');
+
+const indexRouter = require('./routes/index');
+const usersRouter = require('./routes/users');
+const heroesRouter = require('./routes/heroes');
+const graphqlRouter = require('./routes/graphql');
+const providerStateRouter = require ('./routes/provider_state');
+
+const app = express();
+
+app.use(logger('dev'));
+app.use(express.json());
+app.use(express.urlencoded({ extended: false }));
+app.use(cookieParser());
+app.use(express.static(path.join(__dirname, 'public')));
+
+app.use('/', indexRouter);
+app.use('/users', usersRouter);
+app.use('/heroes', heroesRouter);
+app.use('/graphql', graphqlRouter);
+
+if (process.env.PACT_MODE === 'true') {
+    app.use('/provider-state', providerStateRouter);
+}
+
+module.exports = app;

pact/pact-node-provider/bin/www

@@ -0,0 +1,90 @@
+#!/usr/bin/env node
+
+/**
+ * Module dependencies.
+ */
+
+var app = require('../app');
+var debug = require('debug')('test:server');
+var http = require('http');
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+var port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+/**
+ * Create HTTP server.
+ */
+
+var server = http.createServer(app);
+
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+server.listen(port);
+server.on('error', onError);
+server.on('listening', onListening);
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  var port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  var bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+  var addr = server.address();
+  var bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  debug('Listening on ' + bind);
+}

pact/pact-node-provider/package.json

@@ -0,0 +1,23 @@
+{
+  "name": "test",
+  "version": "0.0.0",
+  "private": true,
+  "scripts": {
+    "start": "node ./bin/www",
+    "pact:providerTests": "node ./pact/provider_tests.js",
+    "pact:providerTests:graphql": "node ./pact/provider_tests_graphql.js",
+    "test:pact": "start-server-and-test start http://localhost:3000 pact:providerTests",
+    "test:pact:graphql": "start-server-and-test start http://localhost:3000 pact:providerTests:graphql"
+  },
+  "dependencies": {
+    "cookie-parser": "~1.4.3",
+    "debug": "~2.6.9",
+    "express": "~4.16.0",
+    "express-graphql": "^0.7.1",
+    "morgan": "~1.9.0"
+  },
+  "devDependencies": {
+    "@pact-foundation/pact": "7.0.3",
+    "start-server-and-test": "^1.7.5"
+  }
+}

pact/pact-node-provider/pact/provider_tests.js

@@ -0,0 +1,17 @@
+const { Verifier } = require('@pact-foundation/pact');
+const packageJson = require('../package.json');
+
+let opts = {
+    providerBaseUrl: 'http://localhost:3000',
+    provider: 'hero-provider',
+    pactBrokerUrl: 'https://adesso.pact.dius.com.au',
+    pactBrokerUsername: process.env.PACT_USERNAME,
+    pactBrokerPassword: process.env.PACT_PASSWORD,
+    publishVerificationResult: true,
+    providerVersion: packageJson.version,
+    providerStatesSetupUrl: 'http://localhost:3000/provider-state'
+};
+
+new Verifier().verifyProvider(opts).then(function () {
+    console.log("Pacts successfully verified!");
+});

pact/pact-node-provider/pact/provider_tests_graphql.js

@@ -0,0 +1,16 @@
+const { Verifier } = require('@pact-foundation/pact');
+const packageJson = require('../package.json');
+
+let opts = {
+    providerBaseUrl: 'http://localhost:3000',
+    provider: 'graphql-hero-provider',
+    pactBrokerUrl: 'https://adesso.pact.dius.com.au',
+    pactBrokerUsername: process.env.PACT_USERNAME,
+    pactBrokerPassword: process.env.PACT_PASSWORD,
+    publishVerificationResult: true,
+    providerVersion: packageJson.version,
+};
+
+new Verifier().verifyProvider(opts).then(function () {
+    console.log("Pacts successfully verified!");
+});

pact/pact-node-provider/public/index.html

@@ -0,0 +1,13 @@
+<html>
+
+<head>
+  <title>Express</title>
+  <link rel="stylesheet" href="/stylesheets/style.css">
+</head>
+
+<body>
+  <h1>Express</h1>
+  <p>Welcome to Express</p>
+</body>
+
+</html>

pact/pact-node-provider/public/stylesheets/style.css

@@ -0,0 +1,8 @@
+body {
+  padding: 50px;
+  font: 14px "Lucida Grande", Helvetica, Arial, sans-serif;
+}
+
+a {
+  color: #00B7FF;
+}

pact/pact-node-provider/routes/graphql.js

@@ -0,0 +1,36 @@
+const graphqlHTTP = require('express-graphql');
+const {buildSchema} = require("graphql");
+
+const heroesSchema = buildSchema(`
+  type Query {
+    hero(id: Int!): Hero
+  }
+
+  type Hero {
+    id: Int!
+    name: String!
+    superpower: String!
+    universe: String!
+  }
+`);
+
+const getHero = function () {
+    return {
+        id: 42,
+        name: "Superman",
+        superpower: "Flying",
+        universe: "DC"
+    }
+};
+
+const root = {
+    hero: getHero
+};
+
+const router = graphqlHTTP({
+    schema: heroesSchema,
+    graphiql: true,
+    rootValue: root
+});
+
+module.exports = router;

pact/pact-node-provider/routes/heroes.js

@@ -0,0 +1,27 @@
+const express = require('express');
+const router = express.Router();
+
+router.route('/:hero_id')
+    .get(function (req, res) {
+        const heroId = parseInt(req.params['hero_id']);
+        res.status(200);
+        res.json({
+            id: heroId,
+            superpower: 'flying',
+            name: 'Superman',
+            universe: 'DC'
+        });
+    });
+
+router.route('/')
+    .post(function (req, res) {
+        res.status(201);
+        res.json({
+            id: 42,
+            superpower: 'flying',
+            name: 'Superman',
+            universe: 'DC'
+        });
+    });
+
+module.exports = router;

pact/pact-node-provider/routes/index.js

@@ -0,0 +1,9 @@
+var express = require('express');
+var router = express.Router();
+
+/* GET home page. */
+router.get('/', function(req, res, next) {
+  res.render('index', { title: 'Express' });
+});
+
+module.exports = router;

pact/pact-node-provider/routes/provider_state.js

@@ -0,0 +1,13 @@
+const express = require('express');
+const router = express.Router();
+
+router.route('/')
+    .post(function (req, res) {
+        const consumer = req.query['consumer'];
+        const providerState = req.query['state'];
+        // imagine we're setting the server into a certain state
+        res.send(`changed to provider state "${providerState}" for consumer "${consumer}"`);
+        res.status(200);
+    });
+
+module.exports = router;