From edbaeed4df287944e82719059f62a65bf902b705 Mon Sep 17 00:00:00 2001
From: Woonduk Kang <wd.kang@navercorp.com>
Date: Tue, 6 Nov 2012 07:09:33 +0000
Subject: [PATCH] =?UTF-8?q?[=EA=B0=95=EC=9A=B4=EB=8D=95]=20[LUCYSUS-1744]?=
 =?UTF-8?q?=20systemmonitor=EC=88=98=EC=A0=95.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@845 84d0f5b1-2673-498c-a247-62c4ff18d310
---
 src/main/java/com/profiler/SystemMonitor.java |  6 ++---
 .../profiler/sender/LoggingDataSender.java    | 23 +++++++++++++++++++
 .../java/com/profiler/SystemMonitorTest.java  | 13 +++++++++--
 3 files changed, 37 insertions(+), 5 deletions(-)
 create mode 100644 src/main/java/com/profiler/sender/LoggingDataSender.java

diff --git a/src/main/java/com/profiler/SystemMonitor.java b/src/main/java/com/profiler/SystemMonitor.java
index dcb356d77..973a74212 100644
--- a/src/main/java/com/profiler/SystemMonitor.java
+++ b/src/main/java/com/profiler/SystemMonitor.java
@@ -45,8 +45,8 @@ public class SystemMonitor {
     public SystemMonitor() {
     }
 
-    public void setDataSender(DataSender udpDataSender) {
-        this.dataSender = udpDataSender;
+    public void setDataSender(DataSender dataSender) {
+        this.dataSender = dataSender;
     }
 
     public void start() {
@@ -59,7 +59,7 @@ public class SystemMonitor {
         executor.shutdown();
     }
 
-    static class Worker implements Runnable {
+    private static class Worker implements Runnable {
 
         private DataSender dataSender;
 
diff --git a/src/main/java/com/profiler/sender/LoggingDataSender.java b/src/main/java/com/profiler/sender/LoggingDataSender.java
new file mode 100644
index 000000000..2035a5120
--- /dev/null
+++ b/src/main/java/com/profiler/sender/LoggingDataSender.java
@@ -0,0 +1,23 @@
+package com.profiler.sender;
+
+import org.apache.thrift.TBase;
+
+import java.util.logging.Logger;
+
+/**
+ *
+ */
+public class LoggingDataSender implements DataSender {
+    private Logger logger = Logger.getLogger(this.getClass().getName());
+
+    @Override
+    public boolean send(TBase<?, ?> data) {
+        logger.info("send tBase:" + data);
+        return true;
+    }
+
+    @Override
+    public void stop() {
+
+    }
+}
diff --git a/src/test/java/com/profiler/SystemMonitorTest.java b/src/test/java/com/profiler/SystemMonitorTest.java
index ec9b94e23..3efd7f4c1 100644
--- a/src/test/java/com/profiler/SystemMonitorTest.java
+++ b/src/test/java/com/profiler/SystemMonitorTest.java
@@ -1,5 +1,7 @@
 package com.profiler;
 
+import com.profiler.sender.DataSender;
+import com.profiler.sender.LoggingDataSender;
 import org.junit.Test;
 
 /**
@@ -12,8 +14,15 @@ import org.junit.Test;
 public class SystemMonitorTest {
     @Test
     public void testStart() throws Exception {
-        SystemMonitor.Worker systemMonitor = new SystemMonitor.Worker();
-        systemMonitor.run();
+        DataSender loggingDataSender = new LoggingDataSender();
+
+        SystemMonitor systemMonitor = new SystemMonitor();
+        systemMonitor.setDataSender(loggingDataSender);
+        systemMonitor.start();
+
+        Thread.sleep(10000);
+
+        systemMonitor.stop();
     }
 
     @Test