updated for compatability with meteor 0.5.7 DDP spec

Author: kutrumbo

src/me/kutrumbos/DdpClient.java

@@ -23,12 +23,15 @@ public class DdpClient extends Observable {
 	private final WebSocketClient wsClient;
 	private final Gson gson = new Gson();
 
+	private final static String DDP_PROTOCOL_VERSION = "pre1";
+	
 	/**
 	 * Field names supported in the DDP protocol
 	 *
 	 */
 	public enum DdpMessageField {
-		MSG("msg"), ID("id"), METHOD("method"), PARAMS("params"), NAME("name"), SERVER_ID("server_id");
+		MSG("msg"), ID("id"), METHOD("method"), PARAMS("params"), NAME("name"), SERVER_ID("server_id"),
+		SESSION("session"), VERSION("version"), SUPPORT("support");
 
 		private String fieldId;
 
@@ -86,6 +89,8 @@ private void connectionOpened() {
 		System.out.println("WebSocket connection opened");
 		Map<DdpMessageField,Object> connectMsg = new HashMap<DdpMessageField,Object>();
 		connectMsg.put(DdpMessageField.MSG, "connect");
+		connectMsg.put(DdpMessageField.VERSION, DDP_PROTOCOL_VERSION);
+		connectMsg.put(DdpMessageField.SUPPORT, new String[]{DDP_PROTOCOL_VERSION});
 		send(connectMsg);
 	}
 

src/me/kutrumbos/examples/DdpClientExample.java

@@ -1,6 +1,7 @@
 package me.kutrumbos.examples;
 
 import java.net.URISyntaxException;
+import java.util.Date;
 import java.util.Observer;
 
 import me.kutrumbos.DdpClient;
@@ -32,11 +33,26 @@ public static void main(String[] args) {
 
 			// make connection to Meteor server
 			ddp.connect();
+			
+			while(true) {
+				try {
+					Thread.sleep(5000);
+
+					System.out.println("calling remote method...");
+					
+					Object[] methodArgs = new Object[1];
+					methodArgs[0] = new Date().toString();
+					ddp.call("update_time", methodArgs);
+
+				} catch (InterruptedException e) {
+					
+					e.printStackTrace();
+				}
+			}
 
 		} catch (URISyntaxException e) {
 			e.printStackTrace();
-		}
-			
+		}			
 	}
 
 

src/me/kutrumbos/examples/DdpMultiClientTestExample.java

@@ -0,0 +1,51 @@
+package me.kutrumbos.examples;
+
+import java.net.URISyntaxException;
+import java.util.Observer;
+
+import me.kutrumbos.DdpClient;
+
+/**
+ * Simple example of DDP client use-case that just involves 
+ * 		making a connection to a locally hosted Meteor server
+ * @author peterkutrumbos
+ *
+ */
+public class DdpMultiClientTestExample {
+
+	public static void main(String[] args) {
+		
+		// specify location of Meteor server (assumes it is running locally) 
+		String meteorIp = "localhost";
+		Integer meteorPort = 3000;
+
+		try {
+			
+			// create DDP client instance
+			DdpClient ddp = new DdpClient(meteorIp, meteorPort);
+			
+			// create DDP client observer
+			Observer obs = new SimpleDdpClientObserver();
+			
+			// add observer
+			ddp.addObserver(obs);
+						
+			// make connection to Meteor server
+			ddp.connect();
+			
+			Thread.sleep(1000);
+			
+			ddp.subscribe("allPositions", new Object[]{});
+					
+		} catch (URISyntaxException e) {
+			e.printStackTrace();
+		} catch (InterruptedException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+			
+	}
+
+	
+	
+}