JAVA - Worker APIs

public void tr50ReponseHandlingExamples(){
 
    DwMqttClient client = new DwMqttClient();
    client.initialize(MqttConstants.DEFAULT_MQTTHOST, true, "tr50_client_id");
    client.authenticate("myThingKey","myAppToken");
 
    StringReply replyString = new StringReply();                               //initialize String helper response Object
    DwOpenResponse respGen = new DwOpenResponse();                             //initialize Generic helper response Object
    DwOpenLocationEncodeDecode respExt = new DwOpenLocationEncodeDecode();     //initialize response Object
 
    // api call with string helper response object. No parsing of response JSON
    client.getWorker().Location().publish("myThingKey", TimeFormatter.toRFC3339(new Date(System.currentTimeMillis())), "zzz1", 30.455, -84.253333, 10.0, 15.2,30.1,5.3,"fixType", replyString);
 
    // api call with generic helper response object. Basic parsing of response JSON
    client.getWorker().Location().publish("myThingKey", TimeFormatter.toRFC3339(new Date(System.currentTimeMillis())), "corrId", 30.455, -84.253333, 10.0, 15.2,30.1,5.3,"fixType", respGen);
 
    // api call with extender helper response object. Extended parsing of response JSON
    client.getWorker().Location().decode(30.455, -84.253333, respExt);        
 
    System.out.println("JSON Response from deviceWISE Cloud for Location Publish = "+replyString.getValue());
 
    if(respGen.isSuccess())
       System.out.println("TR50 Location Publish API Call Successful!");
    else
       System.out.println("TR50 Location Publish API Call Failed with Error Message: "+respGen.getErrormessages()[0]+" Error Code: "+respGen.getErrorcodes()[0]);
    
    if(respExt.isSuccess()){
       System.out.println("TR50 Location Decode API Call Successful!");
       System.out.println("Location Latitude  = "+respExt.getLat());           //additional response helper functions available over generic DwOpenResponse helper functions
       System.out.println("Location Longitude = "+respExt.getLng());
       System.out.println("Location City      = "+respExt.getAddress().getCity());
       System.out.println("Location State     = "+respExt.getAddress().getState());
       System.out.println("Location Country   = "+respExt.getAddress().getCountry());
    }
    else{
       System.out.println("TR50 Location Decode API Call Failed with Error Message: "+respExt.getErrormessages()[0]+" Error Code: "+respExt.getErrorcodes()[0]);
    }
    client.disconnect();
}

public class DwOpenWorkerAsyncExample implements DwOpenReceiveActionListener, DwOpenSendActionListener, DwOpenDisconnectActionListener {
	public void tr50AsyncWorkerAPIExamples() throws IOException, DwOpenException, MqttException, InterruptedException {
		DwMqttClient client = new DwMqttClient();
		client.initialize(MqttConstants.DEFAULT_MQTTHOST, true, "tr50_client_id");
		client.authenticate("mythingkey", "myapptoken");

		client.registerDisconnectActionListener(this); //register for callbacks
		client.registerSendActionListener(this);
		client.registerReceiveActionListener(this);

		synchronized(this) {
			// api call with string helper response object. No parsing of response JSON
			client.getWorker().Location().publish("myThingKey", TimeFormatter.toRFC3339(new Date(System.currentTimeMillis())), "zzz1", 30.455, -84.253333, 10.0, 15.2, 30.1, 5.3, "fixType", this, new StringReply());
			this.wait();

			// api call with generic helper response object. Basic parsing of response JSON
			client.getWorker().Location().publish("myThingKey", TimeFormatter.toRFC3339(new Date(System.currentTimeMillis())), "corrId", 30.455, -84.253333, 10.0, 15.2, 30.1, 5.3, "fixType", this, new DwOpenResponse());
			this.wait();

			// api call with extender helper response object. Extended parsing of response JSON
			client.getWorker().Location().decode(30.455, -84.253333, this, new DwOpenLocationEncodeDecode());
			this.wait();
			}

			client.disconnect();
		}

			@Override
			public void onDisconnect(DwClient source, Throwable cause) {
				// TR50 disconnect handler
				}

			@Override
			public void onSend(DwClient source, int responseCode, Throwable cause, DwPacket packet) {
				// send TR50 message handler
				}
			@Override //handle response callbacks from async calls
			public void onReceive(DwClient source, int responseCode, Throwable cause, DwPacket packet, Object response) {
			synchronized(this) {
				if (response instanceof StringReply)
				System.out.println("JSON Response from deviceWISE Cloud for Location Publish = " + ((StringReply) response).getValue());

			else if (response instanceof DwOpenResponse) {
			DwOpenResponse respGen = (DwOpenResponse) response;
		if (respGen.isSuccess())
			System.out.println("TR50 Location Publish API Call Successful!");
				else
			System.out.println("TR50 Location Publish API Call Failed with Error Message: " + respGen.getErrormessages()[0] + " Error Code: " + respGen.getErrorcodes()[0]);
				} else if (response instanceof DwOpenLocationEncodeDecode) {
			DwOpenLocationEncodeDecode respExt = (DwOpenLocationEncodeDecode) response;

		if (respExt.isSuccess()) {
			System.out.println("TR50 Location Decode API Call Successful!");
			System.out.println("Location Latitude  = " + respExt.getLat()); //additional response helper functions available over generic DwOpenResponse helper functions
			System.out.println("Location Longitude = " + respExt.getLng());
			System.out.println("Location City      = " + respExt.getAddress().getCity());
			System.out.println("Location State     = " + respExt.getAddress().getState());
			System.out.println("Location Country   = " + respExt.getAddress().getCountry());
			} else {
			System.out.println("TR50 Location Decode API Call Failed with Error Message: " + respExt.getErrormessages()[0] + " Error Code: " + respExt.getErrorcodes()[0]);
			}
		}
		this.notify();
	}	
}
}