Управление элементами и событиями системы подразумевает под собой отбор типов событий, которые нужно получать, получение событий и их дальнейшую обработку.
Внимание! Для запуска данного примера на Wialon Kit следует заменить http://hst-api.wialon.com на http://kit-api.wialon.com.
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(); } }
|