in src/main/java/com/aliyun/mns/model/serialize/queue/QueueArrayDeserializer.java [37:64]
public PagingListResult<QueueMeta> deserialize(InputStream stream)
throws Exception {
// byte[] bytes = new byte[1024];
// while(stream.read(bytes, 0, stream.available())>0){
// System.out.println(new String(bytes));
// }
Document doc = getDocumentBuilder().parse(stream);
NodeList list = doc.getElementsByTagName(QUEUE_TAG);
List<QueueMeta> queues = new ArrayList<QueueMeta>();
for (int i = 0; i < list.getLength(); i++) {
Element e = (Element) list.item(i);
queues.add(parseQueueMeta(e));
}
PagingListResult<QueueMeta> result = null;
if (queues.size() > 0) {
result = new PagingListResult<QueueMeta>();
list = doc.getElementsByTagName(NEXT_MARKER_TAG);
if (list.getLength() > 0) {
result.setMarker(list.item(0).getTextContent());
}
result.setResult(queues);
}
return result;
}