Examples of toStringWithConsume()


Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

        try {
            OMElement eprCrEl = EndpointReferenceHelper.toOM(OMAbstractFactory.getOMFactory(), encodedEpr, new QName(
                    "EndpointReference"), NameSpaceConstants.WSA_NS.getNamespaceURI());

            ret = eprCrEl.toStringWithConsume();

        } catch (Exception e) {
            logger.error("unable to convert broker url", e);
        }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

            }
        } else {

            topicLocalString = BrokerUtil.getTopicLocalString(topicEl.getText());
            try {
                topicElString = topicEl.toStringWithConsume();
            } catch (XMLStreamException e) {
                logger.error("exceptions occured at WSE eventing notification creating", e);
            }
            additionalMessageContent.setTopicElement(topicElString);
        }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

            throw new AxisFault("no message found");
        }

        String message = null;
        try {
            message = messageEl.toStringWithConsume();
        } catch (XMLStreamException e) {
            logger.error("unable to serialize the message", e);
            throw new AxisFault("unable to serialize the message", e);
        }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

                topicLocalString = BrokerUtil.getTopicLocalString(topicEl.getText()); // get what ever inside this
                                                                                      // element

                try {
                    topicElString = topicEl.toStringWithConsume();
                } catch (XMLStreamException e) {
                    logger.error("exception occured while creating NotificationConsumer", e);
                }
                additionalMessageContent.setTopicElement(topicElString);
            }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

            OMElement producerReferenceEl = wrappedMessageEl.getFirstChildWithName(new QName(NameSpaceConstants.WSNT_NS
                    .getNamespaceURI(), "ProducerReference"));

            if (producerReferenceEl != null) {
                try {
                    producerReferenceElString = producerReferenceEl.toStringWithConsume();
                } catch (XMLStreamException e) {
                    logger.error("exception occured while creating notification consumer", e);

                }
                additionalMessageContent.setProducerReference(producerReferenceElString);
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

            OMElement notificationMessageEl = wrappedMessageEl.getFirstChildWithName(
                    new QName(NameSpaceConstants.WSNT_NS.getNamespaceURI(), "Message")).getFirstElement();

            String message = null;
            try {
                message = notificationMessageEl.toStringWithConsume();
            } catch (XMLStreamException e) {
                logger.error("exception occured while creating notification consumer", e);
                throw new AxisFault("unable to serialize the message", e);
            }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

            for (Iterator<OMElement> ite = referenceParametersMap.values().iterator(); ite.hasNext();) {
                OMElement currentReferenceParameter = ite.next();

                try {
                    buffer.append(currentReferenceParameter.toStringWithConsume());
                } catch (XMLStreamException se) {
                    logger.error("unable to convert reference parameter", se);
                }

            }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

        String topic = getTopic(messageContext);
        OMElement outputElement = null;
        OMElement header = getHeader(messageContext);
        ContextHeaderDocument document = null;
        try {
            document = ContextHeaderDocument.Factory.parse(header.toStringWithConsume());
        } catch (XMLStreamException e) {
            e.printStackTrace();
        } catch (XmlException e) {
            e.printStackTrace();
        }
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

        SOAPHeader header = context.getEnvelope().getHeader();
        OMElement contextHeader = header.getFirstChildWithName(new QName(
                "http://airavata.apache.org/schemas/wec/2012/05", "context-header"));
        String address = null;
        try {
            ContextHeaderDocument document = ContextHeaderDocument.Factory.parse(contextHeader.toStringWithConsume());
            address = document.getContextHeader().getWorkflowMonitoringContext().getEventPublishEpr();
        } catch (XmlException e) {
            e.printStackTrace(); // To change body of catch statement use File | Settings | File Templates.
        } catch (XMLStreamException e) {
            e.printStackTrace(); // To change body of catch statement use File | Settings | File Templates.
View Full Code Here

Examples of org.apache.axiom.om.OMElement.toStringWithConsume()

    private String getTopic(MessageContext context) {
        OMElement contextHeader = getHeader(context);
        String topic = null;
        try {
            ContextHeaderDocument document = ContextHeaderDocument.Factory.parse(contextHeader.toStringWithConsume());
            topic = document.getContextHeader().getWorkflowMonitoringContext().getExperimentId();
        } catch (XmlException e) {
            e.printStackTrace();
        } catch (XMLStreamException e) {
            e.printStackTrace();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.