From 99f2d9a92ef2c371547b691ffe9528f18bd36a5f Mon Sep 17 00:00:00 2001
From: Mark Fisher <mfisher@pivotal.io>
Date: Thu, 14 Apr 2016 17:43:49 -0400
Subject: [PATCH] add test that uses stub message producer

---
 pom.xml                                             |  7 +++++++
 .../github/AnalyticsApplicationTests.java           | 13 +++++++++----
 2 files changed, 16 insertions(+), 4 deletions(-)

diff --git a/pom.xml b/pom.xml
index 48b6267..02301f0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -48,6 +48,13 @@
 			<artifactId>spring-boot-starter-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.github</groupId>
+			<artifactId>github-webhook-stub</artifactId>
+			<version>0.0.1-SNAPSHOT</version>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
 	
 	<dependencyManagement>
diff --git a/src/test/java/org/springframework/github/AnalyticsApplicationTests.java b/src/test/java/org/springframework/github/AnalyticsApplicationTests.java
index 927fe60..54dcefd 100644
--- a/src/test/java/org/springframework/github/AnalyticsApplicationTests.java
+++ b/src/test/java/org/springframework/github/AnalyticsApplicationTests.java
@@ -2,9 +2,11 @@
 
 import org.junit.Test;
 import org.junit.runner.RunWith;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.SpringApplicationConfiguration;
 import org.springframework.cloud.stream.messaging.Sink;
+import org.springframework.cloud.stream.test.stub.StubMessageProducer;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageHeaders;
 import org.springframework.messaging.support.MessageBuilder;
@@ -21,10 +23,11 @@ public class AnalyticsApplicationTests {
 	@Autowired
 	private Sink sink;
 
+	@Autowired
+	private StubMessageProducer messageProducer;
 
 	@Test
-	public void contextLoads() throws JsonProcessingException {
-
+	public void testWithMarshalledPojo() throws JsonProcessingException {
 		GithubData data = new GithubData();
 		data.setRepository("spring-framework");
 		data.setUsername("rossen");
@@ -32,9 +35,11 @@ public void contextLoads() throws JsonProcessingException {
 		Message<String> message =
 				MessageBuilder.withPayload(json).setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON).build();
 		this.sink.input().send(message);
-
 	}
 
-
+	@Test
+	public void testWithStubData() {
+		messageProducer.produce("issue-created.json", MimeTypeUtils.APPLICATION_JSON);
+	}
 
 }