package nl.justobjects.pushlet.test;

import nl.justobjects.pushlet.client.PushletClient;
import nl.justobjects.pushlet.client.PushletClientListener;
import nl.justobjects.pushlet.core.Event;
import nl.justobjects.pushlet.core.Protocol;
import nl.justobjects.pushlet.util.PushletException;

public class PushTest implements Protocol, PushletClientListener {

	/** Error occurred. */
	public void onError(String message) {
		p(message);
	}

	/** Abort event from server. */
	public void onAbort(Event theEvent) {
		p("onAbort received: " + theEvent);
	}

	/** Data event from server. */
	public void onData(Event theEvent) {
		// Calculate round trip delay
		System.out.println("onData output is --------");
		System.out.println("theEvent.toXML() : " + theEvent.toXML());
		System.out.println("theEvent.toQueryString() : " + theEvent.toQueryString());
		System.out.println("----Stock name--- : " + theEvent.getField("name"));
		System.out.println("----Stock rate--- : :" + theEvent.getField("rate"));
		System.out.println();
	}

	/** Heartbeat event from server. */
	public void onHeartbeat(Event theEvent) {
		p("onHeartbeat received: " + theEvent);
	}
	
	public PushTest() {
		String SUBJECT = "/stocks/aexonlinewispy";
		final String MODE = Protocol.MODE_STREAM;
//		 Create and start a Pushlet client; we receive callbacks
		// through onHeartbeat() and onData().
		String aHost = "localhost";
		int aPort = 8080;
		try {
			PushletClient pushletClient = new PushletClient(aHost, aPort);
			pushletClient.setDebug(true);
			pushletClient.join();
			pushletClient.listen(this, MODE, SUBJECT);
			p("pushletClient started");
		} catch (PushletException pe) {
			p("Error in setting up pushlet session pe=" + pe);
		}
	}
	
	public static void main(String[] args) {
		new PushTest();
	}
	
	public static void p(String string){
		System.out.println("string");
	}

}