TelldusLiveDeviceController.java 文件源码

private <T> T innerCallRest(String uri, Class<T> response) throws InterruptedException, ExecutionException,
        TimeoutException, JAXBException, FactoryConfigurationError, XMLStreamException {
    Future<Response> future = client.prepareGet(uri).execute();
    Response resp = future.get(REQUEST_TIMEOUT_MS, TimeUnit.MILLISECONDS);
    // TelldusLiveHandler.logger.info("Devices" + resp.getResponseBody());
    JAXBContext jc = JAXBContext.newInstance(response);
    XMLInputFactory xif = XMLInputFactory.newInstance();
    XMLStreamReader xsr = xif.createXMLStreamReader(resp.getResponseBodyAsStream());
    // xsr = new PropertyRenamerDelegate(xsr);

    @SuppressWarnings("unchecked")
    T obj = (T) jc.createUnmarshaller().unmarshal(xsr);
    if (logger.isTraceEnabled()) {
        logger.trace("Request [{}] Response:{}", uri, resp.getResponseBody());
    }
    return obj;
}