1 files changed, 61 insertions, 0 deletions
diff --git a/jdisc_core/src/test/java/com/yahoo/jdisc/application/ContainerThreadTestCase.java b/jdisc_core/src/test/java/com/yahoo/jdisc/application/ContainerThreadTestCase.java
new file mode 100644
index 00000000000..d92512b3650
--- /dev/null
+++ b/jdisc_core/src/test/java/com/yahoo/jdisc/application/ContainerThreadTestCase.java
@@ -0,0 +1,61 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+package com.yahoo.jdisc.application;
+
+import com.yahoo.jdisc.Metric;
+import org.junit.Test;
+
+import java.util.Map;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+import static org.junit.Assert.assertSame;
+
+
+/**
+ * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a>
+ */
+public class ContainerThreadTestCase {
+
+    @Test
+    public void requireThatAccessorsWork() {
+        MetricConsumer consumer = new MyConsumer();
+        ContainerThread thread = new ContainerThread(new MyTask(), consumer);
+        assertSame(consumer, thread.consumer());
+    }
+
+    @Test
+    public void requireThatTaskIsRun() throws InterruptedException {
+        MyTask task = new MyTask();
+        ContainerThread thread = new ContainerThread(task, null);
+        thread.start();
+        task.latch.await(600, TimeUnit.SECONDS);
+    }
+
+    private static class MyConsumer implements MetricConsumer {
+
+        @Override
+        public void set(String key, Number val, Metric.Context ctx) {
+
+        }
+
+        @Override
+        public void add(String key, Number val, Metric.Context ctx) {
+
+        }
+
+        @Override
+        public Metric.Context createContext(Map<String, ?> properties) {
+            return null;
+        }
+    }
+
+    private static class MyTask implements Runnable {
+
+        final CountDownLatch latch = new CountDownLatch(1);
+
+        @Override
+        public void run() {
+            latch.countDown();
+        }
+    }
+}