Java 类com.google.gwt.user.client.rpc.impl.RequestCallbackAdapter.ResponseReader 实例源码

项目：gwt-syncproxy 文件：RemoteServiceInvocationHandler.java

private ResponseReader getReaderFor(Class<?> type) {
    this.logger.finer("Getting reader for: " + type.getName());
    ResponseReader primitiveResponseReader = JPRIMITIVETYPE_TO_RESPONSEREADER
            .get(type);
    if (primitiveResponseReader != null) {
        return primitiveResponseReader;
    }

    if (type == String.class) {
        return ResponseReader.STRING;
    }
    if (type == Void.class || type == void.class) {
        return ResponseReader.VOID;
    }

    return ResponseReader.OBJECT;
}

项目：OpenNMS 文件：EventService_Proxy.java

public void addEvent(de.novanic.eventservice.client.event.domain.Domain aDomain, de.novanic.eventservice.client.event.Event anEvent, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.addEvent", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("addEvent");
    streamWriter.writeInt(2);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeString("de.novanic.eventservice.client.event.Event");
    streamWriter.writeObject(aDomain);
    streamWriter.writeObject(anEvent);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.addEvent",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.addEvent", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void addEventUserSpecific(de.novanic.eventservice.client.event.Event anEvent, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.addEventUserSpecific", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("addEventUserSpecific");
    streamWriter.writeInt(1);
    streamWriter.writeString("de.novanic.eventservice.client.event.Event");
    streamWriter.writeObject(anEvent);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.addEventUserSpecific",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.addEventUserSpecific", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void deregisterEventFilter(de.novanic.eventservice.client.event.domain.Domain aDomain, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.deregisterEventFilter", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("deregisterEventFilter");
    streamWriter.writeInt(1);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeObject(aDomain);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.deregisterEventFilter",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.deregisterEventFilter", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void getActiveListenDomains(com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.getActiveListenDomains", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getActiveListenDomains");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.getActiveListenDomains",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "EventService_Proxy.getActiveListenDomains", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void getEventFilter(de.novanic.eventservice.client.event.domain.Domain aDomain, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.getEventFilter", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getEventFilter");
    streamWriter.writeInt(1);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeObject(aDomain);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.getEventFilter",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "EventService_Proxy.getEventFilter", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void initEventService(com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.initEventService", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("initEventService");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.initEventService",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.initEventService", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void isUserRegistered(de.novanic.eventservice.client.event.domain.Domain aDomain, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.isUserRegistered", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("isUserRegistered");
    streamWriter.writeInt(1);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeObject(aDomain);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.isUserRegistered",  "requestSerialized"));
    doInvoke(ResponseReader.BOOLEAN, "EventService_Proxy.isUserRegistered", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void listen(com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.listen", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("listen");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.listen",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "EventService_Proxy.listen", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void register(de.novanic.eventservice.client.event.domain.Domain aDomain, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("register");
    streamWriter.writeInt(1);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeObject(aDomain);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.register", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void register(de.novanic.eventservice.client.event.domain.Domain aDomain, de.novanic.eventservice.client.event.filter.EventFilter anEventFilter, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("register");
    streamWriter.writeInt(2);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeString("de.novanic.eventservice.client.event.filter.EventFilter");
    streamWriter.writeObject(aDomain);
    streamWriter.writeObject(anEventFilter);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.register", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void register(java.util.Set aDomains, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("register");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.util.Set");
    streamWriter.writeObject(aDomains);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.register", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void register(java.util.Set aDomains, de.novanic.eventservice.client.event.filter.EventFilter anEventFilter, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("register");
    streamWriter.writeInt(2);
    streamWriter.writeString("java.util.Set");
    streamWriter.writeString("de.novanic.eventservice.client.event.filter.EventFilter");
    streamWriter.writeObject(aDomains);
    streamWriter.writeObject(anEventFilter);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.register",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.register", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void registerEventFilter(de.novanic.eventservice.client.event.domain.Domain aDomain, de.novanic.eventservice.client.event.filter.EventFilter anEventFilter, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.registerEventFilter", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("registerEventFilter");
    streamWriter.writeInt(2);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeString("de.novanic.eventservice.client.event.filter.EventFilter");
    streamWriter.writeObject(aDomain);
    streamWriter.writeObject(anEventFilter);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.registerEventFilter",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.registerEventFilter", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void registerUnlistenEvent(de.novanic.eventservice.client.event.listener.unlisten.UnlistenEventListener.Scope anUnlistenScope, de.novanic.eventservice.client.event.listener.unlisten.UnlistenEvent anUnlistenEvent, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.registerUnlistenEvent", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("registerUnlistenEvent");
    streamWriter.writeInt(2);
    streamWriter.writeString("de.novanic.eventservice.client.event.listener.unlisten.UnlistenEventListener$Scope/4054018674");
    streamWriter.writeString("de.novanic.eventservice.client.event.listener.unlisten.UnlistenEvent");
    streamWriter.writeObject(anUnlistenScope);
    streamWriter.writeObject(anUnlistenEvent);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.registerUnlistenEvent",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.registerUnlistenEvent", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void unlisten(com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.unlisten", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("unlisten");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.unlisten",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.unlisten", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void unlisten(de.novanic.eventservice.client.event.domain.Domain aDomain, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.unlisten", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("unlisten");
    streamWriter.writeInt(1);
    streamWriter.writeString("de.novanic.eventservice.client.event.domain.Domain");
    streamWriter.writeObject(aDomain);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.unlisten",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.unlisten", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：EventService_Proxy.java

public void unlisten(java.util.Set aDomains, com.google.gwt.user.client.rpc.AsyncCallback async) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.unlisten", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("unlisten");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.util.Set");
    streamWriter.writeObject(aDomains);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("EventService_Proxy.unlisten",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "EventService_Proxy.unlisten", statsContext, payload, async);
  } catch (SerializationException ex) {
    async.onFailure(ex);
  }
}

项目：OpenNMS 文件：LocationStatusService_Proxy.java

public void getApplicationDetails(java.lang.String applicationName, com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getApplicationDetails", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getApplicationDetails");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.lang.String/2004016611");
    streamWriter.writeString(applicationName);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getApplicationDetails",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "LocationStatusService_Proxy.getApplicationDetails", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：OpenNMS 文件：LocationStatusService_Proxy.java

public void getApplicationInfo(java.lang.String applicationName, com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getApplicationInfo", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getApplicationInfo");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.lang.String/2004016611");
    streamWriter.writeString(applicationName);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getApplicationInfo",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "LocationStatusService_Proxy.getApplicationInfo", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：OpenNMS 文件：LocationStatusService_Proxy.java

public void getLocationDetails(java.lang.String locationName, com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getLocationDetails", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getLocationDetails");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.lang.String/2004016611");
    streamWriter.writeString(locationName);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getLocationDetails",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "LocationStatusService_Proxy.getLocationDetails", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：OpenNMS 文件：LocationStatusService_Proxy.java

public void getLocationInfo(java.lang.String locationName, com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getLocationInfo", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getLocationInfo");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.lang.String/2004016611");
    streamWriter.writeString(locationName);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.getLocationInfo",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "LocationStatusService_Proxy.getLocationInfo", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：OpenNMS 文件：LocationStatusService_Proxy.java

public void start(com.google.gwt.user.client.rpc.AsyncCallback anAsyncCallback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.start", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("start");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("LocationStatusService_Proxy.start",  "requestSerialized"));
    doInvoke(ResponseReader.VOID, "LocationStatusService_Proxy.start", statsContext, payload, anAsyncCallback);
  } catch (SerializationException ex) {
    anAsyncCallback.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getAlarmsForSet(org.opennms.dashboard.client.SurveillanceSet set, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getAlarmsForSet", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getAlarmsForSet");
    streamWriter.writeInt(1);
    streamWriter.writeString("org.opennms.dashboard.client.SurveillanceSet/3355889218");
    streamWriter.writeObject(set);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getAlarmsForSet",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getAlarmsForSet", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getChildResources(java.lang.String resourceId, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getChildResources", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getChildResources");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.lang.String/2004016611");
    streamWriter.writeString(resourceId);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getChildResources",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getChildResources", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getNodeNames(org.opennms.dashboard.client.SurveillanceSet set, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getNodeNames", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getNodeNames");
    streamWriter.writeInt(1);
    streamWriter.writeString("org.opennms.dashboard.client.SurveillanceSet/3355889218");
    streamWriter.writeObject(set);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getNodeNames",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getNodeNames", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getNotificationsForSet(org.opennms.dashboard.client.SurveillanceSet set, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getNotificationsForSet", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getNotificationsForSet");
    streamWriter.writeInt(1);
    streamWriter.writeString("org.opennms.dashboard.client.SurveillanceSet/3355889218");
    streamWriter.writeObject(set);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getNotificationsForSet",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getNotificationsForSet", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getPrefabGraphs(java.lang.String resourceId, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getPrefabGraphs", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getPrefabGraphs");
    streamWriter.writeInt(1);
    streamWriter.writeString("java.lang.String/2004016611");
    streamWriter.writeString(resourceId);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getPrefabGraphs",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getPrefabGraphs", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getResources(org.opennms.dashboard.client.SurveillanceSet set, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getResources", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getResources");
    streamWriter.writeInt(1);
    streamWriter.writeString("org.opennms.dashboard.client.SurveillanceSet/3355889218");
    streamWriter.writeObject(set);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getResources",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getResources", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getRtcForSet(org.opennms.dashboard.client.SurveillanceSet set, com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getRtcForSet", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getRtcForSet");
    streamWriter.writeInt(1);
    streamWriter.writeString("org.opennms.dashboard.client.SurveillanceSet/3355889218");
    streamWriter.writeObject(set);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getRtcForSet",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getRtcForSet", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：SurveillanceService_Proxy.java

public void getSurveillanceData(com.google.gwt.user.client.rpc.AsyncCallback cb) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getSurveillanceData", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getSurveillanceData");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("SurveillanceService_Proxy.getSurveillanceData",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "SurveillanceService_Proxy.getSurveillanceData", statsContext, payload, cb);
  } catch (SerializationException ex) {
    cb.onFailure(ex);
  }
}

项目：OpenNMS 文件：AssetService_Proxy.java

public void getAssetByNodeId(int nodeId, com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("AssetService_Proxy.getAssetByNodeId", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getAssetByNodeId");
    streamWriter.writeInt(1);
    streamWriter.writeString("I");
    streamWriter.writeInt(nodeId);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("AssetService_Proxy.getAssetByNodeId",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "AssetService_Proxy.getAssetByNodeId", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：OpenNMS 文件：AssetService_Proxy.java

public void getAssetSuggestions(com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("AssetService_Proxy.getAssetSuggestions", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("getAssetSuggestions");
    streamWriter.writeInt(0);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("AssetService_Proxy.getAssetSuggestions",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "AssetService_Proxy.getAssetSuggestions", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：OpenNMS 文件：AssetService_Proxy.java

public void saveOrUpdateAssetByNodeId(int nodeId, org.opennms.gwt.web.ui.asset.shared.AssetCommand asset, com.google.gwt.user.client.rpc.AsyncCallback callback) {
  RpcStatsContext statsContext = new RpcStatsContext();
  boolean toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("AssetService_Proxy.saveOrUpdateAssetByNodeId", "begin"));
  SerializationStreamWriter streamWriter = createStreamWriter();
  // createStreamWriter() prepared the stream
  try {
    if (getRpcToken() != null) {
      streamWriter.writeObject(getRpcToken());
    }
    streamWriter.writeString(REMOTE_SERVICE_INTERFACE_NAME);
    streamWriter.writeString("saveOrUpdateAssetByNodeId");
    streamWriter.writeInt(2);
    streamWriter.writeString("I");
    streamWriter.writeString("org.opennms.gwt.web.ui.asset.shared.AssetCommand/2836854699");
    streamWriter.writeInt(nodeId);
    streamWriter.writeObject(asset);
    String payload = streamWriter.toString();
    toss = statsContext.isStatsAvailable() && statsContext.stats(statsContext.timeStat("AssetService_Proxy.saveOrUpdateAssetByNodeId",  "requestSerialized"));
    doInvoke(ResponseReader.OBJECT, "AssetService_Proxy.saveOrUpdateAssetByNodeId", statsContext, payload, callback);
  } catch (SerializationException ex) {
    callback.onFailure(ex);
  }
}

项目：unitimes 文件：GwtRpcProxy.java

@Override
   protected <T> Request doInvoke(ResponseReader responseReader, final String methodName, RpcStatsContext statsContext, String requestData, final AsyncCallback<T> callback) {
    return super.doInvoke(responseReader, methodName, statsContext, requestData, new AsyncCallback<T>() {
        @Override
        public void onFailure(Throwable caught) {
            UniTimeNotifications.error("Request " + methodName.replace("_Proxy", "") + " failed: " + caught.getMessage(), caught);
            callback.onFailure(caught);
        }
        @Override
        public void onSuccess(T result) {
            callback.onSuccess(result);
        }
    });
}

项目：unitime 文件：GwtRpcProxy.java

@Override
   protected <T> Request doInvoke(ResponseReader responseReader, final String methodName, RpcStatsContext statsContext, String requestData, final AsyncCallback<T> callback) {
    return super.doInvoke(responseReader, methodName, statsContext, requestData, new AsyncCallback<T>() {
        @Override
        public void onFailure(Throwable caught) {
            UniTimeNotifications.error("Request " + methodName.replace("_Proxy", "") + " failed: " + caught.getMessage(), caught);
            callback.onFailure(caught);
        }
        @Override
        public void onSuccess(T result) {
            callback.onSuccess(result);
        }
    });
}