public InputStream serialize()

in src/main/java/com/aliyun/mns/model/serialize/queue/QueueMetaSerializer.java [42:88]

38 lines of code
7 McCabe index (conditional complexity)


    public InputStream serialize(QueueMeta obj, String encoding)
        throws Exception {
        Document doc = getDocumentBuilder().newDocument();

        Element root = doc.createElementNS(DEFAULT_XML_NAMESPACE, QUEUE_TAG);
        doc.appendChild(root);

        Element node = safeCreateContentElement(doc, DELAY_SECONDS_TAG,
            obj.getDelaySeconds(), null);
        if (node != null) {
            root.appendChild(node);
        }

        node = safeCreateContentElement(doc, VISIBILITY_TIMEOUT,
            obj.getVisibilityTimeout(), null);
        if (node != null) {
            root.appendChild(node);
        }

        node = safeCreateContentElement(doc, MAX_MESSAGE_SIZE_TAG,
            obj.getMaxMessageSize(), null);
        if (node != null) {
            root.appendChild(node);
        }

        node = safeCreateContentElement(doc, MESSAGE_RETENTION_PERIOD_TAG,
            obj.getMessageRetentionPeriod(), null);
        if (node != null) {
            root.appendChild(node);
        }

        node = safeCreateContentElement(doc, POLLING_WAITSECONDS_TAG,
            obj.getPollingWaitSeconds(), null);
        if (node != null) {
            root.appendChild(node);
        }

        node = safeCreateContentElement(doc, LOGGING_ENABLED_TAG,
            obj.isLoggingEnabled(), null);
        if (node != null) {
            root.appendChild(node);
        }

        String xml = XmlUtil.xmlNodeToString(doc, encoding);

        return new ByteArrayInputStream(xml.getBytes(encoding));
    }