1 4 package nl.justobjects.pushlet.test; 5 6 import nl.justobjects.pushlet.client.PushletClient; 7 import nl.justobjects.pushlet.client.PushletClientListener; 8 import nl.justobjects.pushlet.core.Event; 9 import nl.justobjects.pushlet.core.Protocol; 10 import nl.justobjects.pushlet.util.PushletException; 11 12 import java.util.HashMap ; 13 import java.util.Map ; 14 15 25 public class SimpleListener implements PushletClientListener, Protocol { 26 private static final String SUBJECT = "/temperature"; 27 private static final String MODE = MODE_STREAM; 28 29 public SimpleListener(String aHost, int aPort) { 30 try { 33 PushletClient pushletClient = new PushletClient(aHost, aPort); 34 pushletClient.setDebug(true); 35 pushletClient.join(); 36 pushletClient.listen(this, MODE, SUBJECT); 37 p("pushletClient started"); 38 } catch (PushletException pe) { 39 p("Error in setting up pushlet session pe=" + pe); 40 } 41 } 42 43 44 public void onError(String message) { 45 p(message); 46 } 47 48 49 public void onAbort(Event theEvent) { 50 p("onAbort received: " + theEvent); 51 } 52 53 54 public void onData(Event theEvent) { 55 p("onData: " + theEvent); 57 } 58 59 60 public void onHeartbeat(Event theEvent) { 61 p("onHeartbeat received: " + theEvent); 62 } 63 64 65 public void p(String s) { 66 System.out.println("[SimpleListener] " + s); 67 } 68 69 70 public static void main(String args[]) { 71 if (args.length == 0) { 72 new SimpleListener("localhost", 8080); 73 } else { 74 new SimpleListener(args[0], Integer.parseInt(args[1])); 76 } 77 } 78 } 79 80 81 91 | Popular Tags |