How to use JsonMessageValidationContext method of com.consol.citrus.dsl.builder.ReceiveMessageBuilder class

Best Citrus code snippet using com.consol.citrus.dsl.builder.ReceiveMessageBuilder.JsonMessageValidationContext

Source:ReceiveMessageBuilder.java Github

copy

Full Screen

...61 private String messageType;62 /** Validation context used in this action builder */63 private HeaderValidationContext headerValidationContext = new HeaderValidationContext();64 private XmlMessageValidationContext xmlMessageValidationContext = new XmlMessageValidationContext();65 private JsonMessageValidationContext jsonMessageValidationContext = new JsonMessageValidationContext();66 /** JSON validation context used in this action builder */67 private JsonPathMessageValidationContext jsonPathValidationContext;68 /** Script validation context used in this action builder */69 private ScriptValidationContext scriptValidationContext;70 /** Variable extractors filled within this action builder */71 private MessageHeaderVariableExtractor headerExtractor;72 private XpathPayloadVariableExtractor xpathExtractor;73 private JsonPathVariableExtractor jsonPathExtractor;74 /** Basic application context */75 private ApplicationContext applicationContext;76 /**77 * Default constructor using test action, basic application context and position handle.78 * @param action79 */80 public ReceiveMessageBuilder(A action) {81 this(new DelegatingTestAction(action));82 }83 /**84 * Default constructor.85 */86 public ReceiveMessageBuilder() {87 this((A) new ReceiveMessageAction());88 }89 /**90 * Constructor using delegate test action.91 * @param action92 */93 public ReceiveMessageBuilder(DelegatingTestAction<TestAction> action) {94 super(action);95 this.self = (T) this;96 }97 /**98 * Sets the message endpoint to receive messages from.99 * @param messageEndpoint100 * @return101 */102 public ReceiveMessageBuilder endpoint(Endpoint messageEndpoint) {103 getAction().setEndpoint(messageEndpoint);104 return this;105 }106 /**107 * Sets the message endpoint uri to receive messages from.108 * @param messageEndpointUri109 * @return110 */111 public ReceiveMessageBuilder endpoint(String messageEndpointUri) {112 getAction().setEndpointUri(messageEndpointUri);113 return this;114 }115 /**116 * Adds a custom timeout to this message receiving action.117 * @param receiveTimeout118 * @return119 */120 public T timeout(long receiveTimeout) {121 getAction().setReceiveTimeout(receiveTimeout);122 return self;123 }124 125 /**126 * Expect a control message in this receive action.127 * @param controlMessage128 * @return129 */130 public T message(Message controlMessage) {131 StaticMessageContentBuilder staticMessageContentBuilder = StaticMessageContentBuilder.withMessage(controlMessage);132 staticMessageContentBuilder.setMessageHeaders(getMessageContentBuilder().getMessageHeaders());133 getAction().setMessageBuilder(staticMessageContentBuilder);134 return self;135 }136 /**137 * Sets the payload data on the message builder implementation.138 * @param payload139 * @return140 */141 protected void setPayload(String payload) {142 MessageContentBuilder messageContentBuilder = getMessageContentBuilder();143 if (messageContentBuilder instanceof PayloadTemplateMessageBuilder) {144 ((PayloadTemplateMessageBuilder) messageContentBuilder).setPayloadData(payload);145 } else if (messageContentBuilder instanceof StaticMessageContentBuilder) {146 ((StaticMessageContentBuilder) messageContentBuilder).getMessage().setPayload(payload);147 } else {148 throw new CitrusRuntimeException("Unable to set payload on message builder type: " + messageContentBuilder.getClass());149 }150 }151 /**152 * Sets the message name.153 * @param name154 * @return155 */156 public T name(String name) {157 getMessageContentBuilder().setMessageName(name);158 return self;159 }160 161 /**162 * Expect this message payload data in received message.163 * @param payload164 * @return165 */166 public T payload(String payload) {167 setPayload(payload);168 return self;169 }170 171 /**172 * Expect this message payload data in received message.173 * @param payloadResource174 * @return175 */176 public T payload(Resource payloadResource) {177 return payload(payloadResource, FileUtils.getDefaultCharset());178 }179 /**180 * Expect this message payload data in received message.181 * @param payloadResource182 * @param charset183 * @return184 */185 public T payload(Resource payloadResource, Charset charset) {186 try {187 setPayload(FileUtils.readToString(payloadResource, charset));188 } catch (IOException e) {189 throw new CitrusRuntimeException("Failed to read payload resource", e);190 }191 return self;192 }193 /**194 * Expect this message payload as model object which is marshalled to a character sequence195 * using the default object to xml mapper before validation is performed.196 * @param payload197 * @param marshaller198 * @return199 */200 public T payload(Object payload, Marshaller marshaller) {201 StringResult result = new StringResult();202 try {203 marshaller.marshal(payload, result);204 } catch (XmlMappingException e) {205 throw new CitrusRuntimeException("Failed to marshal object graph for message payload", e);206 } catch (IOException e) {207 throw new CitrusRuntimeException("Failed to marshal object graph for message payload", e);208 }209 setPayload(result.toString());210 return self;211 }212 /**213 * Expect this message payload as model object which is mapped to a character sequence214 * using the default object to json mapper before validation is performed.215 * @param payload216 * @param objectMapper217 * @return218 */219 public T payload(Object payload, ObjectMapper objectMapper) {220 try {221 setPayload(objectMapper.writer().writeValueAsString(payload));222 } catch (JsonProcessingException e) {223 throw new CitrusRuntimeException("Failed to map object graph for message payload", e);224 }225 return self;226 }227 /**228 * Expect this message payload as model object which is marshalled to a character sequence using the default object to xml mapper that229 * is available in Spring bean application context.230 *231 * @param payload232 * @return233 */234 public T payloadModel(Object payload) {235 Assert.notNull(applicationContext, "Citrus application context is not initialized!");236 if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(Marshaller.class))) {237 return payload(payload, applicationContext.getBean(Marshaller.class));238 } else if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(ObjectMapper.class))) {239 return payload(payload, applicationContext.getBean(ObjectMapper.class));240 }241 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");242 }243 /**244 * Expect this message payload as model object which is marshalled to a character sequence using the given object to xml mapper that245 * is accessed by its bean name in Spring bean application context.246 *247 * @param payload248 * @param mapperName249 * @return250 */251 public T payload(Object payload, String mapperName) {252 Assert.notNull(applicationContext, "Citrus application context is not initialized!");253 if (applicationContext.containsBean(mapperName)) {254 Object mapper = applicationContext.getBean(mapperName);255 if (Marshaller.class.isAssignableFrom(mapper.getClass())) {256 return payload(payload, (Marshaller) mapper);257 } else if (ObjectMapper.class.isAssignableFrom(mapper.getClass())) {258 return payload(payload, (ObjectMapper) mapper);259 } else {260 throw new CitrusRuntimeException(String.format("Invalid bean type for mapper '%s' expected ObjectMapper or Marshaller but was '%s'", mapperName, mapper.getClass()));261 }262 }263 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");264 }265 266 /**267 * Expect this message header entry in received message.268 * @param name269 * @param value270 * @return271 */272 public T header(String name, Object value) {273 getMessageContentBuilder().getMessageHeaders().put(name, value);274 return self;275 }276 /**277 * Expect this message header entries in received message.278 * @param headers279 * @return280 */281 public T headers(Map<String, Object> headers) {282 getMessageContentBuilder().getMessageHeaders().putAll(headers);283 return self;284 }285 286 /**287 * Expect this message header data in received message. Message header data is used in 288 * SOAP messages as XML fragment for instance.289 * @param data290 * @return291 */292 public T header(String data) {293 getMessageContentBuilder().getHeaderData().add(data);294 return self;295 }296 /**297 * Expect this message header data as model object which is marshalled to a character sequence using the default object to xml mapper that298 * is available in Spring bean application context.299 *300 * @param model301 * @return302 */303 public T headerFragment(Object model) {304 Assert.notNull(applicationContext, "Citrus application context is not initialized!");305 if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(Marshaller.class))) {306 return headerFragment(model, applicationContext.getBean(Marshaller.class));307 } else if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(ObjectMapper.class))) {308 return headerFragment(model, applicationContext.getBean(ObjectMapper.class));309 }310 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");311 }312 /**313 * Expect this message header data as model object which is marshalled to a character sequence using the given object to xml mapper that314 * is accessed by its bean name in Spring bean application context.315 *316 * @param model317 * @param mapperName318 * @return319 */320 public T headerFragment(Object model, String mapperName) {321 Assert.notNull(applicationContext, "Citrus application context is not initialized!");322 if (applicationContext.containsBean(mapperName)) {323 Object mapper = applicationContext.getBean(mapperName);324 if (Marshaller.class.isAssignableFrom(mapper.getClass())) {325 return headerFragment(model, (Marshaller) mapper);326 } else if (ObjectMapper.class.isAssignableFrom(mapper.getClass())) {327 return headerFragment(model, (ObjectMapper) mapper);328 } else {329 throw new CitrusRuntimeException(String.format("Invalid bean type for mapper '%s' expected ObjectMapper or Marshaller but was '%s'", mapperName, mapper.getClass()));330 }331 }332 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");333 }334 /**335 * Expect this message header data as model object which is marshalled to a character sequence336 * using the default object to xml mapper before validation is performed.337 * @param model338 * @param marshaller339 * @return340 */341 public T headerFragment(Object model, Marshaller marshaller) {342 StringResult result = new StringResult();343 try {344 marshaller.marshal(model, result);345 } catch (XmlMappingException e) {346 throw new CitrusRuntimeException("Failed to marshal object graph for message header data", e);347 } catch (IOException e) {348 throw new CitrusRuntimeException("Failed to marshal object graph for message header data", e);349 }350 return header(result.toString());351 }352 /**353 * Expect this message header data as model object which is mapped to a character sequence354 * using the default object to json mapper before validation is performed.355 * @param model356 * @param objectMapper357 * @return358 */359 public T headerFragment(Object model, ObjectMapper objectMapper) {360 try {361 return header(objectMapper.writer().writeValueAsString(model));362 } catch (JsonProcessingException e) {363 throw new CitrusRuntimeException("Failed to map object graph for message header data", e);364 }365 }366 /**367 * Expect this message header data in received message from file resource. Message header data is used in 368 * SOAP messages as XML fragment for instance.369 * @param resource370 * @return371 */372 public T header(Resource resource) {373 return header(resource, FileUtils.getDefaultCharset());374 }375 /**376 * Expect this message header data in received message from file resource. Message header data is used in377 * SOAP messages as XML fragment for instance.378 * @param resource379 * @param charset380 * @return381 */382 public T header(Resource resource, Charset charset) {383 try {384 getMessageContentBuilder().getHeaderData().add(FileUtils.readToString(resource, charset));385 } catch (IOException e) {386 throw new CitrusRuntimeException("Failed to read header resource", e);387 }388 return self;389 }390 /**391 * Validate header names with case insensitive keys.392 * @param value393 * @return394 */395 public T headerNameIgnoreCase(boolean value) {396 headerValidationContext.setHeaderNameIgnoreCase(value);397 return self;398 }399 400 /**401 * Adds script validation.402 * @param validationScript403 * @return404 */405 public T validateScript(String validationScript) {406 getScriptValidationContext().setValidationScript(validationScript);407 return self;408 }409 410 /**411 * Reads validation script file resource and sets content as validation script.412 * @param scriptResource413 * @return414 */415 public T validateScript(Resource scriptResource) {416 return validateScript(scriptResource, FileUtils.getDefaultCharset());417 }418 /**419 * Reads validation script file resource and sets content as validation script.420 * @param scriptResource421 * @param charset422 * @return423 */424 public T validateScript(Resource scriptResource, Charset charset) {425 try {426 validateScript(FileUtils.readToString(scriptResource, charset));427 } catch (IOException e) {428 throw new CitrusRuntimeException("Failed to read script resource file", e);429 }430 return self;431 }432 /**433 * Adds script validation file resource.434 * @param fileResourcePath435 * @return436 */437 public T validateScriptResource(String fileResourcePath) {438 getScriptValidationContext().setValidationScriptResourcePath(fileResourcePath);439 return self;440 }441 442 /**443 * Adds custom validation script type.444 * @param type445 * @return446 */447 public T validateScriptType(String type) {448 getScriptValidationContext().setScriptType(type);449 return self;450 }451 /**452 * Sets a explicit message type for this receive action.453 * @param messageType454 * @return455 */456 public T messageType(MessageType messageType) {457 messageType(messageType.name());458 return self;459 }460 461 /**462 * Sets a explicit message type for this receive action.463 * @param messageType464 * @return465 */466 public T messageType(String messageType) {467 this.messageType = messageType;468 getAction().setMessageType(messageType);469 if (getAction().getValidationContexts().isEmpty()) {470 getAction().getValidationContexts().add(headerValidationContext);471 getAction().getValidationContexts().add(xmlMessageValidationContext);472 getAction().getValidationContexts().add(jsonMessageValidationContext);473 }474 return self;475 }476 477 /**478 * Sets schema validation enabled/disabled for this message.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);812 }813 return scriptValidationContext;814 }815 /**816 * Creates new JSONPath validation context if not done before and gets the validation context.817 */818 private JsonPathMessageValidationContext getJsonPathValidationContext() {819 if (jsonPathValidationContext == null) {820 jsonPathValidationContext = new JsonPathMessageValidationContext();821 getAction().getValidationContexts().add(jsonPathValidationContext);822 }823 return jsonPathValidationContext;824 }825 /**826 * Provides access to receive message action delegate.827 * @return828 */829 protected ReceiveMessageAction getAction() {830 return (ReceiveMessageAction) action.getDelegate();831 }832 /**833 * Sets the message type.834 * @param messageType835 */836 protected void setMessageType(MessageType messageType) {837 this.messageType = messageType.name();838 }839 /**840 * Sets the message type.841 * @param messageType842 */843 protected void setMessageType(String messageType) {844 this.messageType = messageType;845 }846 /**847 * Sets the xpath extractor.848 * @param xpathExtractor849 */850 protected void setXpathExtractor(XpathPayloadVariableExtractor xpathExtractor) {851 this.xpathExtractor = xpathExtractor;852 }853 /**854 * Sets the jsonPath extractor.855 * @param jsonPathExtractor856 */857 protected void setJsonPathExtractor(JsonPathVariableExtractor jsonPathExtractor) {858 this.jsonPathExtractor = jsonPathExtractor;859 }860 /**861 * Sets the header extractor.862 * @param headerExtractor863 */864 protected void setHeaderExtractor(MessageHeaderVariableExtractor headerExtractor) {865 this.headerExtractor = headerExtractor;866 }867 /**868 * Sets the script message validator.869 * @param scriptValidationContext870 */871 protected void setScriptValidationContext(ScriptValidationContext scriptValidationContext) {872 this.scriptValidationContext = scriptValidationContext;873 }874 /**875 * Sets the script message validator.876 * @param jsonPathValidationContext877 */878 protected void setJsonPathValidationContext(JsonPathMessageValidationContext jsonPathValidationContext) {879 this.jsonPathValidationContext = jsonPathValidationContext;880 }881 /**882 * Sets the XML validation context.883 * @param validationContext884 */885 protected void setXmlMessageValidationContext(XmlMessageValidationContext validationContext) {886 this.xmlMessageValidationContext = validationContext;887 }888 /**889 * Sets the JSON validation context.890 * @param validationContext891 */892 protected void setJsonMessageValidationContext(JsonMessageValidationContext validationContext) {893 this.jsonMessageValidationContext = validationContext;894 }895 /**896 * Sets the header validation context.897 * @param validationContext898 */899 protected void setHeaderValidationContext(HeaderValidationContext validationContext) {900 this.headerValidationContext = validationContext;901 }902}...

