add dao to work with logstash tcp

src/main/java/jenkins/plugins/logstash/configuration/Logstash.java

@@ -0,0 +1,39 @@
+package jenkins.plugins.logstash.configuration;
+
+import org.kohsuke.stapler.DataBoundConstructor;
+
+import hudson.Extension;
+import jenkins.plugins.logstash.persistence.LogstashDao;
+
+public class Logstash extends HostBasedLogstashIndexer<LogstashDao>
+{
+
+  @DataBoundConstructor
+  public Logstash()
+  {
+  }
+
+  @Override
+  protected LogstashDao createIndexerInstance()
+  {
+    return new LogstashDao(getHost(), getPort());
+  }
+
+  @Extension
+  public static class Descriptor extends LogstashIndexerDescriptor
+  {
+
+    @Override
+    public String getDisplayName()
+    {
+      return "Logstash";
+    }
+
+    @Override
+    public int getDefaultPort()
+    {
+      return 9000;
+    }
+
+  }
+}

src/main/java/jenkins/plugins/logstash/persistence/LogstashDao.java

@@ -0,0 +1,26 @@
+package jenkins.plugins.logstash.persistence;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.Socket;
+import java.nio.charset.StandardCharsets;
+
+public class LogstashDao extends HostBasedLogstashIndexerDao {
+
+  public LogstashDao(String logstashHostString, int logstashPortInt) {
+    super(logstashHostString, logstashPortInt);
+  }
+
+  @Override
+  public void push(String data) throws IOException {
+
+    try (Socket logstashClientSocket = new Socket(getHost(), getPort()))
+    {
+      OutputStream out = logstashClientSocket.getOutputStream();
+      out.write(data.getBytes(StandardCharsets.UTF_8));
+      out.write(10);
+      out.flush();
+      out.close();
+    }
+  }
+}

src/test/java/jenkins/plugins/logstash/persistence/LogstashDaoTest.java

@@ -0,0 +1,65 @@
+package jenkins.plugins.logstash.persistence;
+
+import static org.junit.Assert.assertEquals;
+import static org.mockito.Mockito.*;
+
+import java.io.IOException;
+import java.net.SocketException;
+import java.nio.charset.Charset;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang.exception.ExceptionUtils;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+
+import com.rabbitmq.client.AuthenticationFailureException;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+
+@RunWith(MockitoJUnitRunner.class)
+public class LogstashDaoTest {
+  LogstashDao dao;
+
+  LogstashDao createDao(String host, int port) {
+    LogstashDao factory = new LogstashDao(host, port);
+
+    factory.setCharset(Charset.defaultCharset());
+
+    return factory;
+  }
+
+  @Test(expected = IllegalArgumentException.class)
+  public void constructorFailNullHost() throws Exception {
+    try {
+      createDao(null, 9000);
+    } catch (IllegalArgumentException e) {
+      assertEquals("Wrong error message was thrown", "host name is required", e.getMessage());
+      throw e;
+    }
+  }
+
+  @Test(expected = IllegalArgumentException.class)
+  public void constructorFailEmptyHost() throws Exception {
+    try {
+      createDao(" ", 9000);
+    } catch (IllegalArgumentException e) {
+      assertEquals("Wrong error message was thrown", "host name is required", e.getMessage());
+      throw e;
+    }
+  }
+
+  @Test
+  public void constructorSuccess() throws Exception {
+    // Unit under test
+    dao = createDao("localhost", 5672);
+
+    // Verify results
+    assertEquals("Wrong host name", "localhost", dao.getHost());
+    assertEquals("Wrong port", 5672, dao.getPort());
+  }
+}