How to use setSchemaValidation method of com.consol.citrus.validation.xml.XmlMessageValidationContext class

Best Citrus code snippet using com.consol.citrus.validation.xml.XmlMessageValidationContext.setSchemaValidation

Source:ReceiveMessageActionTest.java

...414 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);415 when(endpointConfiguration.getTimeout()).thenReturn(5000L);416 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);417 when(endpoint.getActor()).thenReturn(null);418 validationContext.setSchemaValidation(false);419 420 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 421 validationContexts.add(validationContext);422 receiveAction.setValidationContexts(validationContexts);423 receiveAction.execute(context);424 }425 426 @Test427 @SuppressWarnings({ "unchecked", "rawtypes" })428 public void testReceiveMessageOverwriteMessageElementsXPathWithNestedNamespaces() {429 ReceiveMessageAction receiveAction = new ReceiveMessageAction();430 receiveAction.setEndpoint(endpoint);431 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();432 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();433 receiveAction.setMessageBuilder(controlMessageBuilder);434 controlMessageBuilder.setPayloadData("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +435 "<ns1:Message xmlns:ns1=\"http://citrusframework.org/unittest/message\">?</ns1:Message></ns0:TestRequest>");436 437 Map<String, String> overwriteElements = new HashMap<String, String>();438 overwriteElements.put("/ns0:TestRequest/ns1:Message", "Hello World!");439 XpathMessageConstructionInterceptor interceptor = new XpathMessageConstructionInterceptor(overwriteElements);440 controlMessageBuilder.add(interceptor);441 442 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +443 "<ns1:Message xmlns:ns1=\"http://citrusframework.org/unittest/message\">Hello World!</ns1:Message></ns0:TestRequest>");444 reset(endpoint, consumer, endpointConfiguration);445 when(endpoint.createConsumer()).thenReturn(consumer);446 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);447 when(endpointConfiguration.getTimeout()).thenReturn(5000L);448 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);449 when(endpoint.getActor()).thenReturn(null);450 validationContext.setSchemaValidation(false);451 452 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 453 validationContexts.add(validationContext);454 receiveAction.setValidationContexts(validationContexts);455 receiveAction.execute(context);456 }457 458 @Test459 @SuppressWarnings({ "unchecked", "rawtypes" })460 public void testReceiveMessageOverwriteMessageElementsXPathWithDefaultNamespaces() {461 ReceiveMessageAction receiveAction = new ReceiveMessageAction();462 receiveAction.setEndpoint(endpoint);463 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();464 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();465 receiveAction.setMessageBuilder(controlMessageBuilder);466 controlMessageBuilder.setPayloadData("<TestRequest xmlns=\"http://citrusframework.org/unittest\">" +467 "<Message>?</Message></TestRequest>");468 469 Map<String, String> overwriteElements = new HashMap<String, String>();470 overwriteElements.put("/:TestRequest/:Message", "Hello World!");471 XpathMessageConstructionInterceptor interceptor = new XpathMessageConstructionInterceptor(overwriteElements);472 controlMessageBuilder.add(interceptor);473 474 Message controlMessage = new DefaultMessage("<TestRequest xmlns=\"http://citrusframework.org/unittest\"><Message>Hello World!</Message></TestRequest>");475 reset(endpoint, consumer, endpointConfiguration);476 when(endpoint.createConsumer()).thenReturn(consumer);477 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);478 when(endpointConfiguration.getTimeout()).thenReturn(5000L);479 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);480 when(endpoint.getActor()).thenReturn(null);481 validationContext.setSchemaValidation(false);482 483 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 484 validationContexts.add(validationContext);485 receiveAction.setValidationContexts(validationContexts);486 receiveAction.execute(context);487 }488 489 @Test490 @SuppressWarnings({ "unchecked", "rawtypes" })491 public void testReceiveMessageWithMessageHeaders() {492 ReceiveMessageAction receiveAction = new ReceiveMessageAction();493 receiveAction.setEndpoint(endpoint);494 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();495 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();496 receiveAction.setMessageBuilder(controlMessageBuilder);497 controlMessageBuilder.setPayloadData("<TestRequest><Message>Hello World!</Message></TestRequest>");498 Map<String, Object> headers = new HashMap<String, Object>();499 headers.put("Operation", "sayHello");500 controlMessageBuilder.setMessageHeaders(headers);501 Map<String, Object> controlHeaders = new HashMap<String, Object>();502 controlHeaders.put("Operation", "sayHello");503 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>", controlHeaders);504 reset(endpoint, consumer, endpointConfiguration);505 when(endpoint.createConsumer()).thenReturn(consumer);506 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);507 when(endpointConfiguration.getTimeout()).thenReturn(5000L);508 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);509 when(endpoint.getActor()).thenReturn(null);510 511 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 512 validationContexts.add(validationContext);513 receiveAction.setValidationContexts(validationContexts);514 receiveAction.execute(context);515 }516 517 @Test518 @SuppressWarnings({ "unchecked", "rawtypes" })519 public void testReceiveMessageWithMessageHeadersVariablesSupport() {520 ReceiveMessageAction receiveAction = new ReceiveMessageAction();521 receiveAction.setEndpoint(endpoint);522 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();523 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();524 receiveAction.setMessageBuilder(controlMessageBuilder);525 controlMessageBuilder.setPayloadData("<TestRequest><Message>Hello World!</Message></TestRequest>");526 context.setVariable("myOperation", "sayHello");527 528 Map<String, Object> headers = new HashMap<String, Object>();529 headers.put("Operation", "${myOperation}");530 controlMessageBuilder.setMessageHeaders(headers);531 532 Map<String, Object> controlHeaders = new HashMap<String, Object>();533 controlHeaders.put("Operation", "sayHello");534 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>", controlHeaders);535 reset(endpoint, consumer, endpointConfiguration);536 when(endpoint.createConsumer()).thenReturn(consumer);537 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);538 when(endpointConfiguration.getTimeout()).thenReturn(5000L);539 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);540 when(endpoint.getActor()).thenReturn(null);541 542 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 543 validationContexts.add(validationContext);544 receiveAction.setValidationContexts(validationContexts);545 receiveAction.execute(context);546 }547 548 @Test549 @SuppressWarnings({ "unchecked", "rawtypes" })550 public void testReceiveMessageWithUnknownVariablesInMessageHeaders() {551 ReceiveMessageAction receiveAction = new ReceiveMessageAction();552 receiveAction.setEndpoint(endpoint);553 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();554 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();555 receiveAction.setMessageBuilder(controlMessageBuilder);556 controlMessageBuilder.setPayloadData("<TestRequest><Message>Hello World!</Message></TestRequest>");557 Map<String, Object> headers = new HashMap<String, Object>();558 headers.put("Operation", "${myOperation}");559 controlMessageBuilder.setMessageHeaders(headers);560 561 Map<String, Object> controlHeaders = new HashMap<String, Object>();562 controlHeaders.put("Operation", "sayHello");563 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>", controlHeaders);564 reset(endpoint, consumer, endpointConfiguration);565 when(endpoint.createConsumer()).thenReturn(consumer);566 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);567 when(endpointConfiguration.getTimeout()).thenReturn(5000L);568 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);569 when(endpoint.getActor()).thenReturn(null);570 571 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 572 validationContexts.add(validationContext);573 receiveAction.setValidationContexts(validationContexts);574 try {575 receiveAction.execute(context);576 } catch(CitrusRuntimeException e) {577 Assert.assertEquals(e.getMessage(), "Unknown variable 'myOperation'");578 return;579 }580 }581 582 @Test583 @SuppressWarnings({ "unchecked", "rawtypes" })584 public void testReceiveMessageWithUnknownVariableInMessagePayload() {585 ReceiveMessageAction receiveAction = new ReceiveMessageAction();586 receiveAction.setEndpoint(endpoint);587 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();588 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();589 receiveAction.setMessageBuilder(controlMessageBuilder);590 controlMessageBuilder.setPayloadData("<TestRequest><Message>${myText}</Message></TestRequest>");591 592 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>");593 reset(endpoint, consumer, endpointConfiguration);594 when(endpoint.createConsumer()).thenReturn(consumer);595 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);596 when(endpointConfiguration.getTimeout()).thenReturn(5000L);597 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);598 when(endpoint.getActor()).thenReturn(null);599 600 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 601 validationContexts.add(validationContext);602 receiveAction.setValidationContexts(validationContexts);603 try {604 receiveAction.execute(context);605 } catch(CitrusRuntimeException e) {606 Assert.assertEquals(e.getMessage(), "Unknown variable 'myText'");607 return;608 }609 }610 611 @Test612 @SuppressWarnings({ "unchecked", "rawtypes" })613 public void testReceiveMessageWithExtractVariablesFromHeaders() {614 ReceiveMessageAction receiveAction = new ReceiveMessageAction();615 receiveAction.setEndpoint(endpoint);616 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();617 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();618 receiveAction.setMessageBuilder(controlMessageBuilder);619 controlMessageBuilder.setPayloadData("<TestRequest><Message>Hello World!</Message></TestRequest>");620 Map<String, String> headers = new HashMap<String, String>();621 headers.put("Operation", "myOperation");622 623 MessageHeaderVariableExtractor headerVariableExtractor = new MessageHeaderVariableExtractor();624 headerVariableExtractor.setHeaderMappings(headers);625 List<VariableExtractor> variableExtractors = new ArrayList<VariableExtractor>();626 variableExtractors.add(headerVariableExtractor);627 receiveAction.addVariableExtractors(headerVariableExtractor);628 629 Map<String, Object> controlHeaders = new HashMap<String, Object>();630 controlHeaders.put("Operation", "sayHello");631 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>", controlHeaders);632 reset(endpoint, consumer, endpointConfiguration);633 when(endpoint.createConsumer()).thenReturn(consumer);634 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);635 when(endpointConfiguration.getTimeout()).thenReturn(5000L);636 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);637 when(endpoint.getActor()).thenReturn(null);638 639 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 640 validationContexts.add(validationContext);641 receiveAction.setValidationContexts(validationContexts);642 receiveAction.execute(context);643 644 Assert.assertNotNull(context.getVariable("myOperation"));645 Assert.assertEquals(context.getVariable("myOperation"), "sayHello");646 }647 648 @Test649 @SuppressWarnings({ "unchecked", "rawtypes" })650 public void testReceiveMessageWithValidateMessageElementsFromMessageXPath() {651 ReceiveMessageAction receiveAction = new ReceiveMessageAction();652 receiveAction.setEndpoint(endpoint);653 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();654 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();655 receiveAction.setMessageBuilder(controlMessageBuilder);656 Map<String, Object> messageElements = new HashMap<>();657 messageElements.put("/TestRequest/Message", "Hello World!");658 validationContext.setXpathExpressions(messageElements);659 660 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>");661 reset(endpoint, consumer, endpointConfiguration);662 when(endpoint.createConsumer()).thenReturn(consumer);663 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);664 when(endpointConfiguration.getTimeout()).thenReturn(5000L);665 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);666 when(endpoint.getActor()).thenReturn(null);667 668 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 669 validationContexts.add(validationContext);670 receiveAction.setValidationContexts(validationContexts);671 receiveAction.execute(context);672 }673 674 @Test675 @SuppressWarnings({ "unchecked", "rawtypes" })676 public void testReceiveMessageWithValidateMessageElementsXPathDefaultNamespaceSupport() {677 ReceiveMessageAction receiveAction = new ReceiveMessageAction();678 receiveAction.setEndpoint(endpoint);679 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();680 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();681 receiveAction.setMessageBuilder(controlMessageBuilder);682 Map<String, Object> messageElements = new HashMap<>();683 messageElements.put("/:TestRequest/:Message", "Hello World!");684 validationContext.setXpathExpressions(messageElements);685 686 Message controlMessage = new DefaultMessage("<TestRequest xmlns=\"http://citrusframework.org/unittest\">" +687 "<Message>Hello World!</Message></TestRequest>");688 reset(endpoint, consumer, endpointConfiguration);689 when(endpoint.createConsumer()).thenReturn(consumer);690 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);691 when(endpointConfiguration.getTimeout()).thenReturn(5000L);692 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);693 when(endpoint.getActor()).thenReturn(null);694 validationContext.setSchemaValidation(false);695 696 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 697 validationContexts.add(validationContext);698 receiveAction.setValidationContexts(validationContexts);699 receiveAction.execute(context);700 }701 702 @Test703 @SuppressWarnings({ "unchecked", "rawtypes" })704 public void testReceiveMessageWithValidateMessageElementsXPathNamespaceSupport() {705 ReceiveMessageAction receiveAction = new ReceiveMessageAction();706 receiveAction.setEndpoint(endpoint);707 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();708 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();709 receiveAction.setMessageBuilder(controlMessageBuilder);710 Map<String, Object> messageElements = new HashMap<>();711 messageElements.put("/ns0:TestRequest/ns0:Message", "Hello World!");712 validationContext.setXpathExpressions(messageElements);713 714 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +715 "<ns0:Message>Hello World!</ns0:Message></ns0:TestRequest>");716 reset(endpoint, consumer, endpointConfiguration);717 when(endpoint.createConsumer()).thenReturn(consumer);718 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);719 when(endpointConfiguration.getTimeout()).thenReturn(5000L);720 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);721 when(endpoint.getActor()).thenReturn(null);722 validationContext.setSchemaValidation(false);723 724 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 725 validationContexts.add(validationContext);726 receiveAction.setValidationContexts(validationContexts);727 receiveAction.execute(context);728 }729 730 @Test731 @SuppressWarnings({ "unchecked", "rawtypes" })732 public void testReceiveMessageWithValidateMessageElementsXPathNestedNamespaceSupport() {733 ReceiveMessageAction receiveAction = new ReceiveMessageAction();734 receiveAction.setEndpoint(endpoint);735 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();736 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();737 receiveAction.setMessageBuilder(controlMessageBuilder);738 Map<String, Object> messageElements = new HashMap<>();739 messageElements.put("/ns0:TestRequest/ns1:Message", "Hello World!");740 validationContext.setXpathExpressions(messageElements);741 742 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +743 "<ns1:Message xmlns:ns1=\"http://citrusframework.org/unittest/message\">Hello World!</ns1:Message></ns0:TestRequest>");744 reset(endpoint, consumer, endpointConfiguration);745 when(endpoint.createConsumer()).thenReturn(consumer);746 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);747 when(endpointConfiguration.getTimeout()).thenReturn(5000L);748 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);749 when(endpoint.getActor()).thenReturn(null);750 validationContext.setSchemaValidation(false);751 752 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 753 validationContexts.add(validationContext);754 receiveAction.setValidationContexts(validationContexts);755 receiveAction.execute(context);756 }757 758 @Test759 @SuppressWarnings({ "unchecked", "rawtypes" })760 public void testReceiveMessageWithValidateMessageElementsXPathNamespaceBindings() {761 ReceiveMessageAction receiveAction = new ReceiveMessageAction();762 receiveAction.setEndpoint(endpoint);763 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();764 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();765 receiveAction.setMessageBuilder(controlMessageBuilder);766 Map<String, Object> messageElements = new HashMap<>();767 messageElements.put("/pfx:TestRequest/pfx:Message", "Hello World!");768 validationContext.setXpathExpressions(messageElements);769 770 Map<String, String> namespaces = new HashMap<String, String>();771 namespaces.put("pfx", "http://citrusframework.org/unittest");772 validationContext.setNamespaces(namespaces);773 774 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +775 "<ns0:Message>Hello World!</ns0:Message></ns0:TestRequest>");776 reset(endpoint, consumer, endpointConfiguration);777 when(endpoint.createConsumer()).thenReturn(consumer);778 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);779 when(endpointConfiguration.getTimeout()).thenReturn(5000L);780 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);781 when(endpoint.getActor()).thenReturn(null);782 validationContext.setSchemaValidation(false);783 784 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 785 validationContexts.add(validationContext);786 receiveAction.setValidationContexts(validationContexts);787 receiveAction.execute(context);788 }789 @Test790 @SuppressWarnings({ "unchecked", "rawtypes" })791 public void testReceiveMessageWithExtractVariablesFromMessageJsonPath() {792 ReceiveMessageAction receiveAction = new ReceiveMessageAction();793 receiveAction.setEndpoint(endpoint);794 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();795 JsonMessageValidationContext validationContext = new JsonMessageValidationContext();796 receiveAction.setMessageBuilder(controlMessageBuilder);797 controlMessageBuilder.setPayloadData("{\"text\":\"Hello World!\", \"person\":{\"name\":\"John\",\"surname\":\"Doe\"}, \"index\":5, \"id\":\"x123456789x\"}");798 Map<String, String> extractMessageElements = new HashMap<String, String>();799 extractMessageElements.put("$.text", "messageVar");800 extractMessageElements.put("$.person", "person");801 JsonPathVariableExtractor variableExtractor = new JsonPathVariableExtractor();802 variableExtractor.setJsonPathExpressions(extractMessageElements);803 receiveAction.addVariableExtractors(variableExtractor);804 Message controlMessage = new DefaultMessage("{\"text\":\"Hello World!\", \"person\":{\"name\":\"John\",\"surname\":\"Doe\"}, \"index\":5, \"id\":\"x123456789x\"}");805 reset(endpoint, consumer, endpointConfiguration);806 when(endpoint.createConsumer()).thenReturn(consumer);807 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);808 when(endpointConfiguration.getTimeout()).thenReturn(5000L);809 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);810 when(endpoint.getActor()).thenReturn(null);811 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();812 validationContexts.add(validationContext);813 receiveAction.setValidationContexts(validationContexts);814 receiveAction.execute(context);815 Assert.assertNotNull(context.getVariable("messageVar"));816 Assert.assertEquals(context.getVariable("messageVar"), "Hello World!");817 Assert.assertNotNull(context.getVariable("person"));818 Assert.assertTrue(context.getVariable("person").contains("\"John\""));819 }820 821 @Test822 @SuppressWarnings({ "unchecked", "rawtypes" })823 public void testReceiveMessageWithExtractVariablesFromMessageXPath() {824 ReceiveMessageAction receiveAction = new ReceiveMessageAction();825 receiveAction.setEndpoint(endpoint);826 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();827 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();828 receiveAction.setMessageBuilder(controlMessageBuilder);829 controlMessageBuilder.setPayloadData("<TestRequest><Message>Hello World!</Message></TestRequest>");830 Map<String, String> extractMessageElements = new HashMap<String, String>();831 extractMessageElements.put("/TestRequest/Message", "messageVar");832 833 XpathPayloadVariableExtractor variableExtractor = new XpathPayloadVariableExtractor();834 variableExtractor.setXpathExpressions(extractMessageElements);835 receiveAction.addVariableExtractors(variableExtractor);836 837 Message controlMessage = new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>");838 reset(endpoint, consumer, endpointConfiguration);839 when(endpoint.createConsumer()).thenReturn(consumer);840 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);841 when(endpointConfiguration.getTimeout()).thenReturn(5000L);842 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);843 when(endpoint.getActor()).thenReturn(null);844 845 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 846 validationContexts.add(validationContext);847 receiveAction.setValidationContexts(validationContexts);848 receiveAction.execute(context);849 850 Assert.assertNotNull(context.getVariable("messageVar"));851 Assert.assertEquals(context.getVariable("messageVar"), "Hello World!");852 }853 @Test854 @SuppressWarnings({ "unchecked", "rawtypes" })855 public void testReceiveMessageWithExtractVariablesFromMessageXPathNodeList() {856 ReceiveMessageAction receiveAction = new ReceiveMessageAction();857 receiveAction.setEndpoint(endpoint);858 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();859 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();860 receiveAction.setMessageBuilder(controlMessageBuilder);861 controlMessageBuilder.setPayloadData("<TestRequest>" +862 "<Message>Hello</Message>" +863 "<Message>ByeBye</Message>" +864 "</TestRequest>");865 Map<String, String> extractMessageElements = new HashMap<String, String>();866 extractMessageElements.put("node-set://TestRequest/Message", "messageVar");867 XpathPayloadVariableExtractor variableExtractor = new XpathPayloadVariableExtractor();868 variableExtractor.setXpathExpressions(extractMessageElements);869 receiveAction.addVariableExtractors(variableExtractor);870 Message controlMessage = new DefaultMessage("<TestRequest>" +871 "<Message>Hello</Message>" +872 "<Message>ByeBye</Message>" +873 "</TestRequest>");874 reset(endpoint, consumer, endpointConfiguration);875 when(endpoint.createConsumer()).thenReturn(consumer);876 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);877 when(endpointConfiguration.getTimeout()).thenReturn(5000L);878 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);879 when(endpoint.getActor()).thenReturn(null);880 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();881 validationContexts.add(validationContext);882 receiveAction.setValidationContexts(validationContexts);883 receiveAction.execute(context);884 Assert.assertNotNull(context.getVariable("messageVar"));885 Assert.assertEquals(context.getVariable("messageVar"), "Hello,ByeBye");886 }887 @Test888 @SuppressWarnings({ "unchecked", "rawtypes" })889 public void testReceiveMessageWithExtractVariablesFromMessageXPathDefaultNamespaceSupport() {890 ReceiveMessageAction receiveAction = new ReceiveMessageAction();891 receiveAction.setEndpoint(endpoint);892 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();893 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();894 receiveAction.setMessageBuilder(controlMessageBuilder);895 controlMessageBuilder.setPayloadData("<TestRequest xmlns=\"http://citrusframework.org/unittest\">" +896 "<Message>Hello World!</Message></TestRequest>");897 Map<String, String> extractMessageElements = new HashMap<String, String>();898 extractMessageElements.put("/:TestRequest/:Message", "messageVar");899 900 XpathPayloadVariableExtractor variableExtractor = new XpathPayloadVariableExtractor();901 variableExtractor.setXpathExpressions(extractMessageElements);902 receiveAction.addVariableExtractors(variableExtractor);903 904 Message controlMessage = new DefaultMessage("<TestRequest xmlns=\"http://citrusframework.org/unittest\">" +905 "<Message>Hello World!</Message></TestRequest>");906 reset(endpoint, consumer, endpointConfiguration);907 when(endpoint.createConsumer()).thenReturn(consumer);908 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);909 when(endpointConfiguration.getTimeout()).thenReturn(5000L);910 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);911 when(endpoint.getActor()).thenReturn(null);912 913 validationContext.setSchemaValidation(false);914 915 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 916 validationContexts.add(validationContext);917 receiveAction.setValidationContexts(validationContexts);918 receiveAction.execute(context);919 920 Assert.assertNotNull(context.getVariable("messageVar"));921 Assert.assertEquals(context.getVariable("messageVar"), "Hello World!");922 }923 924 @Test925 @SuppressWarnings({ "unchecked", "rawtypes" })926 public void testReceiveMessageWithExtractVariablesFromMessageXPathNamespaceSupport() {927 ReceiveMessageAction receiveAction = new ReceiveMessageAction();928 receiveAction.setEndpoint(endpoint);929 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();930 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();931 receiveAction.setMessageBuilder(controlMessageBuilder);932 controlMessageBuilder.setPayloadData("<TestRequest xmlns=\"http://citrusframework.org/unittest\">" +933 "<Message>Hello World!</Message></TestRequest>");934 935 Map<String, String> extractMessageElements = new HashMap<String, String>();936 extractMessageElements.put("/ns0:TestRequest/ns0:Message", "messageVar");937 XpathPayloadVariableExtractor variableExtractor = new XpathPayloadVariableExtractor();938 variableExtractor.setXpathExpressions(extractMessageElements);939 receiveAction.addVariableExtractors(variableExtractor);940 941 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +942 "<ns0:Message>Hello World!</ns0:Message></ns0:TestRequest>");943 reset(endpoint, consumer, endpointConfiguration);944 when(endpoint.createConsumer()).thenReturn(consumer);945 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);946 when(endpointConfiguration.getTimeout()).thenReturn(5000L);947 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);948 when(endpoint.getActor()).thenReturn(null);949 950 validationContext.setSchemaValidation(false);951 952 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 953 validationContexts.add(validationContext);954 receiveAction.setValidationContexts(validationContexts);955 receiveAction.execute(context);956 957 Assert.assertNotNull(context.getVariable("messageVar"));958 Assert.assertEquals(context.getVariable("messageVar"), "Hello World!");959 }960 961 @Test962 @SuppressWarnings({ "unchecked", "rawtypes" })963 public void testReceiveMessageWithExtractVariablesFromMessageXPathNestedNamespaceSupport() {964 ReceiveMessageAction receiveAction = new ReceiveMessageAction();965 receiveAction.setEndpoint(endpoint);966 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();967 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();968 receiveAction.setMessageBuilder(controlMessageBuilder);969 controlMessageBuilder.setPayloadData("<TestRequest xmlns=\"http://citrusframework.org/unittest\" xmlns:ns1=\"http://citrusframework.org/unittest/message\">" +970 "<ns1:Message>Hello World!</ns1:Message></TestRequest>");971 Map<String, String> extractMessageElements = new HashMap<String, String>();972 extractMessageElements.put("/ns0:TestRequest/ns1:Message", "messageVar");973 974 XpathPayloadVariableExtractor variableExtractor = new XpathPayloadVariableExtractor();975 variableExtractor.setXpathExpressions(extractMessageElements);976 receiveAction.addVariableExtractors(variableExtractor);977 978 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +979 "<ns1:Message xmlns:ns1=\"http://citrusframework.org/unittest/message\">Hello World!</ns1:Message></ns0:TestRequest>");980 reset(endpoint, consumer, endpointConfiguration);981 when(endpoint.createConsumer()).thenReturn(consumer);982 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);983 when(endpointConfiguration.getTimeout()).thenReturn(5000L);984 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);985 when(endpoint.getActor()).thenReturn(null);986 987 validationContext.setSchemaValidation(false);988 989 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 990 validationContexts.add(validationContext);991 receiveAction.setValidationContexts(validationContexts);992 receiveAction.execute(context);993 994 Assert.assertNotNull(context.getVariable("messageVar"));995 Assert.assertEquals(context.getVariable("messageVar"), "Hello World!");996 }997 998 @Test999 @SuppressWarnings({ "unchecked", "rawtypes" })1000 public void testReceiveMessageWithExtractVariablesFromMessageXPathNamespaceBindings() {1001 ReceiveMessageAction receiveAction = new ReceiveMessageAction();1002 receiveAction.setEndpoint(endpoint);1003 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();1004 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();1005 receiveAction.setMessageBuilder(controlMessageBuilder);1006 controlMessageBuilder.setPayloadData("<TestRequest xmlns=\"http://citrusframework.org/unittest\">" +1007 "<Message>Hello World!</Message></TestRequest>");1008 Map<String, String> extractMessageElements = new HashMap<String, String>();1009 extractMessageElements.put("/pfx:TestRequest/pfx:Message", "messageVar");1010 1011 XpathPayloadVariableExtractor variableExtractor = new XpathPayloadVariableExtractor();1012 variableExtractor.setXpathExpressions(extractMessageElements);1013 receiveAction.addVariableExtractors(variableExtractor);1014 1015 Map<String, String> namespaces = new HashMap<String, String>();1016 namespaces.put("pfx", "http://citrusframework.org/unittest");1017 variableExtractor.setNamespaces(namespaces);1018 1019 Message controlMessage = new DefaultMessage("<ns0:TestRequest xmlns:ns0=\"http://citrusframework.org/unittest\">" +1020 "<ns0:Message>Hello World!</ns0:Message></ns0:TestRequest>");1021 reset(endpoint, consumer, endpointConfiguration);1022 when(endpoint.createConsumer()).thenReturn(consumer);1023 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);1024 when(endpointConfiguration.getTimeout()).thenReturn(5000L);1025 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(controlMessage);1026 when(endpoint.getActor()).thenReturn(null);1027 1028 validationContext.setSchemaValidation(false);1029 1030 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>(); 1031 validationContexts.add(validationContext);1032 receiveAction.setValidationContexts(validationContexts);1033 receiveAction.execute(context);1034 1035 Assert.assertNotNull(context.getVariable("messageVar"));1036 Assert.assertEquals(context.getVariable("messageVar"), "Hello World!");1037 }1038 @Test1039 public void testReceiveMessageWithJsonPathValidation() {1040 ReceiveMessageAction receiveAction = new ReceiveMessageAction();1041 receiveAction.setEndpoint(endpoint);1042 receiveAction.setMessageType(MessageType.JSON.toString());...

Source:NamespaceTest.java

...77 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"78 + "</ns1:element>" 79 + "</ns1:root>");80 81 validationContext.setSchemaValidation(false);82 83 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();84 validationContexts.add(validationContext);85 receiveMessageBean.setValidationContexts(validationContexts);86 receiveMessageBean.execute(context);87 }88 89 @Test90 @SuppressWarnings({ "unchecked", "rawtypes" })91 public void testDifferentNamespacePrefix() {92 reset(endpoint, consumer, endpointConfiguration);93 when(endpoint.createConsumer()).thenReturn(consumer);94 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);95 when(endpointConfiguration.getTimeout()).thenReturn(5000L);96 97 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus'>"98 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"99 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"100 + "</ns1:element>" 101 + "</ns1:root>");102 103 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);104 when(endpoint.getActor()).thenReturn(null);105 106 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();107 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();108 receiveMessageBean.setMessageBuilder(controlMessageBuilder);109 controlMessageBuilder.setPayloadData("<ns2:root xmlns:ns2='http://citrus'>"110 + "<ns2:element attributeA='attribute-value' attributeB='attribute-value'>"111 + "<ns2:sub-element attribute='A'>text-value</ns2:sub-element>"112 + "</ns2:element>" 113 + "</ns2:root>");114 115 validationContext.setSchemaValidation(false);116 117 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();118 validationContexts.add(validationContext);119 receiveMessageBean.setValidationContexts(validationContexts);120 receiveMessageBean.execute(context);121 }122 123 @Test124 @SuppressWarnings({ "unchecked", "rawtypes" })125 public void testAdditionalNamespace() {126 reset(endpoint, consumer, endpointConfiguration);127 when(endpoint.createConsumer()).thenReturn(consumer);128 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);129 when(endpointConfiguration.getTimeout()).thenReturn(5000L);130 131 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus'>"132 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"133 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"134 + "</ns1:element>" 135 + "</ns1:root>");136 137 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);138 when(endpoint.getActor()).thenReturn(null);139 140 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();141 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();142 receiveMessageBean.setMessageBuilder(controlMessageBuilder);143 controlMessageBuilder.setPayloadData("<ns1:root xmlns:ns1='http://citrus' xmlns:ns2='http://citrus/default'>"144 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"145 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"146 + "</ns1:element>" 147 + "</ns1:root>");148 149 validationContext.setSchemaValidation(false);150 151 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();152 validationContexts.add(validationContext);153 receiveMessageBean.setValidationContexts(validationContexts);154 receiveMessageBean.execute(context);155 }156 157 @Test158 @SuppressWarnings({ "unchecked", "rawtypes" })159 public void testMissingNamespaceDeclaration() {160 reset(endpoint, consumer, endpointConfiguration);161 when(endpoint.createConsumer()).thenReturn(consumer);162 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);163 when(endpointConfiguration.getTimeout()).thenReturn(5000L);164 165 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus' xmlns:ns2='http://citrus/default'>"166 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"167 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"168 + "</ns1:element>" 169 + "</ns1:root>");170 171 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);172 when(endpoint.getActor()).thenReturn(null);173 174 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();175 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();176 receiveMessageBean.setMessageBuilder(controlMessageBuilder);177 controlMessageBuilder.setPayloadData("<ns1:root xmlns:ns1='http://citrus'>"178 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"179 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"180 + "</ns1:element>" 181 + "</ns1:root>");182 183 validationContext.setSchemaValidation(false);184 185 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();186 validationContexts.add(validationContext);187 receiveMessageBean.setValidationContexts(validationContexts);188 receiveMessageBean.execute(context);189 }190 191 @Test192 @SuppressWarnings({ "unchecked", "rawtypes" })193 public void testDefaultNamespaces() {194 reset(endpoint, consumer, endpointConfiguration);195 when(endpoint.createConsumer()).thenReturn(consumer);196 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);197 when(endpointConfiguration.getTimeout()).thenReturn(5000L);198 199 Message message = new DefaultMessage("<root xmlns='http://citrus'>"200 + "<element attributeA='attribute-value' attributeB='attribute-value'>"201 + "<sub-element attribute='A'>text-value</sub-element>"202 + "</element>" 203 + "</root>");204 205 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);206 when(endpoint.getActor()).thenReturn(null);207 208 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();209 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();210 receiveMessageBean.setMessageBuilder(controlMessageBuilder);211 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus'>"212 + "<element attributeA='attribute-value' attributeB='attribute-value'>"213 + "<sub-element attribute='A'>text-value</sub-element>"214 + "</element>" 215 + "</root>");216 217 validationContext.setSchemaValidation(false);218 219 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();220 validationContexts.add(validationContext);221 receiveMessageBean.setValidationContexts(validationContexts);222 receiveMessageBean.execute(context);223 }224 @Test225 @SuppressWarnings({ "unchecked", "rawtypes" })226 public void testDefaultNamespacesInExpectedMessage() {227 reset(endpoint, consumer, endpointConfiguration);228 when(endpoint.createConsumer()).thenReturn(consumer);229 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);230 when(endpointConfiguration.getTimeout()).thenReturn(5000L);231 232 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus'>"233 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"234 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"235 + "</ns1:element>" 236 + "</ns1:root>");237 238 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);239 when(endpoint.getActor()).thenReturn(null);240 241 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();242 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();243 receiveMessageBean.setMessageBuilder(controlMessageBuilder);244 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus'>"245 + "<element attributeA='attribute-value' attributeB='attribute-value'>"246 + "<sub-element attribute='A'>text-value</sub-element>"247 + "</element>" 248 + "</root>");249 250 validationContext.setSchemaValidation(false);251 252 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();253 validationContexts.add(validationContext);254 receiveMessageBean.setValidationContexts(validationContexts);255 receiveMessageBean.execute(context);256 }257 258 @Test259 @SuppressWarnings({ "unchecked", "rawtypes" })260 public void testDefaultNamespacesInSourceMessage() {261 reset(endpoint, consumer, endpointConfiguration);262 when(endpoint.createConsumer()).thenReturn(consumer);263 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);264 when(endpointConfiguration.getTimeout()).thenReturn(5000L);265 266 Message message = new DefaultMessage("<root xmlns='http://citrus'>"267 + "<element attributeA='attribute-value' attributeB='attribute-value'>"268 + "<sub-element attribute='A'>text-value</sub-element>"269 + "</element>" 270 + "</root>");271 272 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);273 when(endpoint.getActor()).thenReturn(null);274 275 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();276 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();277 receiveMessageBean.setMessageBuilder(controlMessageBuilder);278 controlMessageBuilder.setPayloadData("<ns1:root xmlns:ns1='http://citrus'>"279 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"280 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"281 + "</ns1:element>" 282 + "</ns1:root>");283 284 validationContext.setSchemaValidation(false);285 286 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();287 validationContexts.add(validationContext);288 receiveMessageBean.setValidationContexts(validationContexts);289 receiveMessageBean.execute(context);290 }291 292 @Test(expectedExceptions = {ValidationException.class})293 @SuppressWarnings({ "unchecked", "rawtypes" })294 public void testMissingNamespace() {295 reset(endpoint, consumer, endpointConfiguration);296 when(endpoint.createConsumer()).thenReturn(consumer);297 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);298 when(endpointConfiguration.getTimeout()).thenReturn(5000L);299 300 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus'>"301 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"302 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"303 + "</ns1:element>" 304 + "</ns1:root>");305 306 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);307 when(endpoint.getActor()).thenReturn(null);308 309 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();310 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();311 receiveMessageBean.setMessageBuilder(controlMessageBuilder);312 controlMessageBuilder.setPayloadData("<root>"313 + "<element attributeA='attribute-value' attributeB='attribute-value'>"314 + "<sub-element attribute='A'>text-value</sub-element>"315 + "</element>" 316 + "</root>");317 318 validationContext.setSchemaValidation(false);319 320 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();321 validationContexts.add(validationContext);322 receiveMessageBean.setValidationContexts(validationContexts);323 receiveMessageBean.execute(context);324 }325 326 @Test(expectedExceptions = {ValidationException.class})327 @SuppressWarnings({ "unchecked", "rawtypes" })328 public void testWrongNamespace() {329 reset(endpoint, consumer, endpointConfiguration);330 when(endpoint.createConsumer()).thenReturn(consumer);331 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);332 when(endpointConfiguration.getTimeout()).thenReturn(5000L);333 334 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus'>"335 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"336 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"337 + "</ns1:element>" 338 + "</ns1:root>");339 340 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);341 when(endpoint.getActor()).thenReturn(null);342 343 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();344 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();345 receiveMessageBean.setMessageBuilder(controlMessageBuilder);346 controlMessageBuilder.setPayloadData("<ns1:root xmlns:ns1='http://citrus/wrong'>"347 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"348 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"349 + "</ns1:element>" 350 + "</ns1:root>");351 352 validationContext.setSchemaValidation(false);353 354 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();355 validationContexts.add(validationContext);356 receiveMessageBean.setValidationContexts(validationContexts);357 receiveMessageBean.execute(context);358 }359 360 @Test361 @SuppressWarnings({ "unchecked", "rawtypes" })362 public void testExpectDefaultNamespace() {363 reset(endpoint, consumer, endpointConfiguration);364 when(endpoint.createConsumer()).thenReturn(consumer);365 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);366 when(endpointConfiguration.getTimeout()).thenReturn(5000L);367 368 Message message = new DefaultMessage("<root xmlns='http://citrus'>"369 + "<element attributeA='attribute-value' attributeB='attribute-value'>"370 + "<sub-element attribute='A'>text-value</sub-element>"371 + "</element>" 372 + "</root>");373 374 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);375 when(endpoint.getActor()).thenReturn(null);376 377 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();378 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();379 receiveMessageBean.setMessageBuilder(controlMessageBuilder);380 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus'>"381 + "<element attributeA='attribute-value' attributeB='attribute-value'>"382 + "<sub-element attribute='A'>text-value</sub-element>"383 + "</element>" 384 + "</root>");385 386 Map<String, String> expectedNamespaces = new HashMap<String, String>();387 expectedNamespaces.put("", "http://citrus");388 389 validationContext.setControlNamespaces(expectedNamespaces);390 391 validationContext.setSchemaValidation(false);392 393 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();394 validationContexts.add(validationContext);395 receiveMessageBean.setValidationContexts(validationContexts);396 receiveMessageBean.execute(context);397 }398 399 @Test400 @SuppressWarnings({ "unchecked", "rawtypes" })401 public void testExpectNamespace() {402 reset(endpoint, consumer, endpointConfiguration);403 when(endpoint.createConsumer()).thenReturn(consumer);404 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);405 when(endpointConfiguration.getTimeout()).thenReturn(5000L);406 407 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus/ns1'>"408 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"409 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"410 + "</ns1:element>" 411 + "</ns1:root>");412 413 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);414 when(endpoint.getActor()).thenReturn(null);415 416 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();417 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();418 receiveMessageBean.setMessageBuilder(controlMessageBuilder);419 controlMessageBuilder.setPayloadData("<ns1:root xmlns:ns1='http://citrus/ns1'>"420 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"421 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"422 + "</ns1:element>" 423 + "</ns1:root>");424 425 Map<String, String> expectedNamespaces = new HashMap<String, String>();426 expectedNamespaces.put("ns1", "http://citrus/ns1");427 428 validationContext.setControlNamespaces(expectedNamespaces);429 430 validationContext.setSchemaValidation(false);431 432 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();433 validationContexts.add(validationContext);434 receiveMessageBean.setValidationContexts(validationContexts);435 receiveMessageBean.execute(context);436 }437 438 @Test439 @SuppressWarnings({ "unchecked", "rawtypes" })440 public void testExpectMixedNamespaces() {441 reset(endpoint, consumer, endpointConfiguration);442 when(endpoint.createConsumer()).thenReturn(consumer);443 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);444 when(endpointConfiguration.getTimeout()).thenReturn(5000L);445 446 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1'>"447 + "<element attributeA='attribute-value' attributeB='attribute-value'>"448 + "<sub-element attribute='A'>text-value</sub-element>"449 + "</element>" 450 + "</root>");451 452 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);453 when(endpoint.getActor()).thenReturn(null);454 455 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();456 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();457 receiveMessageBean.setMessageBuilder(controlMessageBuilder);458 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1'>"459 + "<element attributeA='attribute-value' attributeB='attribute-value'>"460 + "<sub-element attribute='A'>text-value</sub-element>"461 + "</element>" 462 + "</root>");463 464 Map<String, String> expectedNamespaces = new HashMap<String, String>();465 expectedNamespaces.put("", "http://citrus/default");466 expectedNamespaces.put("ns1", "http://citrus/ns1");467 468 validationContext.setControlNamespaces(expectedNamespaces);469 470 validationContext.setSchemaValidation(false);471 472 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();473 validationContexts.add(validationContext);474 receiveMessageBean.setValidationContexts(validationContexts);475 receiveMessageBean.execute(context);476 }477 478 @Test479 @SuppressWarnings({ "unchecked", "rawtypes" })480 public void testExpectMultipleNamespaces() {481 reset(endpoint, consumer, endpointConfiguration);482 when(endpoint.createConsumer()).thenReturn(consumer);483 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);484 when(endpointConfiguration.getTimeout()).thenReturn(5000L);485 486 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"487 + "<element attributeA='attribute-value' attributeB='attribute-value'>"488 + "<sub-element attribute='A'>text-value</sub-element>"489 + "</element>" 490 + "</root>");491 492 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);493 when(endpoint.getActor()).thenReturn(null);494 495 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();496 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();497 receiveMessageBean.setMessageBuilder(controlMessageBuilder);498 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"499 + "<element attributeA='attribute-value' attributeB='attribute-value'>"500 + "<sub-element attribute='A'>text-value</sub-element>"501 + "</element>" 502 + "</root>");503 504 Map<String, String> expectedNamespaces = new HashMap<String, String>();505 expectedNamespaces.put("", "http://citrus/default");506 expectedNamespaces.put("ns1", "http://citrus/ns1");507 expectedNamespaces.put("ns2", "http://citrus/ns2");508 509 validationContext.setControlNamespaces(expectedNamespaces);510 511 validationContext.setSchemaValidation(false);512 513 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();514 validationContexts.add(validationContext);515 receiveMessageBean.setValidationContexts(validationContexts);516 receiveMessageBean.execute(context);517 }518 519 @Test(expectedExceptions = {ValidationException.class})520 @SuppressWarnings({ "unchecked", "rawtypes" })521 public void testExpectDefaultNamespaceError() {522 reset(endpoint, consumer, endpointConfiguration);523 when(endpoint.createConsumer()).thenReturn(consumer);524 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);525 when(endpointConfiguration.getTimeout()).thenReturn(5000L);526 527 Message message = new DefaultMessage("<root xmlns='http://citrus'>"528 + "<element attributeA='attribute-value' attributeB='attribute-value'>"529 + "<sub-element attribute='A'>text-value</sub-element>"530 + "</element>" 531 + "</root>");532 533 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);534 when(endpoint.getActor()).thenReturn(null);535 536 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();537 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();538 receiveMessageBean.setMessageBuilder(controlMessageBuilder);539 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus'>"540 + "<element attributeA='attribute-value' attributeB='attribute-value'>"541 + "<sub-element attribute='A'>text-value</sub-element>"542 + "</element>" 543 + "</root>");544 545 Map<String, String> expectedNamespaces = new HashMap<String, String>();546 expectedNamespaces.put("", "http://citrus/wrong");547 548 validationContext.setControlNamespaces(expectedNamespaces);549 550 validationContext.setSchemaValidation(false);551 552 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();553 validationContexts.add(validationContext);554 receiveMessageBean.setValidationContexts(validationContexts);555 receiveMessageBean.execute(context);556 }557 558 @Test(expectedExceptions = {ValidationException.class})559 @SuppressWarnings({ "unchecked", "rawtypes" })560 public void testExpectNamespaceError() {561 reset(endpoint, consumer, endpointConfiguration);562 when(endpoint.createConsumer()).thenReturn(consumer);563 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);564 when(endpointConfiguration.getTimeout()).thenReturn(5000L);565 566 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus/ns1'>"567 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"568 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"569 + "</ns1:element>" 570 + "</ns1:root>");571 572 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);573 when(endpoint.getActor()).thenReturn(null);574 575 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();576 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();577 receiveMessageBean.setMessageBuilder(controlMessageBuilder);578 controlMessageBuilder.setPayloadData("<ns1:root xmlns:ns1='http://citrus/ns1'>"579 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value'>"580 + "<ns1:sub-element attribute='A'>text-value</ns1:sub-element>"581 + "</ns1:element>" 582 + "</ns1:root>");583 584 Map<String, String> expectedNamespaces = new HashMap<String, String>();585 expectedNamespaces.put("ns1", "http://citrus/ns1/wrong");586 587 validationContext.setControlNamespaces(expectedNamespaces);588 589 validationContext.setSchemaValidation(false);590 591 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();592 validationContexts.add(validationContext);593 receiveMessageBean.setValidationContexts(validationContexts);594 receiveMessageBean.execute(context);595 }596 597 @Test(expectedExceptions = {ValidationException.class})598 @SuppressWarnings({ "unchecked", "rawtypes" })599 public void testExpectMixedNamespacesError() {600 reset(endpoint, consumer, endpointConfiguration);601 when(endpoint.createConsumer()).thenReturn(consumer);602 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);603 when(endpointConfiguration.getTimeout()).thenReturn(5000L);604 605 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1'>"606 + "<element attributeA='attribute-value' attributeB='attribute-value'>"607 + "<sub-element attribute='A'>text-value</sub-element>"608 + "</element>" 609 + "</root>");610 611 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);612 when(endpoint.getActor()).thenReturn(null);613 614 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();615 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();616 receiveMessageBean.setMessageBuilder(controlMessageBuilder);617 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1'>"618 + "<element attributeA='attribute-value' attributeB='attribute-value'>"619 + "<sub-element attribute='A'>text-value</sub-element>"620 + "</element>" 621 + "</root>");622 623 Map<String, String> expectedNamespaces = new HashMap<String, String>();624 expectedNamespaces.put("", "http://citrus/default/wrong");625 expectedNamespaces.put("ns1", "http://citrus/ns1");626 627 validationContext.setControlNamespaces(expectedNamespaces);628 629 validationContext.setSchemaValidation(false);630 631 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();632 validationContexts.add(validationContext);633 receiveMessageBean.setValidationContexts(validationContexts);634 receiveMessageBean.execute(context);635 }636 637 @Test(expectedExceptions = {ValidationException.class})638 @SuppressWarnings({ "unchecked", "rawtypes" })639 public void testExpectMultipleNamespacesError() {640 reset(endpoint, consumer, endpointConfiguration);641 when(endpoint.createConsumer()).thenReturn(consumer);642 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);643 when(endpointConfiguration.getTimeout()).thenReturn(5000L);644 645 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"646 + "<element attributeA='attribute-value' attributeB='attribute-value'>"647 + "<sub-element attribute='A'>text-value</sub-element>"648 + "</element>" 649 + "</root>");650 651 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);652 when(endpoint.getActor()).thenReturn(null);653 654 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();655 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();656 receiveMessageBean.setMessageBuilder(controlMessageBuilder);657 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"658 + "<element attributeA='attribute-value' attributeB='attribute-value'>"659 + "<sub-element attribute='A'>text-value</sub-element>"660 + "</element>" 661 + "</root>");662 663 Map<String, String> expectedNamespaces = new HashMap<String, String>();664 expectedNamespaces.put("", "http://citrus/default");665 expectedNamespaces.put("ns1", "http://citrus/ns1/wrong");666 expectedNamespaces.put("ns2", "http://citrus/ns2");667 668 validationContext.setControlNamespaces(expectedNamespaces);669 670 validationContext.setSchemaValidation(false);671 672 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();673 validationContexts.add(validationContext);674 receiveMessageBean.setValidationContexts(validationContexts);675 receiveMessageBean.execute(context);676 }677 678 @Test(expectedExceptions = {ValidationException.class})679 @SuppressWarnings({ "unchecked", "rawtypes" })680 public void testExpectWrongNamespacePrefix() {681 reset(endpoint, consumer, endpointConfiguration);682 when(endpoint.createConsumer()).thenReturn(consumer);683 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);684 when(endpointConfiguration.getTimeout()).thenReturn(5000L);685 686 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"687 + "<element attributeA='attribute-value' attributeB='attribute-value'>"688 + "<sub-element attribute='A'>text-value</sub-element>"689 + "</element>" 690 + "</root>");691 692 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);693 when(endpoint.getActor()).thenReturn(null);694 695 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();696 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();697 receiveMessageBean.setMessageBuilder(controlMessageBuilder);698 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"699 + "<element attributeA='attribute-value' attributeB='attribute-value'>"700 + "<sub-element attribute='A'>text-value</sub-element>"701 + "</element>" 702 + "</root>");703 704 Map<String, String> expectedNamespaces = new HashMap<String, String>();705 expectedNamespaces.put("", "http://citrus/default");706 expectedNamespaces.put("nswrong", "http://citrus/ns1");707 expectedNamespaces.put("ns2", "http://citrus/ns2");708 709 validationContext.setControlNamespaces(expectedNamespaces);710 711 validationContext.setSchemaValidation(false);712 713 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();714 validationContexts.add(validationContext);715 receiveMessageBean.setValidationContexts(validationContexts);716 receiveMessageBean.execute(context);717 }718 719 @Test(expectedExceptions = {ValidationException.class})720 @SuppressWarnings({ "unchecked", "rawtypes" })721 public void testExpectDefaultNamespaceButNamespace() {722 reset(endpoint, consumer, endpointConfiguration);723 when(endpoint.createConsumer()).thenReturn(consumer);724 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);725 when(endpointConfiguration.getTimeout()).thenReturn(5000L);726 727 Message message = new DefaultMessage("<ns0:root xmlns:ns0='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"728 + "<ns0:element attributeA='attribute-value' attributeB='attribute-value'>"729 + "<ns0:sub-element attribute='A'>text-value</ns0:sub-element>"730 + "</ns0:element>" 731 + "</ns0:root>");732 733 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);734 when(endpoint.getActor()).thenReturn(null);735 736 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();737 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();738 receiveMessageBean.setMessageBuilder(controlMessageBuilder);739 controlMessageBuilder.setPayloadData("<ns0:root xmlns:ns0='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"740 + "<ns0:element attributeA='attribute-value' attributeB='attribute-value'>"741 + "<ns0:sub-element attribute='A'>text-value</ns0:sub-element>"742 + "</ns0:element>" 743 + "</ns0:root>");744 745 Map<String, String> expectedNamespaces = new HashMap<String, String>();746 expectedNamespaces.put("", "http://citrus/default");747 expectedNamespaces.put("ns1", "http://citrus/ns1");748 expectedNamespaces.put("ns2", "http://citrus/ns2");749 750 validationContext.setControlNamespaces(expectedNamespaces);751 752 validationContext.setSchemaValidation(false);753 754 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();755 validationContexts.add(validationContext);756 receiveMessageBean.setValidationContexts(validationContexts);757 receiveMessageBean.execute(context);758 }759 760 @Test(expectedExceptions = {ValidationException.class})761 @SuppressWarnings({ "unchecked", "rawtypes" })762 public void testExpectNamespaceButDefaultNamespace() {763 reset(endpoint, consumer, endpointConfiguration);764 when(endpoint.createConsumer()).thenReturn(consumer);765 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);766 when(endpointConfiguration.getTimeout()).thenReturn(5000L);767 768 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"769 + "<element attributeA='attribute-value' attributeB='attribute-value'>"770 + "<sub-element attribute='A'>text-value</sub-element>"771 + "</element>" 772 + "</root>");773 774 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);775 when(endpoint.getActor()).thenReturn(null);776 777 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();778 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();779 receiveMessageBean.setMessageBuilder(controlMessageBuilder);780 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"781 + "<element attributeA='attribute-value' attributeB='attribute-value'>"782 + "<sub-element attribute='A'>text-value</sub-element>"783 + "</element>" 784 + "</root>");785 786 Map<String, String> expectedNamespaces = new HashMap<String, String>();787 expectedNamespaces.put("ns0", "http://citrus/default");788 expectedNamespaces.put("ns1", "http://citrus/ns1");789 expectedNamespaces.put("ns2", "http://citrus/ns2");790 791 validationContext.setControlNamespaces(expectedNamespaces);792 793 validationContext.setSchemaValidation(false);794 795 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();796 validationContexts.add(validationContext);797 receiveMessageBean.setValidationContexts(validationContexts);798 receiveMessageBean.execute(context);799 }800 801 @Test(expectedExceptions = {ValidationException.class})802 @SuppressWarnings({ "unchecked", "rawtypes" })803 public void testExpectAdditionalNamespace() {804 reset(endpoint, consumer, endpointConfiguration);805 when(endpoint.createConsumer()).thenReturn(consumer);806 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);807 when(endpointConfiguration.getTimeout()).thenReturn(5000L);808 809 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"810 + "<element attributeA='attribute-value' attributeB='attribute-value'>"811 + "<sub-element attribute='A'>text-value</sub-element>"812 + "</element>" 813 + "</root>");814 815 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);816 when(endpoint.getActor()).thenReturn(null);817 818 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();819 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();820 receiveMessageBean.setMessageBuilder(controlMessageBuilder);821 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2'>"822 + "<element attributeA='attribute-value' attributeB='attribute-value'>"823 + "<sub-element attribute='A'>text-value</sub-element>"824 + "</element>" 825 + "</root>");826 827 Map<String, String> expectedNamespaces = new HashMap<String, String>();828 expectedNamespaces.put("", "http://citrus/default");829 expectedNamespaces.put("ns1", "http://citrus/ns1");830 expectedNamespaces.put("ns2", "http://citrus/ns2");831 expectedNamespaces.put("ns4", "http://citrus/ns4");832 833 validationContext.setControlNamespaces(expectedNamespaces);834 835 validationContext.setSchemaValidation(false);836 837 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();838 validationContexts.add(validationContext);839 receiveMessageBean.setValidationContexts(validationContexts);840 receiveMessageBean.execute(context);841 }842 843 @Test(expectedExceptions = {ValidationException.class})844 @SuppressWarnings({ "unchecked", "rawtypes" })845 public void testExpectNamespaceButNamespaceMissing() {846 reset(endpoint, consumer, endpointConfiguration);847 when(endpoint.createConsumer()).thenReturn(consumer);848 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);849 when(endpointConfiguration.getTimeout()).thenReturn(5000L);850 851 Message message = new DefaultMessage("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2' xmlns:ns4='http://citrus/ns4'>"852 + "<element attributeA='attribute-value' attributeB='attribute-value'>"853 + "<sub-element attribute='A'>text-value</sub-element>"854 + "</element>" 855 + "</root>");856 857 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);858 when(endpoint.getActor()).thenReturn(null);859 860 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();861 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();862 receiveMessageBean.setMessageBuilder(controlMessageBuilder);863 controlMessageBuilder.setPayloadData("<root xmlns='http://citrus/default' xmlns:ns1='http://citrus/ns1' xmlns:ns2='http://citrus/ns2' xmlns:ns4='http://citrus/ns4'>"864 + "<element attributeA='attribute-value' attributeB='attribute-value'>"865 + "<sub-element attribute='A'>text-value</sub-element>"866 + "</element>" 867 + "</root>");868 869 Map<String, String> expectedNamespaces = new HashMap<String, String>();870 expectedNamespaces.put("", "http://citrus/default");871 expectedNamespaces.put("ns1", "http://citrus/ns1");872 expectedNamespaces.put("ns2", "http://citrus/ns2");873 874 validationContext.setControlNamespaces(expectedNamespaces);875 876 validationContext.setSchemaValidation(false);877 878 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();879 validationContexts.add(validationContext);880 receiveMessageBean.setValidationContexts(validationContexts);881 receiveMessageBean.execute(context);882 }883 884 @Test885 @SuppressWarnings({ "unchecked", "rawtypes" })886 public void testValidateMessageElementsWithAdditionalNamespacePrefix() {887 reset(endpoint, consumer, endpointConfiguration);888 when(endpoint.createConsumer()).thenReturn(consumer);889 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);890 when(endpointConfiguration.getTimeout()).thenReturn(5000L);891 892 Message message = new DefaultMessage("<root xmlns='http://citrus/default'>"893 + "<element attributeA='attribute-value' attributeB='attribute-value' >"894 + "<sub-elementA attribute='A'>text-value</sub-elementA>"895 + "<sub-elementB attribute='B'>text-value</sub-elementB>"896 + "<sub-elementC attribute='C'>text-value</sub-elementC>"897 + "</element>" 898 + "</root>");899 900 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);901 when(endpoint.getActor()).thenReturn(null);902 HashMap<String, Object> validateMessageElements = new HashMap<>();903 validateMessageElements.put("//ns1:root/ns1:element/ns1:sub-elementA", "text-value");904 validateMessageElements.put("//ns1:sub-elementB", "text-value");905 906 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();907 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();908 receiveMessageBean.setMessageBuilder(controlMessageBuilder);909 validationContext.setXpathExpressions(validateMessageElements);910 911 Map<String, String> namespaces = new HashMap<String, String>();912 namespaces.put("ns1", "http://citrus/default");913 914 validationContext.setNamespaces(namespaces);915 916 validationContext.setSchemaValidation(false);917 918 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();919 validationContexts.add(validationContext);920 receiveMessageBean.setValidationContexts(validationContexts);921 receiveMessageBean.execute(context);922 }923 924 @Test925 @SuppressWarnings({ "unchecked", "rawtypes" })926 public void testValidateMessageElementsWithDifferentNamespacePrefix() {927 reset(endpoint, consumer, endpointConfiguration);928 when(endpoint.createConsumer()).thenReturn(consumer);929 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);930 when(endpointConfiguration.getTimeout()).thenReturn(5000L);931 932 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus/default'>"933 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value' >"934 + "<ns1:sub-elementA attribute='A'>text-value</ns1:sub-elementA>"935 + "<ns1:sub-elementB attribute='B'>text-value</ns1:sub-elementB>"936 + "<ns1:sub-elementC attribute='C'>text-value</ns1:sub-elementC>"937 + "</ns1:element>" 938 + "</ns1:root>");939 940 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);941 when(endpoint.getActor()).thenReturn(null);942 HashMap<String, Object> validateMessageElements = new HashMap<>();943 validateMessageElements.put("//pfx:root/pfx:element/pfx:sub-elementA", "text-value");944 validateMessageElements.put("//pfx:sub-elementB", "text-value");945 946 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();947 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();948 receiveMessageBean.setMessageBuilder(controlMessageBuilder);949 validationContext.setXpathExpressions(validateMessageElements);950 951 Map<String, String> namespaces = new HashMap<String, String>();952 namespaces.put("pfx", "http://citrus/default");953 954 validationContext.setNamespaces(namespaces);955 956 validationContext.setSchemaValidation(false);957 958 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();959 validationContexts.add(validationContext);960 receiveMessageBean.setValidationContexts(validationContexts);961 receiveMessageBean.execute(context);962 }963 964 @Test(expectedExceptions = {CitrusRuntimeException.class})965 @SuppressWarnings({ "unchecked", "rawtypes" })966 public void testWrongNamespaceContext() {967 reset(endpoint, consumer, endpointConfiguration);968 when(endpoint.createConsumer()).thenReturn(consumer);969 when(endpoint.getEndpointConfiguration()).thenReturn(endpointConfiguration);970 when(endpointConfiguration.getTimeout()).thenReturn(5000L);971 972 Message message = new DefaultMessage("<ns1:root xmlns:ns1='http://citrus/default'>"973 + "<ns1:element attributeA='attribute-value' attributeB='attribute-value' >"974 + "<ns1:sub-elementA attribute='A'>text-value</ns1:sub-elementA>"975 + "<ns1:sub-elementB attribute='B'>text-value</ns1:sub-elementB>"976 + "<ns1:sub-elementC attribute='C'>text-value</ns1:sub-elementC>"977 + "</ns1:element>" 978 + "</ns1:root>");979 980 when(consumer.receive(any(TestContext.class), anyLong())).thenReturn(message);981 when(endpoint.getActor()).thenReturn(null);982 HashMap<String, Object> validateMessageElements = new HashMap<>();983 validateMessageElements.put("//pfx:root/ns1:element/pfx:sub-elementA", "text-value");984 validateMessageElements.put("//pfx:sub-elementB", "text-value");985 986 PayloadTemplateMessageBuilder controlMessageBuilder = new PayloadTemplateMessageBuilder();987 XpathMessageValidationContext validationContext = new XpathMessageValidationContext();988 receiveMessageBean.setMessageBuilder(controlMessageBuilder);989 validationContext.setXpathExpressions(validateMessageElements);990 991 Map<String, String> namespaces = new HashMap<String, String>();992 namespaces.put("pfx", "http://citrus/wrong");993 994 validationContext.setNamespaces(namespaces);995 996 validationContext.setSchemaValidation(false);997 998 List<ValidationContext> validationContexts = new ArrayList<ValidationContext>();999 validationContexts.add(validationContext);1000 receiveMessageBean.setValidationContexts(validationContexts);1001 receiveMessageBean.execute(context);1002 }1003}...

