|
|
|
en:local:javaapi:codesamples:update_datafalags [20/05/2014 11:49]
|
en:local:javaapi:codesamples:update_datafalags [20/05/2014 11:49] (current)
|
| | {{indexmenu_n>3}} |
| | ====== 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 **<nowiki>http://hst-api.wialon.com</nowiki>** for **<nowiki>http://kit-api.wialon.com</nowiki>** in all requests and use user name and password of your account to login to the system or name and password of demo user //**kitdemo kitdemo**//. |
| | |
| | <code java> |
| | |
| | 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.login("wialon_test", "test", 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(); |
| | } |
| | } |
| | </code> |
