Item events management

Management of system items and events allows to choose types of events to be received, get these events and process them.

Attention! To launch this example at Wialon Kit, change http://hst-api.wialon.com to http://kit-api.wialon.com in all requests.

package com.wialon.java.test;
 
import com.wialon.core.Errors;
import com.wialon.core.EventHandler;
import com.wialon.core.EventProvider;
import com.wialon.core.Session;
import com.wialon.extra.UpdateSpec;
import com.wialon.item.Item;
import com.wialon.item.Unit;
import com.wialon.remote.handlers.ResponseHandler;
 
import java.io.IOException;
import java.util.Collection;
 
public class EventsManagementExample implements Runnable {
	private Session session;
 
	// Login to server
	private void login(){
		// initialize Wialon session
		session.initSession("http://hst-api.wialon.com");
		// trying login
		session.loginToken("2fe8024e0ab91aa6c8ed82717b71bddcECDC362358DF7D90986F5173D405CD0D42DE7B38", new ResponseHandler() {
			@Override
			public void onSuccess(String response) {
				super.onSuccess(response);
				// login succeed
				System.out.println(String.format("Logged successfully. User name is %s", session.getCurrUser().getName()));
				//call update data flags
				updateDataFlags();
			}
 
			@Override
			public void onFailure(int errorCode, Throwable throwableError) {
				super.onFailure(errorCode, throwableError);
				// login failed, print error
				System.out.println(Errors.getErrorText(errorCode));
			}
		});
	}
 
	private void updateDataFlags(){
		//Create new update specification
		UpdateSpec updateSpec=new UpdateSpec();
		//Set update mode to add specified flags
		updateSpec.setMode(1);
		//Set update type by type
		updateSpec.setType("type");
		//Set update data to units
		updateSpec.setData(Item.ItemType.avl_unit);
		//Set update data flags
		updateSpec.setFlags(Item.dataFlag.base.getValue()| Unit.dataFlag.lastMessage.getValue());
		//Send update by created update specification
		session.updateDataFlags(new UpdateSpec[]{updateSpec}, new ResponseHandler() {
			@Override
			public void onSuccess(String response) {
				super.onSuccess(response);
				// Update succeed
				System.out.println("Update data flags is successful");
				bindEventsHandler();
			}
			@Override
			public void onFailure(int errorCode, Throwable throwableError) {
				super.onFailure(errorCode, throwableError);
				// update data flags failed, print error
				System.out.println(Errors.getErrorText(errorCode));
				logout();
			}
		});
	}
 
	private void bindEventsHandler(){
		//Get items from session
		Collection<Item> sessionItems=session.getItems();
		//Create events handler
		EventsHandlerExample eventsHandlerExample=new EventsHandlerExample();
		//Add handler to session
		session.addListener(eventsHandlerExample, EventProvider.events.All);
		if (sessionItems!=null && sessionItems.size()>0) {
			System.out.println(String.format("%d items added to Session\r\nStart binding event listeners to items", sessionItems.size()));
			//Add handler to items
			for (Item item : sessionItems)
				item.addListener(eventsHandlerExample, EventProvider.events.All);
			System.out.println("Event listeners successfully bound to items\r\nPress enter to logout and exit");
		}
		//Wait for press enter key
		try {
			System.in.read();
			logout();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	// Logout
	private void logout(){
		session.logout(new ResponseHandler() {
			@Override
			public void onSuccess(String response) {
				super.onSuccess(response);
				// logout succeed
				System.out.println("Logout successfully");
				System.exit(0);
			}
			@Override
			public void onFailure(int errorCode, Throwable throwableError) {
				super.onFailure(errorCode, throwableError);
				// logout failed, print error
				System.out.println(Errors.getErrorText(errorCode));
				System.exit(0);
			}
		});
	}
	//EventHandler witch listen bound event types
	private class EventsHandlerExample implements EventHandler{
		@Override
		public void onEvent(Enum event, Object object, Object oldData, Object newData) {
			String objectValue= object==null ? "null" : object.toString();
			String oldDataValue= oldData==null ? "null" : oldData.toString();
			String newDataValue= newData==null ? "null" : newData.toString();
			System.out.println(String.format("Fired event with type %s, object is %s, oldData is %s, newData is %s", event, objectValue, oldDataValue, newDataValue));
		}
	}
 
	@Override
	public void run() {
		// get instance of current Session
		session=Session.getInstance();
		login();
	}
 
	public static void main(String[] args){
		new Thread(new EventsManagementExample()).start();
	}
}