1 files changed, 52 insertions, 0 deletions
diff --git a/src/main/java/com/orbekk/example/ExampleServer.java b/src/main/java/com/orbekk/example/ExampleServer.java
new file mode 100644
index 0000000..d842dbf
--- /dev/null
+++ b/src/main/java/com/orbekk/example/ExampleServer.java
@@ -0,0 +1,52 @@
+package com.orbekk.example;
+
+import java.util.Random;
+
+import com.google.protobuf.RpcCallback;
+import com.google.protobuf.RpcController;
+import com.orbekk.example.Example.Empty;
+import com.orbekk.example.Example.FortuneReply;
+import com.orbekk.protobuf.SimpleProtobufServer;
+
+public class ExampleServer {
+    public final static String fortunes[] = new String[] {
+      "  The difference between the right word and the almost right word is " +
+      "the difference between lightning and the lightning bug.  -- Mark Twain",
+      "You will lose your present job and have to become a door to door " +
+      "mayonnaise salesman.",
+      "You worry too much about your job.  Stop it.  You are not paid enough " +
+      "to worry."
+    };
+    
+    public class FortuneService extends Example.FortuneService {
+        Random random = new Random();
+        
+        @Override
+        public void getFortune(RpcController controller, Empty request,
+                RpcCallback<FortuneReply> done) {
+            String fortune = fortunes[random.nextInt(fortunes.length)];
+            FortuneReply.Builder reply =
+                    FortuneReply.newBuilder().setFortune(fortune);
+            done.run(reply.build());
+        }
+    }
+    
+    public void runServer(int port) {
+        SimpleProtobufServer server = SimpleProtobufServer.create(port);
+        server.registerService(new FortuneService());
+        server.start();
+        System.out.println("Running server on port " + server.getPort());
+        try {
+            server.join();
+        } catch (InterruptedException e) {
+        }
+    }
+    
+    public static void main(String[] args) {
+        int port = 0;
+        if (args.length > 0) {
+            port = Integer.valueOf(args[0]);
+        }
+        new ExampleServer().runServer(port);
+    }
+}