/* * Copyright (c) 2014, Isode Limited, London, England. * All rights reserved. */ /* * Copyright (c) 2014, Remko Tronçon. * All rights reserved. */ package com.isode.stroke.parser.payloadparsers; import com.isode.stroke.parser.AttributeMap; import com.isode.stroke.parser.GenericPayloadParser; import com.isode.stroke.parser.PayloadParser; import com.isode.stroke.parser.PayloadParserFactoryCollection; import com.isode.stroke.parser.PayloadParserFactory; import com.isode.stroke.elements.PubSubEventItem; public class PubSubEventItemParser extends GenericPayloadParser { public PubSubEventItemParser(PayloadParserFactoryCollection parsers) { super(new PubSubEventItem()); parsers_ = parsers; level_ = 0; } public void handleStartElement(String element, String ns, AttributeMap attributes) { if (level_ == 0) { String attributeValue; attributeValue = attributes.getAttribute("publisher"); if (!attributeValue.isEmpty()) { getPayloadInternal().setPublisher(attributeValue); } attributeValue = attributes.getAttribute("node"); if (!attributeValue.isEmpty()) { getPayloadInternal().setNode(attributeValue); } attributeValue = attributes.getAttribute("id"); if (!attributeValue.isEmpty()) { getPayloadInternal().setID(attributeValue); } } if (level_ == 1) { PayloadParserFactory factory; factory = parsers_.getPayloadParserFactory(element, ns, attributes); if (factory != null) { currentPayloadParser_ = factory.createPayloadParser(); } } if (level_ >= 1 && currentPayloadParser_ != null) { currentPayloadParser_.handleStartElement(element, ns, attributes); } ++level_; } public void handleEndElement(String element, String ns) { --level_; if (currentPayloadParser_ != null) { if (level_ >= 1) { currentPayloadParser_.handleEndElement(element, ns); } if (level_ != 1) { return; } getPayloadInternal().addData(currentPayloadParser_.getPayload()); currentPayloadParser_ = null; } } public void handleCharacterData(String data) { if (level_ > 1 && currentPayloadParser_ != null) { currentPayloadParser_.handleCharacterData(data); } } PayloadParserFactoryCollection parsers_; int level_; PayloadParser currentPayloadParser_; }