first shot at mini-receiver and mini-parser java classes (for gui)

2 files changed, 26 insertions, 3 deletions

diff --git a/java/com/rsyslog/gui/simpServ/simpServ.java b/java/com/rsyslog/gui/simpServ/simpServ.java
index 56e4aaf1..5d248d90 100644
--- a/java/com/rsyslog/gui/simpServ/simpServ.java
+++ b/java/com/rsyslog/gui/simpServ/simpServ.java
@@ -1,7 +1,20 @@
-package com.rsyslog.gui;
+package com.rsyslog.gui.simpServ;
+import com.rsyslog.lib.*;
+import com.rsyslog.gui.*;
 
 public class simpServ {
-	public static void main(String[] args)  {
-		System.out.println("hello world\n");
+
+	public static void main(String args[]) {
+		try {
+			simpServConsumer cons = new simpServConsumer();
+			System.out.println("Starting server on port " + args[0] + "\n");
+			SyslogServerTCP myServ = new
+				SyslogServerTCP(Integer.parseInt(args[0]), cons);
+			myServ.start();
+			System.out.println("Press ctl-c to terminate\n");
+		}
+		catch(Exception e) {
+			System.out.println("Error: " + e.toString());
+		}
 	}
 }
diff --git a/java/com/rsyslog/gui/simpServ/simpServConsumer.java b/java/com/rsyslog/gui/simpServ/simpServConsumer.java
new file mode 100644
index 00000000..c7c576d7
--- /dev/null
+++ b/java/com/rsyslog/gui/simpServ/simpServConsumer.java
@@ -0,0 +1,10 @@
+/** A syslog message consumer for the simple syslog server. */
+package com.rsyslog.gui.simpServ;
+import com.rsyslog.lib.*;
+
+class simpServConsumer implements SyslogMsgConsumer {
+	public void consumeMsg(String ln) {
+		SyslogMessage msg = new SyslogMessage(ln);
+		System.out.println("Line received '" + msg.getRawMsgAfterPRI() + "'\n");
+	}
+}