Source:ReceiveMessageBuilder.java

...479 * @param enabled480 * @return481 */482 public T schemaValidation(boolean enabled) {483 xmlMessageValidationContext.setSchemaValidation(enabled);484 jsonMessageValidationContext.setSchemaValidation(enabled);485 return self;486 }487 /**488 * Validates XML namespace with prefix and uri.489 * @param prefix490 * @param namespaceUri491 * @return492 */493 public T validateNamespace(String prefix, String namespaceUri) {494 xmlMessageValidationContext.getControlNamespaces().put(prefix, namespaceUri);495 return self;496 }497 498 /**499 * Adds message element validation.500 * @param path501 * @param controlValue502 * @return503 */504 public T validate(String path, Object controlValue) {505 if (JsonPathMessageValidationContext.isJsonPathExpression(path)) {506 getJsonPathValidationContext().getJsonPathExpressions().put(path, controlValue);507 } else {508 getXPathValidationContext().getXpathExpressions().put(path, controlValue);509 }510 return self;511 }512 513 /**514 * Adds ignore path expression for message element.515 * @param path516 * @return517 */518 public T ignore(String path) {519 if (messageType.equalsIgnoreCase(MessageType.XML.name())520 || messageType.equalsIgnoreCase(MessageType.XHTML.name())) {521 xmlMessageValidationContext.getIgnoreExpressions().add(path);522 } else if (messageType.equalsIgnoreCase(MessageType.JSON.name())) {523 jsonMessageValidationContext.getIgnoreExpressions().add(path);524 }525 return self;526 }527 528 /**529 * Adds XPath message element validation.530 * @param xPathExpression531 * @param controlValue532 * @return533 */534 public T xpath(String xPathExpression, Object controlValue) {535 validate(xPathExpression, controlValue);536 return self;537 }538 /**539 * Adds JsonPath message element validation.540 * @param jsonPathExpression541 * @param controlValue542 * @return543 */544 public T jsonPath(String jsonPathExpression, Object controlValue) {545 validate(jsonPathExpression, controlValue);546 return self;547 }548 549 /**550 * Sets explicit schema instance name to use for schema validation.551 * @param schemaName552 * @return553 */554 public T xsd(String schemaName) {555 xmlMessageValidationContext.setSchema(schemaName);556 return self;557 }558 /**559 * Sets explicit schema instance name to use for schema validation.560 * @param schemaName The name of the schema bean561 */562 public T jsonSchema(String schemaName) {563 jsonMessageValidationContext.setSchema(schemaName);564 return self;565 }566 567 /**568 * Sets explicit xsd schema repository instance to use for validation.569 * @param schemaRepository570 * @return571 */572 public T xsdSchemaRepository(String schemaRepository) {573 xmlMessageValidationContext.setSchemaRepository(schemaRepository);574 return self;575 }576 /**577 * Sets explicit json schema repository instance to use for validation.578 * @param schemaRepository The name of the schema repository bean579 * @return580 */581 public T jsonSchemaRepository(String schemaRepository) {582 jsonMessageValidationContext.setSchemaRepository(schemaRepository);583 return self;584 }585 586 /**587 * Adds explicit namespace declaration for later path validation expressions.588 * @param prefix589 * @param namespaceUri590 * @return591 */592 public T namespace(String prefix, String namespaceUri) {593 getXpathVariableExtractor().getNamespaces().put(prefix, namespaceUri);594 xmlMessageValidationContext.getNamespaces().put(prefix, namespaceUri);595 return self;596 }597 598 /**599 * Sets default namespace declarations on this action builder.600 * @param namespaceMappings601 * @return602 */603 public T namespaces(Map<String, String> namespaceMappings) {604 getXpathVariableExtractor().getNamespaces().putAll(namespaceMappings);605 xmlMessageValidationContext.getNamespaces().putAll(namespaceMappings);606 return self;607 }608 609 /**610 * Sets message selector string.611 * @param messageSelector612 * @return613 */614 public T selector(String messageSelector) {615 getAction().setMessageSelector(messageSelector);616 return self;617 }618 619 /**620 * Sets message selector elements.621 * @param messageSelector622 * @return623 */624 public T selector(Map<String, Object> messageSelector) {625 getAction().setMessageSelectorMap(messageSelector);626 return self;627 }628 629 /**630 * Sets explicit message validators for this receive action.631 * @param validators632 * @return633 */634 public T validator(MessageValidator<? extends ValidationContext> ... validators) {635 Stream.of(validators).forEach(getAction()::addValidator);636 return self;637 }638 639 /**640 * Sets explicit message validators by name.641 * @param validatorNames642 * @return643 */644 @SuppressWarnings("unchecked")645 public T validator(String ... validatorNames) {646 Assert.notNull(applicationContext, "Citrus application context is not initialized!");647 for (String validatorName : validatorNames) {648 getAction().addValidator(applicationContext.getBean(validatorName, MessageValidator.class));649 }650 return self;651 }652 /**653 * Sets explicit header validator for this receive action.654 * @param validators655 * @return656 */657 public T headerValidator(HeaderValidator... validators) {658 Stream.of(validators).forEach(headerValidationContext::addHeaderValidator);659 return self;660 }661 /**662 * Sets explicit header validators by name.663 * @param validatorNames664 * @return665 */666 @SuppressWarnings("unchecked")667 public T headerValidator(String ... validatorNames) {668 Assert.notNull(applicationContext, "Citrus application context is not initialized!");669 for (String validatorName : validatorNames) {670 headerValidationContext.addHeaderValidator(applicationContext.getBean(validatorName, HeaderValidator.class));671 }672 return self;673 }674 /**675 * Sets explicit data dictionary for this receive action.676 * @param dictionary677 * @return678 */679 public T dictionary(DataDictionary dictionary) {680 getAction().setDataDictionary(dictionary);681 return self;682 }683 /**684 * Sets explicit data dictionary by name.685 * @param dictionaryName686 * @return687 */688 @SuppressWarnings("unchecked")689 public T dictionary(String dictionaryName) {690 Assert.notNull(applicationContext, "Citrus application context is not initialized!");691 DataDictionary dictionary = applicationContext.getBean(dictionaryName, DataDictionary.class);692 getAction().setDataDictionary(dictionary);693 return self;694 }695 696 /**697 * Extract message header entry as variable.698 * @param headerName699 * @param variable700 * @return701 */702 public T extractFromHeader(String headerName, String variable) {703 if (headerExtractor == null) {704 headerExtractor = new MessageHeaderVariableExtractor();705 getAction().getVariableExtractors().add(headerExtractor);706 }707 708 headerExtractor.getHeaderMappings().put(headerName, variable);709 return self;710 }711 712 /**713 * Extract message element via XPath or JSONPath from message payload as new test variable.714 * @param path715 * @param variable716 * @return717 */718 public T extractFromPayload(String path, String variable) {719 if (JsonPathMessageValidationContext.isJsonPathExpression(path)) {720 getJsonPathVariableExtractor().getJsonPathExpressions().put(path, variable);721 } else {722 getXpathVariableExtractor().getXpathExpressions().put(path, variable);723 }724 return self;725 }726 727 /**728 * Adds validation callback to the receive action for validating 729 * the received message with Java code.730 * @param callback731 * @return732 */733 public T validationCallback(ValidationCallback callback) {734 if (callback instanceof ApplicationContextAware) {735 ((ApplicationContextAware) callback).setApplicationContext(applicationContext);736 }737 getAction().setValidationCallback(callback);738 return self;739 }740 /**741 * Sets the Spring bean application context.742 * @param applicationContext743 */744 public T withApplicationContext(ApplicationContext applicationContext) {745 this.applicationContext = applicationContext;746 return self;747 }748 /**749 * Get message builder, if already registered or create a new message builder and register it750 *751 * @return the message builder in use752 */753 protected AbstractMessageContentBuilder getMessageContentBuilder() {754 if (getAction().getMessageBuilder() != null && getAction().getMessageBuilder() instanceof AbstractMessageContentBuilder) {755 return (AbstractMessageContentBuilder) getAction().getMessageBuilder();756 } else {757 PayloadTemplateMessageBuilder messageBuilder = new PayloadTemplateMessageBuilder();758 getAction().setMessageBuilder(messageBuilder);759 return messageBuilder;760 }761 }762 /**763 * Creates new variable extractor and adds it to test action.764 */765 private XpathPayloadVariableExtractor getXpathVariableExtractor() {766 if (xpathExtractor == null) {767 xpathExtractor = new XpathPayloadVariableExtractor();768 getAction().getVariableExtractors().add(xpathExtractor);769 }770 return xpathExtractor;771 }772 /**773 * Creates new variable extractor and adds it to test action.774 */775 private JsonPathVariableExtractor getJsonPathVariableExtractor() {776 if (jsonPathExtractor == null) {777 jsonPathExtractor = new JsonPathVariableExtractor();778 getAction().getVariableExtractors().add(jsonPathExtractor);779 }780 return jsonPathExtractor;781 }782 /**783 * Gets the validation context as XML validation context an raises exception if existing validation context is784 * not a XML validation context.785 * @return786 */787 private XpathMessageValidationContext getXPathValidationContext() {788 if (xmlMessageValidationContext instanceof XpathMessageValidationContext) {789 return ((XpathMessageValidationContext)xmlMessageValidationContext);790 } else {791 XpathMessageValidationContext xPathContext = new XpathMessageValidationContext();792 xPathContext.setNamespaces(xmlMessageValidationContext.getNamespaces());793 xPathContext.setControlNamespaces(xmlMessageValidationContext.getControlNamespaces());794 xPathContext.setIgnoreExpressions(xmlMessageValidationContext.getIgnoreExpressions());795 xPathContext.setSchema(xmlMessageValidationContext.getSchema());796 xPathContext.setSchemaRepository(xmlMessageValidationContext.getSchemaRepository());797 xPathContext.setSchemaValidation(xmlMessageValidationContext.isSchemaValidationEnabled());798 xPathContext.setDTDResource(xmlMessageValidationContext.getDTDResource());799 getAction().getValidationContexts().remove(xmlMessageValidationContext);800 getAction().getValidationContexts().add(xPathContext);801 xmlMessageValidationContext = xPathContext;802 return xPathContext;803 }804 }805 /**806 * Creates new script validation context if not done before and gets the script validation context.807 */808 private ScriptValidationContext getScriptValidationContext() {809 if (scriptValidationContext == null) {810 scriptValidationContext = new ScriptValidationContext(messageType.toString());811 getAction().getValidationContexts().add(scriptValidationContext);...

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.validation.xml;2import com.consol.citrus.context.TestContext;3import com.consol.citrus.exceptions.CitrusRuntimeException;4import com.consol.citrus.message.Message;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.testng.AbstractTestNGUnitTest;7import com.consol.citrus.validation.context.ValidationContext;8import com.consol.citrus.validation.xml.XmlMessageValidationContext;9import org.testng.Assert;10import org.testng.annotations.Test;11import org.xml.sax.SAXException;12import javax.xml.parsers.ParserConfigurationException;13import java.io.IOException;14public class SetSchemaValidationTest extends AbstractTestNGUnitTest {15 public void testSetSchemaValidation() throws IOException, SAXException, ParserConfigurationException {16 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();17 validationContext.setSchemaValidation(false);18 Message message = new Message("<TestMessage><Text>Hello World!</Text></TestMessage>").setMessageType(MessageType.XML.name());19 Assert.assertFalse(validationContext.isSchemaValidation());20 validationContext.setSchemaValidation(true);21 Assert.assertTrue(validationContext.isSchemaValidation());22 try {23 validationContext.validateMessagePayload(message, message, context);24 } catch (CitrusRuntimeException e) {25 Assert.fail("An error occurred while validating the XML message payload.");

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.validation.xml;2import com.consol.citrus.context.TestContext;3import com.consol.citrus.exceptions.ValidationException;4import com.consol.citrus.message.Message;5import com.consol.citrus.validation.context.ValidationContext;6import com.consol.citrus.validation.xml.XmlMessageValidationContext;7import org.springframework.util.StringUtils;8public class XmlSchemaValidationMatcher extends AbstractXmlMessageValidationMatcher {9 public void validateMessagePayload(Message receivedMessage, Message controlMessage, TestContext context, ValidationContext validationContext) throws ValidationException {10 if (!(validationContext instanceof XmlMessageValidationContext)) {11 throw new ValidationException("Validation context is not of type XmlMessageValidationContext");12 }13 XmlMessageValidationContext xmlValidationContext = (XmlMessageValidationContext) validationContext;14 if (StringUtils.hasText(xmlValidationContext.getSchema())) {15 if (xmlValidationContext.isSchemaValidation()) {16 super.validateMessagePayload(receivedMessage, controlMessage, context, validationContext);17 }18 } else {19 throw new ValidationException("Unable to validate XML schema - no schema resource defined in validation context");20 }21 }22}23package com.consol.citrus.validation.xml;24import com.consol.citrus.context.TestContext;25import com.consol.citrus.exceptions.ValidationException;26import com.consol.citrus.message.Message;27import com.consol.citrus.validation.context.ValidationContext;28import com.consol.citrus.validation.xml.XmlMessageValidationContext;29import org.springframework.util.StringUtils;30public class XmlSchemaValidationMatcher extends AbstractXmlMessageValidationMatcher {31 public void validateMessagePayload(Message receivedMessage, Message controlMessage, TestContext context, ValidationContext validationContext) throws ValidationException {32 if (!(validationContext

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.validation.xml;2import com.consol.citrus.context.TestContext;3import com.consol.citrus.exceptions.ValidationException;4import com.consol.citrus.message.Message;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.validation.MessageValidator;7import com.consol.citrus.validation.context.ValidationContext;8import com.consol.citrus.validation.xml.XmlMessageValidationContext;9import com.consol.citrus.validation.xml.XmlMessageValidationUtils;10import org.slf4j.Logger;11import org.slf4j.LoggerFactory;12import org.springframework.util.xml.DomUtils;13import org.springframework.xml.validation.XmlValidator;14import org.springframework.xml.xsd.XsdSchema;15import org.w3c.dom.Document;16import org.w3c.dom.Element;17import org.xml.sax.SAXException;18import javax.xml.parsers.DocumentBuilder;19import javax.xml.parsers.ParserConfigurationException;20import javax.xml.transform.Source;21import javax.xml.transform.dom.DOMSource;22import javax.xml.validation.Schema;23import java.io.IOException;24import java.util.ArrayList;25import java.util.List;26import java.util.Map;27import java.util.Set;28public class XmlSchemaValidator implements MessageValidator<XmlMessageValidationContext> {29 private static Logger log = LoggerFactory.getLogger(XmlSchemaValidator.class);30 private final List<XmlSchemaValidationErrorHandler> validationErrorListeners = new ArrayList<XmlSchemaValidationErrorHandler>();31 private boolean schemaValidation = true;32 private String schemaLanguage = XmlMessageValidationContext.SCHEMA_LANGUAGE_XML_SCHEMA;33 private String schemaResourcePath;34 private Schema schema;35 private XsdSchema xsdSchema;36 private boolean schemaValidationEnabled = true;37 private boolean schemaValidationEnforced = true;38 private XmlValidator schemaValidator;39 private DocumentBuilder documentBuilder;40 public XmlSchemaValidator() {

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.validation.xml;2import com.consol.citrus.context.TestContext;3import com.consol.citrus.message.Message;4import com.consol.citrus.message.MessageType;5import com.consol.citrus.validation.MessageValidator;6import com.consol.citrus.validation.context.ValidationContext;7import com.consol.citrus.validation.xml.XmlMessageValidationContext;8import org.springframework.util.StringUtils;9import org.springframework.xml.xsd.SimpleXsdSchema;10import org.springframework.xml.xsd.XsdSchema;11import org.testng.Assert;12import org.testng.annotations.Test;13import org.xml.sax.SAXException;14import java.io.IOException;15import java.util.Collections;16public class XmlMessageValidationContextTest {17 public void testSchemaValidation() throws IOException, SAXException {18 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();19 validationContext.setSchemaValidation(true);20 validationContext.setSchemaRepository(Collections.singletonMap("test", new SimpleXsdSchema(getClass().getResource("test.xsd"))));21 MessageValidator messageValidator = new XmlMessageValidator();22 messageValidator.setValidationContext(validationContext);23 Message controlMessage = new Message("<testMessage><text>Hello</text></testMessage>")24 .setHeader("operation", "sayHello")25 .setHeader("correlationId", "1234567890")26 .setMessageType(MessageType.XML.name());27 Message receivedMessage = new Message("<testMessage><text>Hello</text></testMessage>")28 .setHeader("operation", "sayHello")29 .setHeader("correlationId", "1234567890")30 .setMessageType(MessageType.XML.name());31 messageValidator.validateMessagePayload(controlMessage, receivedMessage, new TestContext());32 }33 public void testSchemaValidationFail() throws IOException, SAXException {34 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();35 validationContext.setSchemaValidation(true);36 validationContext.setSchemaRepository(Collections.singletonMap("test", new SimpleXsdSchema(getClass().getResource("test.xsd"))));37 MessageValidator messageValidator = new XmlMessageValidator();38 messageValidator.setValidationContext(validationContext);39 Message controlMessage = new Message("<testMessage><text>Hello</text></testMessage>")40 .setHeader("operation", "sayHello")

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.dsl.testng;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.testng.CitrusParameters;4import com.consol.citrus.xml.namespace.NamespaceContextBuilder;5import com.consol.citrus.xml.schema.XsdSchemaRepository;6import org.springframework.beans.factory.annotation.Autowired;7import org.springframework.core.io.ClassPathResource;8import org.springframework.http.HttpStatus;9import org.springframework.http.MediaType;10import org.testng.annotations.Test;11public class SetSchemaValidationTestNGIT extends AbstractTestNGCitrusTest {12 private XsdSchemaRepository schemaRepository;13 @CitrusParameters({"name"})14 public void SetSchemaValidation(String name) {15 variable("name", name);16 variable("schemaLocation", "classpath:com/consol/citrus/dsl/runner/echo.xsd");17 variable("namespacePrefix", "tns");18 echo("SetSchemaValidation");19 http(httpActionBuilder -> httpActionBuilder20 .client("httpClient")21 .send()22 .post()23 .contentType(MediaType.APPLICATION_XML_VALUE)24 + "<tns:text>${name}</tns:text>"25 + "</tns:echoRequest>"));26 http(httpActionBuilder -> httpActionBuilder27 .client("httpClient")28 .receive()29 .response(HttpStatus.OK)30 .schemaValidation(true)31 .schemaRepository(schemaRepository)32 .schemaValidationContext(xmlMessageValidationContextBuilder -> xmlMessageValidationContextBuilder33 .namespaceContextBuilder(new NamespaceContextBuilder()34 + "<tns:text>Hello ${name}!</tns:text>"35 + "</tns:echoResponse>"));36 }37}

setSchemaValidation

Using AI Code Generation

1public class 4 {2 public static void main(String[] args) {3 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();4 xmlMessageValidationContext.setSchemaValidation(true);5 }6}7public class 5 {8 public static void main(String[] args) {9 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();10 xmlMessageValidationContext.setSchemaValidation(true);11 }12}13public class 6 {14 public static void main(String[] args) {15 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();16 xmlMessageValidationContext.setSchemaValidation(true);17 }18}19public class 7 {20 public static void main(String[] args) {21 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();22 xmlMessageValidationContext.setSchemaValidation(true);23 }24}25public class 8 {26 public static void main(String[] args) {27 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();28 xmlMessageValidationContext.setSchemaValidation(true);29 }30}31public class 9 {32 public static void main(String[] args) {33 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();34 xmlMessageValidationContext.setSchemaValidation(true);35 }36}

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.dsl.runner;2import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;3import com.consol.citrus.message.MessageType;4import com.consol.citrus.validation.xml.XmlMessageValidationContext;5import org.springframework.core.io.ClassPathResource;6import org.testng.annotations.Test;7public class SetSchemaValidationIT extends TestNGCitrusTestDesigner {8 public void setSchemaValidation() {9 variable("myVariable", "value");10 http()11 .client("httpClient")12 .send()13 .post("/test")14 .payload("<TestRequestMessage>" +15 "</TestRequestMessage>");16 http()17 .client("httpClient")18 .receive()19 .response(HttpStatus.OK)20 .payload("<TestResponseMessage>" +21 "</TestResponseMessage>");22 http()23 .client("httpClient")24 .send()25 .post("/test")26 .payload("<TestRequestMessage>" +27 "</TestRequestMessage>");28 http()29 .client("httpClient")30 .receive()31 .response(HttpStatus.OK)32 .payload("<TestResponseMessage>" +33 "</TestResponseMessage>");34 http()35 .client("httpClient")36 .send()37 .post("/test")38 .payload("<TestRequestMessage>" +39 "</TestRequestMessage>");40 http()41 .client("httpClient")42 .receive()43 .response(HttpStatus.OK)44 .payload("<TestResponseMessage>" +45 "</TestResponseMessage>");46 http()47 .client("httpClient")48 .send()49 .post("/test")50 .payload("<TestRequestMessage>" +51 "</TestRequestMessage>");52 http()53 .client("httpClient")54 .receive()55 .response(HttpStatus.OK)56 .payload("<TestResponseMessage>" +57 "</TestResponseMessage>");58 http()59 .client("httpClient")60 .send()61 .post("/test")62 .payload("<TestRequestMessage>" +63 "</TestRequestMessage>");64 http()

setSchemaValidation

Using AI Code Generation

1import com.consol.citrus.dsl.runner.TestRunner;2import com.consol.citrus.dsl.builder.BuilderSupport;3import com.consol.citrus.dsl.design.TestDesigner;4import com.consol.citrus.dsl.design.TestDesignerBeforeTestSupport;5import com.consol.citrus.dsl.builder.AbstractTestBehaviorBuilder;6import com.consol.citrus.dsl.builder.ReceiveMessageActionBuilder;7import com.consol.citrus.dsl.builder.SendMessageActionBuilder;8import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder;9import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder;10import com.consol.citrus.dsl.builder.EchoActionBuilder;11import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder;12import com.consol.citrus.dsl.builder.PurgeJmsTopicsActionBuilder;13import com.consol.citrus.dsl.builder.PurgeMessageChannelsActionBuilder;14import com.consol.citrus.dsl.builder.StopTimeActionBuilder;15import com.consol.citrus.dsl.builder.StartTimeActionBuilder;16import com.consol.citrus.dsl.builder.FailActionBuilder;17import com.consol.citrus.dsl.builder.SleepActionBuilder;18import com.consol.citrus.dsl.builder.ParallelBuilder;19import com.consol.citrus.dsl.builder.SequenceBuilder;20import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder.CreateVariablesActionBuilderSupport;21import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder.CreateVariablesActionBuilderImpl;22import com.consol.citrus.dsl.builder.EchoActionBuilder.EchoActionBuilderSupport;23import com.consol.citrus.dsl.builder.EchoActionBuilder.EchoActionBuilderImpl;24import com.consol.citrus.dsl.builder.FailActionBuilder.FailActionBuilderSupport;25import com.consol.citrus.dsl.builder.FailActionBuilder.FailActionBuilderImpl;26import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder.PurgeEndpointActionBuilderSupport;27import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder.PurgeEndpointActionBuilderImpl;28import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport;29import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderImpl;30import com.consol.citrus.dsl.builder.PurgeJmsTopicsActionBuilder.PurgeJmsTopicsActionBuilderSupport;31import com

setSchemaValidation

Using AI Code Generation

1public class 4.java {2public void configure() {3setSchemaValidation(true);4}5}6public class 5.java {7public void configure() {8setSchemaValidation(false);9}10}11public class 6.java {12public void configure() {13setSchemaValidation(true);14}15}16public class 7.java {17public void configure() {18setSchemaValidation(false);19}20}21public class 8.java {22public void configure() {23setSchemaValidation(true);24}25}26public class 9.java {27public void configure() {28setSchemaValidation(false);29}30}31public class 10.java {32public void configure() {33setSchemaValidation(true);34}35}

setSchemaValidation

Using AI Code Generation

1public void validateWithSchemaValidation() {2 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();3 validationContext.setSchemaValidation(true);4 context.setValidationContext(validationContext);5 send("sendRequest");6 receive("receiveResponse");7}8public void validateWithSchemaValidation() {9 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();10 validationContext.setSchemaValidation(true);11 context.setValidationContext(validationContext);12 send("sendRequest");13 receive("receiveResponse");14}15public void validateWithSchemaValidation() {16 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();17 validationContext.setSchemaValidation(true);18 context.setValidationContext(validationContext);19 send("sendRequest");20 receive("receiveResponse");21}22public void validateWithSchemaValidation() {23 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();24 validationContext.setSchemaValidation(true);25 context.setValidationContext(validationContext);26 send("sendRequest");27 receive("receiveResponse");28}29public void validateWithSchemaValidation() {30 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();31 validationContext.setSchemaValidation(true);32 context.setValidationContext(validationContext);33 send("sendRequest");34 receive("receiveResponse");35}36public void validateWithSchemaValidation() {37 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();38 validationContext.setSchemaValidation(true);39 context.setValidationContext(validationContext);40 send("sendRequest");41 receive("receiveResponse");42}43 public XmlSchemaValidator() {

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.validation.xml;2import com.consol.citrus.context.TestContext;3import com.consol.citrus.message.Message;4import com.consol.citrus.message.MessageType;5import com.consol.citrus.validation.MessageValidator;6import com.consol.citrus.validation.context.ValidationContext;7import com.consol.citrus.validation.xml.XmlMessageValidationContext;8import org.springframework.util.StringUtils;9import org.springframework.xml.xsd.SimpleXsdSchema;10import org.springframework.xml.xsd.XsdSchema;11import org.testng.Assert;12import org.testng.annotations.Test;13import org.xml.sax.SAXException;14import java.io.IOException;15import java.util.Collections;16public class XmlMessageValidationContextTest {17 public void testSchemaValidation() throws IOException, SAXException {18 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();19 validationContext.setSchemaValidation(true);20 validationContext.setSchemaRepository(Collections.singletonMap("test", new SimpleXsdSchema(getClass().getResource("test.xsd"))));21 MessageValidator messageValidator = new XmlMessageValidator();22 messageValidator.setValidationContext(validationContext);23 Message controlMessage = new Message("<testMessage><text>Hello</text></testMessage>")24 .setHeader("operation", "sayHello")25 .setHeader("correlationId", "1234567890")26 .setMessageType(MessageType.XML.name());27 Message receivedMessage = new Message("<testMessage><text>Hello</text></testMessage>")28 .setHeader("operation", "sayHello")29 .setHeader("correlationId", "1234567890")30 .setMessageType(MessageType.XML.name());31 messageValidator.validateMessagePayload(controlMessage, receivedMessage, new TestContext());32 }33 public void testSchemaValidationFail() throws IOException, SAXException {34 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();35 validationContext.setSchemaValidation(true);36 validationContext.setSchemaRepository(Collections.singletonMap("test", new SimpleXsdSchema(getClass().getResource("test.xsd"))));37 MessageValidator messageValidator = new XmlMessageValidator();38 messageValidator.setValidationContext(validationContext);39 Message controlMessage = new Message("<testMessage><text>Hello</text></testMessage>")40 .setHeader("operation", "sayHello")

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.dsl.testng;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.testng.CitrusParameters;4import com.consol.citrus.xml.namespace.NamespaceContextBuilder;5import com.consol.citrus.xml.schema.XsdSchemaRepository;6import org.springframework.beans.factory.annotation.Autowired;7import org.springframework.core.io.ClassPathResource;8import org.springframework.http.HttpStatus;9import org.springframework.http.MediaType;10import org.testng.annotations.Test;11public class SetSchemaValidationTestNGIT extends AbstractTestNGCitrusTest {12 private XsdSchemaRepository schemaRepository;13 @CitrusParameters({"name"})14 public void SetSchemaValidation(String name) {15 variable("name", name);16 variable("schemaLocation", "classpath:com/consol/citrus/dsl/runner/echo.xsd");17 variable("namespacePrefix", "tns");18 echo("SetSchemaValidation");19 http(httpActionBuilder -> httpActionBuilder20 .client("httpClient")21 .send()22 .post()23 .contentType(MediaType.APPLICATION_XML_VALUE)24 + "<tns:text>${name}</tns:text>"25 + "</tns:echoRequest>"));26 http(httpActionBuilder -> httpActionBuilder27 .client("httpClient")28 .receive()29 .response(HttpStatus.OK)30 .schemaValidation(true)31 .schemaRepository(schemaRepository)32 .schemaValidationContext(xmlMessageValidationContextBuilder -> xmlMessageValidationContextBuilder33 .namespaceContextBuilder(new NamespaceContextBuilder()34 + "<tns:text>Hello ${name}!</tns:text>"35 + "</tns:echoResponse>"));36 }37}

setSchemaValidation

Using AI Code Generation

1public class 4 {2 public static void main(String[] args) {3 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();4 xmlMessageValidationContext.setSchemaValidation(true);5 }6}7public class 5 {8 public static void main(String[] args) {9 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();10 xmlMessageValidationContext.setSchemaValidation(true);11 }12}13public class 6 {14 public static void main(String[] args) {15 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();16 xmlMessageValidationContext.setSchemaValidation(true);17 }18}19public class 7 {20 public static void main(String[] args) {21 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();22 xmlMessageValidationContext.setSchemaValidation(true);23 }24}25public class 8 {26 public static void main(String[] args) {27 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();28 xmlMessageValidationContext.setSchemaValidation(true);29 }30}31public class 9 {32 public static void main(String[] args) {33 XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();34 xmlMessageValidationContext.setSchemaValidation(true);35 }36}

setSchemaValidation

Using AI Code Generation

1import com.consol.citrus.dsl.runner.TestRunner;2import com.consol.citrus.dsl.builder.BuilderSupport;3import com.consol.citrus.dsl.design.TestDesigner;4import com.consol.citrus.dsl.design.TestDesignerBeforeTestSupport;5import com.consol.citrus.dsl.builder.AbstractTestBehaviorBuilder;6import com.consol.citrus.dsl.builder.ReceiveMessageActionBuilder;7import com.consol.citrus.dsl.builder.SendMessageActionBuilder;8import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder;9import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder;10import com.consol.citrus.dsl.builder.EchoActionBuilder;11import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder;12import com.consol.citrus.dsl.builder.PurgeJmsTopicsActionBuilder;13import com.consol.citrus.dsl.builder.PurgeMessageChannelsActionBuilder;14import com.consol.citrus.dsl.builder.StopTimeActionBuilder;15import com.consol.citrus.dsl.builder.StartTimeActionBuilder;16import com.consol.citrus.dsl.builder.FailActionBuilder;17import com.consol.citrus.dsl.builder.SleepActionBuilder;18import com.consol.citrus.dsl.builder.ParallelBuilder;19import com.consol.citrus.dsl.builder.SequenceBuilder;20import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder.CreateVariablesActionBuilderSupport;21import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder.CreateVariablesActionBuilderImpl;22import com.consol.citrus.dsl.builder.EchoActionBuilder.EchoActionBuilderSupport;23import com.consol.citrus.dsl.builder.EchoActionBuilder.EchoActionBuilderImpl;24import com.consol.citrus.dsl.builder.FailActionBuilder.FailActionBuilderSupport;25import com.consol.citrus.dsl.builder.FailActionBuilder.FailActionBuilderImpl;26import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder.PurgeEndpointActionBuilderSupport;27import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder.PurgeEndpointActionBuilderImpl;28import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport;29import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderImpl;30import com.consol.citrus.dsl.builder.PurgeJmsTopicsActionBuilder.PurgeJmsTopicsActionBuilderSupport;31import com

setSchemaValidation

Using AI Code Generation

1public class 4.java {2public void configure() {3setSchemaValidation(true);4}5}6public class 5.java {7public void configure() {8setSchemaValidation(false);9}10}11public class 6.java {12public void configure() {13setSchemaValidation(true);14}15}16public class 7.java {17public void configure() {18setSchemaValidation(false);19}20}21public class 8.java {22public void configure() {23setSchemaValidation(true);24}25}26public class 9.java {27public void configure() {28setSchemaValidation(false);29}30}31public class 10.java {32public void configure() {33setSchemaValidation(true);34}35}

setSchemaValidation

Using AI Code Generation

1public void validateWithSchemaValidation() {2 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();3 validationContext.setSchemaValidation(true);4 context.setValidationContext(validationContext);5 send("sendRequest");6 receive("receiveResponse");7}8public void validateWithSchemaValidation() {9 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();10 validationContext.setSchemaValidation(true);11 context.setValidationContext(validationContext);12 send("sendRequest");13 receive("receiveResponse");14}15public void validateWithSchemaValidation() {16 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();17 validationContext.setSchemaValidation(true);18 context.setValidationContext(validationContext);19 send("sendRequest");20 receive("receiveResponse");21}22public void validateWithSchemaValidation() {23 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();24 validationContext.setSchemaValidation(true);25 context.setValidationContext(validationContext);26 send("sendRequest");27 receive("receiveResponse");28}29public void validateWithSchemaValidation() {30 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();31 validationContext.setSchemaValidation(true);32 context.setValidationContext(validationContext);33 send("sendRequest");34 receive("receiveResponse");35}36public void validateWithSchemaValidation() {37 XmlMessageValidationContext validationContext = new XmlMessageValidationContext();38 validationContext.setSchemaValidation(true);39 context.setValidationContext(validationContext);40 send("sendRequest");41 receive("receiveResponse");42}

setSchemaValidation

Using AI Code Generation

1import com.consol.citrus.dsl.runner.TestRunner;2import com.consol.citrus.dsl.builder.BuilderSupport;3import com.consol.citrus.dsl.design.TestDesigner;4import com.consol.citrus.dsl.design.TestDesignerBeforeTestSupport;5import com.consol.citrus.dsl.builder.AbstractTestBehaviorBuilder;6import com.consol.citrus.dsl.builder.ReceiveMessageActionBuilder;7import com.consol.citrus.dsl.builder.SendMessageActionBuilder;8import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder;9import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder;10import com.consol.citrus.dsl.builder.EchoActionBuilder;11import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder;12import com.consol.citrus.dsl.builder.PurgeJmsTopicsActionBuilder;13import com.consol.citrus.dsl.builder.PurgeMessageChannelsActionBuilder;14import com.consol.citrus.dsl.builder.StopTimeActionBuilder;15import com.consol.citrus.dsl.builder.StartTimeActionBuilder;16import com.consol.citrus.dsl.builder.FailActionBuilder;17import com.consol.citrus.dsl.builder.SleepActionBuilder;18import com.consol.citrus.dsl.builder.ParallelBuilder;19import com.consol.citrus.dsl.builder.SequenceBuilder;20import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder.CreateVariablesActionBuilderSupport;21import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder.CreateVariablesActionBuilderImpl;22import com.consol.citrus.dsl.builder.EchoActionBuilder.EchoActionBuilderSupport;23import com.consol.citrus.dsl.builder.EchoActionBuilder.EchoActionBuilderImpl;24import com.consol.citrus.dsl.builder.FailActionBuilder.FailActionBuilderSupport;25import com.consol.citrus.dsl.builder.FailActionBuilder.FailActionBuilderImpl;26import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder.PurgeEndpointActionBuilderSupport;27import com.consol.citrus.dsl.builder.PurgeEndpointActionBuilder.PurgeEndpointActionBuilderImpl;28import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport;29import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderImpl;30import com.consol.citrus.dsl.builder.PurgeJmsTopicsActionBuilder.PurgeJmsTopicsActionBuilderSupport;31import com

setSchemaValidation

Using AI Code Generation

1public class 4.java {2public void configure() {3setSchemaValidation(true);4}5}6public class 5.java {7public void configure() {8setSchemaValidation(false);9}10}11public class 6.java {12public void configure() {13setSchemaValidation(true);14}15}16public class 7.java {17public void configure() {18setSchemaValidation(false);19}20}21public class 8.java {22public void configure() {23setSchemaValidation(true);24}25}26public class 9.java {27public void configure() {28setSchemaValidation(false);29}30}31public class 10.java {32public void configure() {33setSchemaValidation(true);34}35}

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.validation.xml;2import com.consol.citrus.context.TestContext;3import com.consol.citrus.exceptions.ValidationException;4import com.consol.citrus.message.Message;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.validation.MessageValidator;7import com.consol.citrus.validation.context.ValidationContext;8import com.consol.citrus.validation.xml.XmlMessageValidationContext;9import com.consol.citrus.validation.xml.XmlMessageValidationUtils;10import org.slf4j.Logger;11import org.slf4j.LoggerFactory;12import org.springframework.util.xml.DomUtils;13import org.springframework.xml.validation.XmlValidator;14import org.springframework.xml.xsd.XsdSchema;15import org.w3c.dom.Document;16import org.w3c.dom.Element;17import org.xml.sax.SAXException;18import javax.xml.parsers.DocumentBuilder;19import javax.xml.parsers.ParserConfigurationException;20import javax.xml.transform.Source;21import javax.xml.transform.dom.DOMSource;22import javax.xml.validation.Schema;23import java.io.IOException;24import java.util.ArrayList;25import java.util.List;26import java.util.Map;27import java.util.Set;28public class XmlSchemaValidator implements MessageValidator<XmlMessageValidationContext> {29 private static Logger log = LoggerFactory.getLogger(XmlSchemaValidator.class);30 private final List<XmlSchemaValidationErrorHandler> validationErrorListeners = new ArrayList<XmlSchemaValidationErrorHandler>();31 private boolean schemaValidation = true;32 private String schemaLanguage = XmlMessageValidationContext.SCHEMA_LANGUAGE_XML_SCHEMA;33 private String schemaResourcePath;34 private Schema schema;35 private XsdSchema xsdSchema;36 private boolean schemaValidationEnabled = true;37 private boolean schemaValidationEnforced = true;38 private XmlValidator schemaValidator;39 private DocumentBuilder documentBuilder;40 public XmlSchemaValidator() {

setSchemaValidation

Using AI Code Generation

1package com.consol.citrus.dsl.testng;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.testng.CitrusParameters;4import com.consol.citrus.xml.namespace.NamespaceContextBuilder;5import com.consol.citrus.xml.schema.XsdSchemaRepository;6import org.springframework.beans.factory.annotation.Autowired;7import org.springframework.core.io.ClassPathResource;8import org.springframework.http.HttpStatus;9import org.springframework.http.MediaType;10import org.testng.annotations.Test;11public class SetSchemaValidationTestNGIT extends AbstractTestNGCitrusTest {12 private XsdSchemaRepository schemaRepository;13 @CitrusParameters({"name"})14 public void SetSchemaValidation(String name) {15 variable("name", name);16 variable("schemaLocation", "classpath:com/consol/citrus/dsl/runner/echo.xsd");17 variable("namespacePrefix", "tns");18 echo("SetSchemaValidation");19 http(httpActionBuilder -> httpActionBuilder20 .client("httpClient")21 .send()22 .post()23 .contentType(MediaType.APPLICATION_XML_VALUE)24 + "<tns:text>${name}</tns:text>"25 + "</tns:echoRequest>"));26 http(httpActionBuilder -> httpActionBuilder27 .client("httpClient")28 .receive()29 .response(HttpStatus.OK)30 .schemaValidation(true)31 .schemaRepository(schemaRepository)32 .schemaValidationContext(xmlMessageValidationContextBuilder -> xmlMessageValidationContextBuilder33 .namespaceContextBuilder(new NamespaceContextBuilder()34 + "<tns:text>Hello ${name}!</tns:text>"35 + "</tns:echoResponse>"));36 }37}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

• JUnit Tutorial
• TestNG Tutorial
• Webdriver Tutorial
• WebDriverIO Tutorial
• Protractor Tutorial
• Selenium 4 Tutorial
• Jenkins Tutorial
• NUnit Tutorial
• Jest Tutorial
• Playwright Tutorial
• Cypress Tutorial
• PyTest Tutorial

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Citrus automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

View sample repo View DocumentationSign up Free

›

_

Most used method in XmlMessageValidationContext

• getIgnoreExpressions
• setIgnoreExpressions
• getNamespaces
• setNamespaces
• getDTDResource
• setDTDResource
• getControlNamespaces
• setControlNamespaces
• isSchemaValidationEnabled
• setSchemaValidation
• getSchemaRepository
• setSchemaRepository
• getSchema
• setSchema