Full Screen

Full Screen

Source:WebHookToFtp_IT.java Github

copy

Full Screen

...27import com.consol.citrus.ftp.message.FtpMessage;28import com.consol.citrus.http.client.HttpClient;29import com.consol.citrus.message.DefaultMessage;30import com.consol.citrus.util.FileUtils;31import com.consol.citrus.validation.json.JsonMessageValidationContext;32import com.consol.citrus.validation.json.JsonTextMessageValidator;33import io.syndesis.test.SyndesisTestEnvironment;34import io.syndesis.test.container.integration.SyndesisIntegrationRuntimeContainer;35import org.apache.commons.net.ftp.FTPCmd;36import org.apache.ftpserver.DataConnectionConfiguration;37import org.apache.ftpserver.DataConnectionConfigurationFactory;38import org.junit.Assert;39import org.junit.ClassRule;40import org.junit.Test;41import org.springframework.beans.factory.annotation.Autowired;42import org.springframework.context.annotation.Bean;43import org.springframework.context.annotation.Configuration;44import org.springframework.http.HttpStatus;45import org.springframework.test.annotation.DirtiesContext;46import org.springframework.test.context.ContextConfiguration;47import org.testcontainers.containers.GenericContainer;48/**49 * @author Christoph Deppisch50 */51@ContextConfiguration(classes = WebHookToFtp_IT.EndpointConfig.class)52@DirtiesContext53public class WebHookToFtp_IT extends FtpTestSupport {54 @Autowired55 private HttpClient webHookClient;56 /**57 * Integration receives a WebHook trigger with contact information as Json object. The contact is transformed to a csv like58 * comma delimited String and pushed to Ftp server as new file.59 */60 @ClassRule61 public static SyndesisIntegrationRuntimeContainer integrationContainer = new SyndesisIntegrationRuntimeContainer.Builder()62 .name("webhook-to-ftp")63 .fromExport(WebHookToFtp_IT.class.getResource("WebhookToFtp-export"))64 .customize("$..configuredProperties.contextPath", "contact")65 .customize("$..configuredProperties.directoryName", "public")66 .customize("$..configuredProperties.host", GenericContainer.INTERNAL_HOST_HOSTNAME)67 .customize("$..configuredProperties.port", FTP_TEST_SERVER_PORT)68 .build()69 .withExposedPorts(SyndesisTestEnvironment.getServerPort());70 @Test71 @CitrusTest72 public void testWebHookToFtp(@CitrusResource TestRunner runner) {73 runner.variable("first_name", "Joanne");74 runner.variable("company", "Red Hat");75 runner.variable("email", "joanne@syndesis.org");76 runner.http(builder -> builder.client(webHookClient)77 .send()78 .post()79 .fork(true)80 .payload("{\"first_name\":\"${first_name}\",\"company\":\"${company}\",\"mail\":\"${email}\"}"));81 runner.receive(receiveMessageBuilder -> receiveMessageBuilder82 .endpoint(ftpTestServer)83 .message(FtpMessage.command(FTPCmd.STOR).arguments("tmp_contacts.csv")));84 runner.send(sendMessageBuilder -> sendMessageBuilder85 .endpoint(ftpTestServer)86 .message(FtpMessage.success()));87 runner.receive(receiveMessageBuilder -> receiveMessageBuilder88 .endpoint(ftpTestServer)89 .message(FtpMessage.command(FTPCmd.RNFR).arguments("public/tmp_contacts.csv")));90 runner.send(sendMessageBuilder -> sendMessageBuilder91 .endpoint(ftpTestServer)92 .message(FtpMessage.success()));93 runner.http(builder -> builder.client(webHookClient)94 .receive()95 .response(HttpStatus.NO_CONTENT));96 runner.run(new VerifyFtpUploadTestAction());97 }98 @Configuration99 public static class EndpointConfig {100 @Bean101 public HttpClient webHookClient() {102 return CitrusEndpoints.http().client()103 .requestUrl(String.format("http://localhost:%s/webhook/contact", integrationContainer.getServerPort()))104 .build();105 }106 @Bean107 public DataConnectionConfiguration dataConnectionConfiguration() {108 DataConnectionConfigurationFactory dataConnectionFactory = new DataConnectionConfigurationFactory();109 dataConnectionFactory.setPassiveExternalAddress(integrationContainer.getInternalHostIp());110 dataConnectionFactory.setPassivePorts(String.valueOf(PASSIVE_PORT));111 return dataConnectionFactory.createDataConnectionConfiguration();112 }113 }114 /*115 * Helper test action ready the uploaded ftp file from user home directory and verifies116 * the content with Json message validator.117 */118 private static class VerifyFtpUploadTestAction extends AbstractTestAction {119 private static final String UPLOAD_FILENAME = "contacts.csv";120 @Override121 public void doExecute(TestContext testContext) {122 Path publicUserDir = getFtpUserHome().resolve("public");123 Assert.assertTrue( "Missing ftp user home directory", publicUserDir.toFile().exists());124 File ftpUploadFile = publicUserDir.resolve(UPLOAD_FILENAME).toFile();125 Assert.assertTrue(String.format("Missing ftp upload file '%s'", UPLOAD_FILENAME), ftpUploadFile.exists());126 try {127 JsonTextMessageValidator validator = new JsonTextMessageValidator();128 validator.validateMessage(new DefaultMessage(FileUtils.readToString(ftpUploadFile)),129 new DefaultMessage("{\"message\" : \"${first_name},${company},${email}\"}"),130 testContext,131 new JsonMessageValidationContext());132 } catch (IOException e) {133 throw new CitrusRuntimeException(String.format("Failed to verify ftp upload file '%s'", UPLOAD_FILENAME), e);134 }135 }136 }137}...

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1package com.consol.citrus.dsl.builder;2import java.util.HashMap;3import java.util.Map;4import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.message.builder.DefaultMessageBuilder;7import com.consol.citrus.validation.json.JsonMessageValidationContext;8import com.consol.citrus.validation.json.JsonPathMessageValidationContext;9public class ReceiveMessageBuilder {10 public ReceiveMessageBuilder payload(String payload) {11 this.payload = payload;12 return this;13 }14 public ReceiveMessageBuilder payload(Map<String, Object> payload) {15 this.payload = payload;16 return this;17 }18 public ReceiveMessageBuilder payload(Object payload) {19 this.payload = payload;20 return this;21 }22 public ReceiveMessageBuilder message(MessageType messageType) {23 this.messageType = messageType;24 return this;25 }26 public ReceiveMessageBuilder message(DefaultMessageBuilder messageBuilder) {27 this.messageBuilder = messageBuilder;28 return this;29 }30 public ReceiveMessageBuilder message(String message) {31 this.message = message;32 return this;33 }34 public ReceiveMessageBuilder message(Map<String, Object> message) {35 this.message = message;36 return this;37 }38 public ReceiveMessageBuilder message(Object message) {39 this.message = message;40 return this;41 }42 public ReceiveMessageBuilder header(String name, Object value) {43 this.headers.put(name, value);44 return this;45 }46 public ReceiveMessageBuilder headers(Map<String, Object> headers) {47 this.headers.putAll(headers);48 return this;49 }50 public ReceiveMessageBuilder validate(String path, String value) {51 if (validationContext == null) {52 validationContext = new JsonMessageValidationContext();53 }54 if (validationContext instanceof JsonPathMessageValidationContext) {55 ((JsonPathMessageValidationContext) validationContext).addJsonPathData(path, value);56 } else {57 throw new CitrusRuntimeException("Unable to add JSON path data to message validation context - not a JSON path validation context");58 }59 return this;60 }61 public ReceiveMessageBuilder validate(String path, String value, String controlPath) {62 if (validationContext == null) {63 validationContext = new JsonMessageValidationContext();64 }65 if (validationContext instanceof JsonPathMessageValidationContext) {66 ((JsonPathMessageValidationContext

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;2import com.consol.citrus.dsl.builder.ReceiveMessageBuilder.ReceiveMessageBuilderSupport;3import com.consol.citrus.message.MessageType;4import com.consol.citrus.validation.context.JsonMessageValidationContext;5import com.consol.citrus.validation.json.JsonMessageValidationContext;6import org.springframework.context.annotation.Bean;7import org.springframework.context.annotation.Configuration;8import org.springframework.context.annotation.Import;9@Import({com.consol.citrus.dsl.endpoint.CitrusEndpoints.class})10public class 3 {11 public ReceiveMessageBuilderSupport receiveMessageBuilderSupport() {12 return new ReceiveMessageBuilderSupport() {13 public ReceiveMessageBuilder messageType(MessageType messageType) {14 return this;15 }16 public ReceiveMessageBuilder messageValidator(String messageValidator) {17 return this;18 }19 public ReceiveMessageBuilder messageValidator(String messageValidator, String messageValidatorName) {20 return this;21 }22 public ReceiveMessageBuilder messageValidator(String messageValidator, String messageValidatorName, boolean autoWire) {23 return this;24 }25 public ReceiveMessageBuilder messageValidator(String messageValidator, boolean autoWire) {26 return this;27 }28 public ReceiveMessageBuilder messageValidator(com.consol.citrus.validation.MessageValidator<? extends com.consol.citrus.message.Message> messageValidator) {29 return this;30 }31 public ReceiveMessageBuilder interceptors(String... interceptors) {32 return this;33 }34 public ReceiveMessageBuilder endpoint(String endpoint) {35 return this;36 }37 public ReceiveMessageBuilder endpoint(com.consol.citrus.endpoint.Endpoint endpoint) {38 return this;39 }40 public ReceiveMessageBuilder message(com.consol.citrus.message.Message message) {41 return this;42 }43 public ReceiveMessageBuilder message(com.consol.citrus.message.Message message, boolean autoWireMessage) {44 return this;45 }46 public ReceiveMessageBuilder message(com.consol.citrus.dsl.builder.Builder<com.consol.citrus.message.Message> messageBuilder) {47 return this;48 }49 public ReceiveMessageBuilder payload(String payload) {50 return this;51 }

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;3import com.consol.citrus.dsl.builder.ReceiveMessageBuilderSupport;4import com.consol.citrus.dsl.builder.ReceiveTimeoutBuilder;5import com.consol.citrus.dsl.builder.ReceiveTimeoutBuilderSupport;6import com.consol.citrus.dsl.builder.ValidationCallback;7import com.consol.citrus.dsl.builder.ValidationContextBuilder;8import com.consol.citrus.message.MessageType;9import com.consol.citrus.validation.builder.DefaultMessageBuilder;10import com.consol.citrus.validation.builder.StaticMessageContentBuilder;11import com.consol.citrus.validation.json.JsonMessageValidationContext;12import com.consol.citrus.validation.xml.XmlMessageValidationContext;13import java.util.Map;14import org.springframework.util.StringUtils;15public class ReceiveMessageBuilderSupport implements ValidationContextBuilder<ReceiveMessageBuilderSupport> {16 protected final ReceiveMessageBuilder receiveMessageBuilder;17 public ReceiveMessageBuilderSupport(ReceiveMessageBuilder receiveMessageBuilder) {18 this.receiveMessageBuilder = receiveMessageBuilder;19 }20 public ReceiveMessageBuilderSupport message(Object messagePayload) {21 this.receiveMessageBuilder.message(messagePayload);22 return this;23 }24 public ReceiveMessageBuilderSupport message(DefaultMessageBuilder messageBuilder) {25 this.receiveMessageBuilder.message(messageBuilder);26 return this;27 }28 public ReceiveMessageBuilderSupport message(StaticMessageContentBuilder messageBuilder) {29 this.receiveMessageBuilder.message(messageBuilder);30 return this;31 }32 public ReceiveMessageBuilderSupport messageType(MessageType messageType) {33 this.receiveMessageBuilder.messageType(messageType);34 return this;35 }36 public ReceiveMessageBuilderSupport extractFromHeader(String headerName, String variableName) {37 this.receiveMessageBuilder.extractFromHeader(headerName, variableName);38 return this;39 }40 public ReceiveMessageBuilderSupport extractFromPayload(String xpathExpression, String variableName) {41 this.receiveMessageBuilder.extractFromPayload(xpathExpression, variableName);42 return this;43 }44 public ReceiveMessageBuilderSupport extractFromPayload(String xpathExpression, String variableName, Map<String, Object> namespaces) {45 this.receiveMessageBuilder.extractFromPayload(xpathExpression, variableName, namespaces);46 return this;47 }48 public ReceiveMessageBuilderSupport extractFromPayload(String jsonPathExpression, String variableName, boolean isJsonPath) {49 this.receiveMessageBuilder.extractFromPayload(jsonPathExpression, variableName, isJson

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1public class ReceiveMessageBuilder {2 public static void main(String[] args) {3 Citrus citrus = Citrus.newInstance();4 citrus.run(builder -> builder5 .receive()6 .messageType(MessageType.JSON)7 .messageValidationContext(new JsonMessageValidationContext())8 .payload("{\"name\":\"John Doe\",\"age\":33,\"address\":{\"street\":\"Main Street\",\"city\":\"Anytown\"}}")9 .extractFromHeader("citrus_jms_messageId", "correlation_id")10 .extractFromPayload("$.name", "name")11 .extractFromPayload("$.age", "age")12 .extractFromPayload("$.address.street", "street")13 .extractFromPayload("$.address.city", "city")14 );15 }16}17public class SendMessageBuilder {18 public static void main(String[] args) {19 Citrus citrus = Citrus.newInstance();20 citrus.run(builder -> builder21 .send()22 .messageType(MessageType.JSON)23 .messageValidationContext(new JsonMessageValidationContext())24 .payload("{\"name\":\"John Doe\",\"age\":33,\"address\":{\"street\":\"Main Street\",\"city\":\"Anytown\"}}")25 .header("citrus_jms_messageId", "1234567890")26 );27 }28}29public class SendSoapMessageBuilder {30 public static void main(String[] args) {31 Citrus citrus = Citrus.newInstance();32 citrus.run(builder -> builder33 .send()34 .messageType(MessageType.JSON)35 .messageValidationContext(new JsonMessageValidationContext())36 .soap()37 );38 }39}40public class ReceiveSoapMessageBuilder {41 public static void main(String

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1package com.consol.citrus.dsl.builder;2import java.util.Map;3import org.springframework.util.StringUtils;4import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;5import com.consol.citrus.dsl.builder.ReceiveMessageBuilderSupport;6import com.consol.citrus.message.MessageType;7import com.consol.citrus.validation.context.ValidationContext;8import com.consol.citrus.validation.json.JsonMessageValidationContext;9import com.consol.citrus.validation.json.JsonSchemaRepository;10import com.consol.citrus.validation.json.JsonTextMessageValidator;11import com.consol.citrus.validation.xml.XmlMessageValidationContext;12import com.consol.citrus.validation.xml.XmlSchemaRepository;13import com.consol.citrus.validation.xml.XsdSchemaRepository;14import com.consol.citrus.validation.xml.XmlTextMessageValidator;15public class JsonMessageValidationContext extends ReceiveMessageBuilderSupport<ReceiveMessageBuilder> {16 public JsonMessageValidationContext(ReceiveMessageBuilder builder) {17 super(builder);18 }19 public JsonMessageValidationContext message(MessageType messageType) {20 super.message(messageType);21 return this;22 }23 public JsonMessageValidationContext messageType(MessageType messageType) {24 super.messageType(messageType);25 return this;26 }27 public JsonMessageValidationContext schemaValidation(boolean schemaValidation) {28 super.schemaValidation(schemaValidation);29 return this;30 }31 public JsonMessageValidationContext schemaRepository(XmlSchemaRepository schemaRepository) {32 super.schemaRepository(schemaRepository);33 return this;34 }35 public JsonMessageValidationContext xsdSchemaRepository(XsdSchemaRepository xsdSchemaRepository) {36 super.xsdSchemaRepository(xsdSchemaRepository);37 return this;38 }39 public JsonMessageValidationContext jsonSchemaRepository(JsonSchemaRepository jsonSchemaRepository) {40 super.jsonSchemaRepository(jsonSchemaRepository);41 return this;42 }43 public JsonMessageValidationContext ignoreWhitespace(boolean ignoreWhitespace) {44 super.ignoreWhitespace(ignoreWhitespace);45 return this;46 }47 public JsonMessageValidationContext ignoreComments(boolean ignoreComments) {48 super.ignoreComments(ignoreComments);49 return this;50 }51 public JsonMessageValidationContext ignoreNamespaces(boolean ignore

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.dsl.runner.TestRunner;3import com.consol.citrus.message.MessageType;4import com.consol.citrus.validation.json.JsonMessageValidationContext;5import com.consol.citrus.validation.xml.XmlMessageValidationContext;6import org.testng.annotations.Test;7public class JsonMessageValidationContextTest {8 public void testJsonMessageValidationContext() {9 TestRunner runner = new TestRunner();10 runner.receive(builder -> builder.endpoint("testEndpoint")11 .messageType(MessageType.JSON)12 .messageValidationContext(new JsonMessageValidationContext())13 .payload("{ \"name\" : \"Citrus\" }"));14 }15}16import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;17import org.testng.annotations.Test;18public class JsonMessageValidationContextTest extends TestNGCitrusTestRunner {19 public void testJsonMessageValidationContext() {20 variable("name", "Citrus");21 receive(builder -> builder.endpoint("testEndpoint")22 .messageType(MessageType.JSON)23 .messageValidationContext(new JsonMessageValidationContext())24 .payload("{ \"name\" : \"${name}\" }"));25 }26}27public class JsonMessageValidationContext extends AbstractMessageValidationContext {28 private boolean ignoreUnknownElements;29 private boolean ignoreNullValues;30 private boolean ignoreEmptyValues;31 private boolean ignoreWhitespace;32 private boolean ignoreDifferences;33 private boolean treatNullValuesAsEmptyStrings;34 private boolean treatEmptyValuesAsNull;35 private boolean ignoreArrayOrder;36 private boolean ignoreExtraElements;

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1public void jsonMessageValidationContext() {2 run(new TestAction() {3 public void doExecute(TestContext context) {4 ReceiveMessageActionBuilder receiveBuilder = receive(builder -> builder.endpoint("foo")5 .messageType(MessageType.PLAINTEXT)6 .messageValidationContext(JsonMessageValidationContext.Builder.json()7 .build()));8 }9 });10}11public void jsonMessageValidationContext() {12 run(new TestAction() {13 public void doExecute(TestContext context) {14 ReceiveMessageActionBuilder receiveBuilder = receive(builder -> builder.endpoint("foo")15 .messageType(MessageType.PLAINTEXT)16 .messageValidationContext(JsonMessageValidationContext.Builder.json()17 .ignoreExtraElements(true)18 .ignoreMissingElements(true)19 .build()));20 }21 });22}23public void jsonMessageValidationContext() {24 run(new TestAction() {25 public void doExecute(TestContext context) {26 ReceiveMessageActionBuilder receiveBuilder = receive(builder -> builder.endpoint("foo")27 .messageType(MessageType.PLAINTEXT)28 .messageValidationContext(JsonMessageValidationContext.Builder.json()29 .ignoreExtraElements(true)30 .ignoreMissingElements(true)31 .ignoreArrayOrder(true)32 .build()));33 }34 });35}36public void jsonMessageValidationContext() {37 run(new TestAction() {38 public void doExecute(TestContext context) {39 ReceiveMessageActionBuilder receiveBuilder = receive(builder -> builder.endpoint("foo")40 .messageType(MessageType.PLAINTEXT)41 .messageValidationContext(JsonMessageValidationContext.Builder.json()42 .ignoreExtraElements(true)43 .ignoreMissingElements(true)44 .ignoreArrayOrder(true)45 .ignoreExtraAttributes(true)46 .build()));47 }48 });49}

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1public class 3 {2 public void 3(ITestContext context) {3 this.context = context;4 variable("json", "com.consol.citrus.dsl.builder.ReceiveMessageBuilder");5 variable("json", "com.consol.citrus.dsl.builder.ReceiveMessageBuilder", "json", "com.consol.citrus.dsl.builder.ReceiveMessageBuilder");6 variable("json", "com.consol.citrus.dsl.builder.ReceiveMessageBuilder", "json", "com.consol.citrus.dsl.builder.ReceiveMessageBuilder", "json", "com.consol.citrus.dsl.builder.ReceiveMe

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1public void testJsonMessageValidationContext() {2 http()3 .client(httpClient)4 .send()5 .post()6 .fork(true)7 .payload("{\"name\":\"John\",\"age\":30,\"cars\":[\"Ford\",\"BMW\",\"Fiat\"]}");8 http()9 .client(httpClient)10 .receive()11 .response(HttpStatus.OK)12 .messageType(MessageType.PLAINTEXT)13 .validate("$.name", "John")14 .validate("$.age", "30")15 .validate("$.cars[0]", "Ford")16 .validate("$.cars[1]", "BMW")17 .validate("$.cars[2]", "Fiat");18}19public void testJsonPathMessageValidationContext() {20 http()21 .client(httpClient)22 .send()23 .post()24 .fork(true)25 .payload("{\"name\":\"John\",\"age\":30,\"cars\":[\"Ford\",\"BMW\",\"Fiat\"]}");26 http()27 .client(httpClient)28 .receive()29 .response(HttpStatus.OK)30 .messageType(MessageType.PLAINTEXT)31 .validate("$.name", "John")32 .validate("$.age", "30")33 .validate("$.cars[0]", "Ford")34 .validate("$.cars[1]", "BMW")35 .validate("$.cars[2]", "Fiat");36}37public void testJsonPathMessageValidationContext() {38 http()39 .client(httpClient)40 .send()41 .post()42 .fork(true)43 .payload("{\"name\":\"John\",\"age\":30,\"cars\":[\"Ford\",\"BMW\",\"Fiat\"]}");44 http()45 .client(httpClient)46 .receive()47 .response(HttpStatus.OK)48 .messageType(MessageType.PLAINTEXT)49 .validate("$.name", "John")50 .validate("$.age", "30")51 .validate("$.cars[0]", "Ford")52 .validate("$.cars[1]", "BMW")

Full Screen

Full Screen

JsonMessageValidationContext

Using AI Code Generation

copy

Full Screen

1public void test() {2 runner.receive(builder -> builder.endpoint(httpEndpoint)3 .messageType(MessageType.JSON)4 .payload("{\"id\": \"1234567890\", \"name\": \"John Doe\"}")5 .messageValidationContext(new JsonMessageValidationContext() {6 public void validateMessage(Message receivedMessage, Message controlMessage) {7 System.out.println("I am validating the json message");8 }9 }));10}11public void test() {12 runner.receive(builder -> builder.endpoint(httpEndpoint)13 .messageType(MessageType.JSON)14 .payload("{\"id\": \"1234567890\", \"name\": \"John Doe\"}")15 .messageValidationContext(new JsonMessageValidationContext() {16 public void validateMessage(Message receivedMessage, Message controlMessage) {17 System.out.println("I am validating the json message");18 }19 }));20}21public void test() {22 runner.receive(builder -> builder.endpoint(httpEndpoint)23 .messageType(MessageType.JSON)24 .payload("{\"id\": \"1234567890\", \"name\": \"John Doe\"}")25 .messageValidationContext(new JsonMessageValidationContext() {26 public void validateMessage(Message receivedMessage, Message controlMessage) {27 System.out.println("I am validating the json message");28 }29 }));30}31public void test() {32 runner.receive(builder -> builder.endpoint(httpEndpoint)33 .messageType(MessageType.JSON)34 .payload("{\"id\": \"1234567890\", \"name\": \"John Doe\"}")35 .messageValidationContext(new JsonMessageValidationContext() {36 public void validateMessage(Message receivedMessage, Message controlMessage) {

Full Screen

Full Screen

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:

YouTube

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

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful