From f495a88e915a1cc894d231b3911ae619f4536a54 Mon Sep 17 00:00:00 2001
From: Paul Campbell <pcampbell@kemitix.net>
Date: Sat, 1 Apr 2017 19:04:48 +0100
Subject: [PATCH] #467 data-bus: members: MessageCollectorMemberTest: added

---
 .../members/MessageCollectorMemberTest.java   | 40 +++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 data-bus/src/test/java/com/iluwatar/databus/members/MessageCollectorMemberTest.java

diff --git a/data-bus/src/test/java/com/iluwatar/databus/members/MessageCollectorMemberTest.java b/data-bus/src/test/java/com/iluwatar/databus/members/MessageCollectorMemberTest.java
new file mode 100644
index 000000000..96fc090ee
--- /dev/null
+++ b/data-bus/src/test/java/com/iluwatar/databus/members/MessageCollectorMemberTest.java
@@ -0,0 +1,40 @@
+package com.iluwatar.databus.members;
+
+import com.iluwatar.databus.data.MessageData;
+import com.iluwatar.databus.data.StartingData;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.time.LocalDateTime;
+
+/**
+ * Tests for {@link MessageCollectorMember}.
+ *
+ * @author Paul Campbell (pcampbell@kemitix.net)
+ */
+public class MessageCollectorMemberTest {
+
+  @Test
+  public void collectMessageFromMessageData() {
+    //given
+    final String message = "message";
+    final MessageData messageData = new MessageData(message);
+    final MessageCollectorMember collector = new MessageCollectorMember("collector");
+    //when
+    collector.accept(messageData);
+    //then
+    Assert.assertTrue(collector.getMessages().contains(message));
+  }
+
+  @Test
+  public void collectIgnoresMessageFromOtherDataTypes() {
+    //given
+    final StartingData startingData = new StartingData(LocalDateTime.now());
+    final MessageCollectorMember collector = new MessageCollectorMember("collector");
+    //when
+    collector.accept(startingData);
+    //then
+    Assert.assertEquals(0, collector.getMessages().size());
+  }
+
+}