refactored message pact examples

Author: thombergs

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

@@ -13,13 +13,13 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class UserCreatedMessageConsumer {
+public class MessageConsumer {
 
-  private Logger logger = LoggerFactory.getLogger(UserCreatedMessageConsumer.class);
+  private Logger logger = LoggerFactory.getLogger(MessageConsumer.class);
 
   private ObjectMapper objectMapper;
 
-  public UserCreatedMessageConsumer(ObjectMapper objectMapper) {
+  public MessageConsumer(ObjectMapper objectMapper) {
     this.objectMapper = objectMapper;
   }
 

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

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

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

@@ -17,14 +17,14 @@
 
 @RunWith(SpringRunner.class)
 @SpringBootTest
-public class UserCreatedMessageConsumerTest {
+public class MessageConsumerTest {
 
 	@Rule
 	public MessagePactProviderRule mockProvider = new MessagePactProviderRule(this);
 	private byte[] currentMessage;
 
 	@Autowired
-	private UserCreatedMessageConsumer userCreatedMessageConsumer;
+	private MessageConsumer messageConsumer;
 
 	@Pact(provider = "userservice", consumer = "userclient")
 	public MessagePact userCreatedMessagePact(MessagePactBuilder builder) {
@@ -46,7 +46,7 @@ public MessagePact userCreatedMessagePact(MessagePactBuilder builder) {
 	@Test
 	@PactVerification("userCreatedMessagePact")
 	public void verifyCreatePersonPact() throws IOException {
-		userCreatedMessageConsumer.consumeStringMessage(new String(this.currentMessage));
+		messageConsumer.consumeStringMessage(new String(this.currentMessage));
 	}
 
 	/**