How to use XPathPayloadMappingKeyExtractor class of com.consol.citrus.endpoint.adapter.mapping package

Best Citrus code snippet using com.consol.citrus.endpoint.adapter.mapping.XPathPayloadMappingKeyExtractor

Source:XmlTestExecutingEndpointAdapterTest.java

...13 * See the License for the specific language governing permissions and14 * limitations under the License.15 */16package com.consol.citrus.endpoint.adapter;17import com.consol.citrus.endpoint.adapter.mapping.XPathPayloadMappingKeyExtractor;18import com.consol.citrus.exceptions.CitrusRuntimeException;19import com.consol.citrus.message.DefaultMessage;20import com.consol.citrus.message.Message;21import com.consol.citrus.testng.AbstractTestNGUnitTest;22import org.springframework.context.ApplicationContext;23import org.springframework.context.support.ClassPathXmlApplicationContext;24import org.testng.Assert;25import org.testng.annotations.BeforeClass;26import org.testng.annotations.Test;27/**28 * @author Christoph Deppisch29 * @since 1.430 */31public class XmlTestExecutingEndpointAdapterTest extends AbstractTestNGUnitTest {32    private XmlTestExecutingEndpointAdapter endpointAdapter;33    @BeforeClass34    public void loadContext() {35        ApplicationContext ctx = new ClassPathXmlApplicationContext(new String[] {"classpath:com/consol/citrus/endpoint/XmlTestExecutingEndpointAdapterTest-context.xml"}, applicationContext);36        endpointAdapter = ctx.getBean(XmlTestExecutingEndpointAdapter.class);37    }38    /**39     * Test for handler routing by node content40     */41    @Test42    public void testRouteMessageByElementTextContent() throws Exception {43        XPathPayloadMappingKeyExtractor mappingNameExtractor = new XPathPayloadMappingKeyExtractor();44        mappingNameExtractor.setXpathExpression("//Test/@name");45        endpointAdapter.setMappingKeyExtractor(mappingNameExtractor);46        Message response = endpointAdapter.handleMessage(47                new DefaultMessage("<Test name=\"FooTest\"></Test>"));48        Assert.assertEquals(response.getPayload(String.class).trim(), "<Test name=\"FooTest\">OK</Test>");49        response = endpointAdapter.handleMessage(50                new DefaultMessage("<Test name=\"BarTest\"></Test>"));51        Assert.assertEquals(response.getPayload(String.class).trim(), "<Test name=\"BarTest\">OK</Test>");52    }53    /**54     * Test for handler routing without Xpath given (implementation takes the value of first node).55     */56    @Test57    public void testRouteMessageWithDefaultXpath() throws Exception {58        XPathPayloadMappingKeyExtractor mappingNameExtractor = new XPathPayloadMappingKeyExtractor();59        endpointAdapter.setMappingKeyExtractor(mappingNameExtractor);60        Message response = endpointAdapter.handleMessage(61                new DefaultMessage(62                        "<FooBarTest></FooBarTest>"));63        Assert.assertEquals(response.getPayload(String.class).trim(), "<FooBarTest>OK</FooBarTest>");64    }65    /**66     * Test for Xpath which is not found --> shall raise exception67     */68    @Test69    public void testRouteMessageWithBadXpathExpression() throws Exception {70        XPathPayloadMappingKeyExtractor mappingNameExtractor = new XPathPayloadMappingKeyExtractor();71        mappingNameExtractor.setXpathExpression("//I_DO_NOT_EXIST");72        endpointAdapter.setMappingKeyExtractor(mappingNameExtractor);73        try {74            endpointAdapter.handleMessage(new DefaultMessage(75                    "<FooTest>foo test please</FooTest>"));76            Assert.fail("Missing exception due to bad XPath expression");77        } catch (CitrusRuntimeException e) {78            Assert.assertEquals(e.getMessage(), "No result for XPath expression: '//I_DO_NOT_EXIST'");79        }80    }81    /**82     * Test for correct xpath, but no handler bean is found --> shall raise exc83     */84    @Test85    public void testRouteMessageWithBadHandlerConfiguration() throws Exception {86        XPathPayloadMappingKeyExtractor mappingNameExtractor = new XPathPayloadMappingKeyExtractor();87        mappingNameExtractor.setXpathExpression("//Test/@name");88        endpointAdapter.setMappingKeyExtractor(mappingNameExtractor);89        try {90            endpointAdapter.handleMessage(new DefaultMessage(91                    "<Test name=\"UNKNOWN_TEST\"></Test>"));92            Assert.fail("Missing exception due to unknown endpoint adapter");93        } catch (CitrusRuntimeException e) {94            Assert.assertEquals(e.getMessage(), "Failed to load test case");95        }96    }97}...

Source:XPathPayloadCorrelationHandler.java

...14 * limitations under the License.15 */16package com.consol.citrus.simulator.correlation;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.endpoint.adapter.mapping.XPathPayloadMappingKeyExtractor;19import com.consol.citrus.message.Message;20import com.consol.citrus.simulator.scenario.ScenarioEndpoint;21import com.consol.citrus.xml.namespace.NamespaceContextBuilder;22import org.slf4j.Logger;23import org.slf4j.LoggerFactory;24/**25 * @author Christoph Deppisch26 */27public class XPathPayloadCorrelationHandler extends AbstractCorrelationHandler {28    private static final Logger LOG = LoggerFactory.getLogger(XPathPayloadCorrelationHandler.class);29    private XPathPayloadMappingKeyExtractor xPathPayloadMappingKeyExtractor = new XPathPayloadMappingKeyExtractor();30    private final String value;31    /**32     * Default constructor using expression value to match.33     *34     * @param namespaceContextBuilder35     * @param scenarioEndpoint36     * @param expression37     * @param value38     */39    public XPathPayloadCorrelationHandler(NamespaceContextBuilder namespaceContextBuilder, ScenarioEndpoint scenarioEndpoint, String expression, String value) {40        super(scenarioEndpoint);41        this.xPathPayloadMappingKeyExtractor.setNamespaceContextBuilder(namespaceContextBuilder);42        this.xPathPayloadMappingKeyExtractor.setXpathExpression(expression);43        this.value = value;...

Source:MessageTypeCorrelationHandler.java

...14 * limitations under the License.15 */16package com.consol.citrus.simulator.correlation;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.endpoint.adapter.mapping.XPathPayloadMappingKeyExtractor;19import com.consol.citrus.message.Message;20import com.consol.citrus.simulator.scenario.ScenarioEndpoint;21/**22 * @author Christoph Deppisch23 */24public class MessageTypeCorrelationHandler extends AbstractCorrelationHandler {25    private XPathPayloadMappingKeyExtractor xPathPayloadMappingKeyExtractor = new XPathPayloadMappingKeyExtractor();26    private final String value;27    /**28     * Default constructor.29     *30     * @param scenarioEndpoint31     * @param value32     */33    public MessageTypeCorrelationHandler(ScenarioEndpoint scenarioEndpoint, String value) {34        super(scenarioEndpoint);35        this.value = value;36    }37    @Override38    public boolean isHandlerFor(Message message, TestContext context) {39        return xPathPayloadMappingKeyExtractor.extractMappingKey(message).equals(context.replaceDynamicContentInString(value));...