added protocol mod

leonlee · Dec 13, 2012 · caa47ae · caa47ae
1 parent 8377608
commit caa47ae
Show file tree

Hide file tree

Showing 4 changed files with 33 additions and 1 deletion.
diff --git a/protocol/build.gradle b/protocol/build.gradle
@@ -0,0 +1,3 @@
+dependencies {
+             compile 'org.msgpack:msgpack:0.6.7'
+}
diff --git a/protocol/gradle.properties b/protocol/gradle.properties
@@ -0,0 +1 @@
+modulename=org.riderzen.ogs.protocol
diff --git a/protocol/src/main/groovy/org/riderzen/ogs/protocol/ProtocolParser.groovy b/protocol/src/main/groovy/org/riderzen/ogs/protocol/ProtocolParser.groovy
@@ -0,0 +1,28 @@
+package org.riderzen.ogs.protocol
+
+import org.vertx.groovy.core.parsetools.RecordParser
+import org.vertx.java.busmods.BusModBase
+
+/**
+ * User: Leon Lee <mail.lgq@gmail.com>
+ * Created On: 12-12-11
+ */
+class ProtocolParser extends BusModBase {
+    String address;
+    RecordParser parser;
+
+    @Override
+    void start() {
+        super.start()
+
+        init()
+    }
+
+    def init() {
+        address = getOptionalStringConfig("address", "org.riderzen.ogs.protocol")
+        eb.registerHandler(address) { message ->
+            logger.debug("received message $message")
+
+        }
+    }
+}
diff --git a/settings.gradle b/settings.gradle
@@ -1 +1 @@
-include 'bootstrap', 'tcp-server'
+include 'bootstrap', 'tcp-server', 'protocol'