Package org.apache.servicemix.jbi.jaxp

Examples of org.apache.servicemix.jbi.jaxp.SourceTransformer

211
212
213
214
215
216
217
218
219
220
221
        throws Exception, ParserConfigurationException {

        Node originalDocumentNode = getDOMNode(requestMessage.getContent());
        Node targetResultNode = getDOMNode(targetResultMessage.getContent());

        Document document = new SourceTransformer().createDocument();
        Element enricherElement = createChildElement(enricherElementName, document);
        Element requestElement = createChildElement(requestElementName, document);

        Node node = document.importNode(originalDocumentNode, true);
        requestElement.appendChild(node);
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
252
        }
        return elem;
    }

    private Node getDOMNode(Source source) throws Exception {
        SourceTransformer sourceTransformer = new SourceTransformer();
        Node node = sourceTransformer.toDOMNode(source);
        if (node.getNodeType() == Node.DOCUMENT_NODE) {
            node = ((Document) node).getDocumentElement();
        }
        return node;
    }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
        me.setService(new QName("http://test", "MyProviderService"));
        me.getInMessage().setContent(new StringSource("<echo xmlns='http://test'><echoin0>world</echoin0></echo>"));
        client.sendSync(me);
        if (me.getStatus() == ExchangeStatus.ERROR) {
            if (me.getFault() != null) {
                fail("Received fault: " + new SourceTransformer().toString(me.getFault().getContent()));
            } else if (me.getError() != null) {
                throw me.getError();
            } else {
                fail("Received ERROR status");
            }
        } else {
            logger.info(new SourceTransformer().toString(me.getOutMessage().getContent()));
        }
        client.done(me);
    }
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
            method.setRequestEntity(new StringRequestEntity(request));
            int state = client.executeMethod(method);
            String str = method.getResponseBodyAsString();
            log.info(str);
            assertEquals(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, state);
            Element e = new SourceTransformer().toDOMElement(new StringSource(str));
            assertEquals("Envelope", e.getLocalName());
            e = (Element) e.getFirstChild();
            assertEquals("Body", e.getLocalName());
            e = (Element) e.getFirstChild();
            assertEquals("Fault", e.getLocalName());
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
            method.setRequestEntity(new StringRequestEntity(request));
            int state = client.executeMethod(method);
            String str = method.getResponseBodyAsString();
            log.info(str);
            assertEquals(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, state);
            Element e = new SourceTransformer().toDOMElement(new StringSource(str));
            assertEquals("Envelope", e.getLocalName());
            e = (Element) e.getFirstChild();
            assertEquals("Body", e.getLocalName());
            e = (Element) e.getFirstChild();
            assertEquals("Fault", e.getLocalName());
View Full Code Here
118
119
120
121
122
123
124
        assertTrue(result);
        NormalizedMessage out = inout.getOutMessage();
        assertNotNull(out);
        Source src = out.getContent();
        assertNotNull(src);
        logger.info(new SourceTransformer().toString(src));
    }
View Full Code Here
193
194
195
196
197
198
199
        assertTrue(result);
        NormalizedMessage out = inout.getOutMessage();
        assertNotNull(out);
        Source src = out.getContent();
        assertNotNull(src);
        logger.info(new SourceTransformer().toString(src));
    }
View Full Code Here
97
98
99
100
101
102
103
104
105
106
        qSender.send(message);

        receiver.getMessageList().assertMessagesReceived(1);
        List msgs = receiver.getMessageList().flushMessages();
        NormalizedMessage msg = (NormalizedMessage) msgs.get(0);
        assertEquals("Messages match", message.getText(), new SourceTransformer().contentToString(msg));

        // Wait for DONE status
        Thread.sleep(50);
    }
View Full Code Here
212
213
214
215
216
217
218
219
220
221
222
223
224
        assertTrue(inout.getStatus() == ExchangeStatus.ACTIVE);

        // Check we received the message
        assertNotNull(inout.getOutMessage());
        assertNotNull(inout.getOutMessage().getContent());
        SourceTransformer sourceTransformer = new SourceTransformer();
        String reply = sourceTransformer.toString(inout.getOutMessage().getContent());
        String inputMesage = sourceTransformer.toString(new StreamSource(new ByteArrayInputStream(msg.getBytes())));
        log.info("Msg Sent [" + inputMesage + "]");
        log.info("Msg Recieved [" + reply + "]");

        assertEquals(inputMesage.length(), reply.length());
        assertEquals(inputMesage, reply);
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
65
66
                throw me.getError();
            } else {
                fail("Received ERROR status");
            }
        } else if (me.getFault() != null) {
            fail("Received fault: " + new SourceTransformer().toString(me.getFault().getContent()));
        } else {
            Node node = new SourceTransformer().toDOMNode(me.getOutMessage());
            log.info(new SourceTransformer().toString(node));
            assertEquals("myid", textValueOfXPath(node, "//*[local-name()='RelatesTo']"));
            assertNotNull(textValueOfXPath(node, "//*[local-name()='MessageID']"));
        }
    }
View Full Code Here
TOP

Related Classes of org.apache.servicemix.jbi.jaxp.SourceTransformer

  • $.MySpringComponentTest
  • loanbroker.CreditAgency
  • org.apache.ode.jbi.JbiTestBase
  • org.apache.servicemix.components.http.HttpSoapTest
  • org.apache.servicemix.components.jdbc.JdbcComponentTest
  • org.apache.servicemix.components.saaj.SaajMarshalerTest
  • org.apache.servicemix.components.util.CopyTransformerTest
  • org.apache.servicemix.components.validation.ValidateComponent
  • org.apache.servicemix.cxfbc.CxfBcProviderTest
  • org.apache.servicemix.cxfbc.interceptors.JbiOutWsdl1Interceptor
    • Copyright © 2018 www.massapicom. 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.