How to use BinaryMessageValidator class of com.consol.citrus.validation.text package

Best Citrus code snippet using com.consol.citrus.validation.text.BinaryMessageValidator

Source:MessageValidatorRegistryTest.java Github

copy

Full Screen

1/*2 * Copyright 2006-2014 the original author or authors.3 *4 * Licensed under the Apache License, Version 2.0 (the "License");5 * you may not use this file except in compliance with the License.6 * You may obtain a copy of the License at7 *8 * http://www.apache.org/licenses/LICENSE-2.09 *10 * Unless required by applicable law or agreed to in writing, software11 * distributed under the License is distributed on an "AS IS" BASIS,12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.13 * See the License for the specific language governing permissions and14 * limitations under the License.15 */16package com.consol.citrus.validation;17import java.util.HashMap;18import java.util.List;19import java.util.Map;20import java.util.Optional;21import com.consol.citrus.exceptions.CitrusRuntimeException;22import com.consol.citrus.message.DefaultMessage;23import com.consol.citrus.message.Message;24import com.consol.citrus.message.MessageType;25import com.consol.citrus.util.MessageUtils;26import com.consol.citrus.validation.context.SchemaValidationContext;27import com.consol.citrus.validation.context.ValidationContext;28import org.mockito.Mock;29import org.mockito.MockitoAnnotations;30import org.testng.Assert;31import org.testng.annotations.BeforeClass;32import org.testng.annotations.Test;33import javax.xml.validation.Schema;34import static org.mockito.ArgumentMatchers.any;35import static org.mockito.Mockito.when;36/**37 * @author Christoph Deppisch38 * @since 2.039 */40public class MessageValidatorRegistryTest {41 @Mock42 private MessageValidator<?> plainTextMessageValidator;43 @Mock44 private MessageValidator<?> xmlMessageValidator;45 @Mock46 private MessageValidator<?> xhtmlMessageValidator;47 @Mock48 private MessageValidator<?> jsonTextMessageValidator;49 @Mock50 private MessageValidator<?> jsonPathMessageValidator;51 @Mock52 private MessageValidator<?> groovyScriptMessageValidator;53 @Mock54 private MessageValidator<?> groovyJsonMessageValidator;55 @Mock56 private MessageValidator<?> groovyXmlMessageValidator;57 @Mock58 private MessageValidator<?> xPathMessageValidator;59 @Mock60 private MessageValidator<?> xhtmlXpathMessageValidator;61 @Mock62 private MessageValidator<?> binaryMessageValidator;63 @Mock64 private MessageValidator<?> binaryBase64MessageValidator;65 @Mock66 private MessageValidator<?> gzipBinaryBase64MessageValidator;67 @Mock68 private SchemaValidator<?> jsonSchemaValidator;69 @Mock70 private SchemaValidator<?> xmlSchemaValidator;71 private MessageValidatorRegistry messageValidatorRegistry = new MessageValidatorRegistry();72 @BeforeClass73 public void setupMocks() {74 MockitoAnnotations.openMocks(this);75 when(plainTextMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.PLAINTEXT.name()));76 when(xmlMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.XML.name()) && MessageUtils.hasXmlPayload(invocation.getArgument(1)));77 when(xhtmlMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.XHTML.name()) && MessageUtils.hasXmlPayload(invocation.getArgument(1)));78 when(jsonTextMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.JSON.name()) && MessageUtils.hasJsonPayload(invocation.getArgument(1)));79 when(jsonPathMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.JSON.name()) && MessageUtils.hasJsonPayload(invocation.getArgument(1)));80 when(groovyScriptMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.PLAINTEXT.name()));81 when(groovyJsonMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.JSON.name()) && MessageUtils.hasJsonPayload(invocation.getArgument(1)));82 when(groovyXmlMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.XML.name()) && MessageUtils.hasXmlPayload(invocation.getArgument(1)));83 when(xPathMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.XML.name()) && MessageUtils.hasXmlPayload(invocation.getArgument(1)));84 when(xhtmlXpathMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.XHTML.name()) && MessageUtils.hasXmlPayload(invocation.getArgument(1)));85 when(binaryMessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.BINARY.name()));86 when(binaryBase64MessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.BINARY_BASE64.name()));87 when(gzipBinaryBase64MessageValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.GZIP_BASE64.name()));88 // Schema validators89 when(jsonSchemaValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.JSON.name()));90 when(xmlSchemaValidator.supportsMessageType(any(String.class), any(Message.class))).thenAnswer(invocation -> invocation.getArgument(0).equals(MessageType.XML.name()));91 messageValidatorRegistry.addMessageValidator("xmlMessageValidator", xmlMessageValidator);92 messageValidatorRegistry.addMessageValidator("xPathMessageValidator", xPathMessageValidator);93 messageValidatorRegistry.addMessageValidator("groovyXmlMessageValidator", groovyXmlMessageValidator);94 messageValidatorRegistry.addMessageValidator("jsonTextMessageValidator", jsonTextMessageValidator);95 messageValidatorRegistry.addMessageValidator("jsonPathMessageValidator", jsonPathMessageValidator);96 messageValidatorRegistry.addMessageValidator("plainTextMessageValidator", plainTextMessageValidator);97 messageValidatorRegistry.addMessageValidator("headerMessageValidator", new DefaultMessageHeaderValidator());98 messageValidatorRegistry.addMessageValidator("binaryMessageValidator", binaryMessageValidator);99 messageValidatorRegistry.addMessageValidator("binaryBase64MessageValidator", binaryBase64MessageValidator);100 messageValidatorRegistry.addMessageValidator("gzipBinaryBase64MessageValidator", gzipBinaryBase64MessageValidator);101 messageValidatorRegistry.addMessageValidator("groovyJsonMessageValidator", groovyJsonMessageValidator);102 messageValidatorRegistry.addMessageValidator("groovyScriptMessageValidator", groovyScriptMessageValidator);103 messageValidatorRegistry.addMessageValidator("xhtmlMessageValidator", xhtmlMessageValidator);104 messageValidatorRegistry.addMessageValidator("xhtmlXpathMessageValidator", xhtmlXpathMessageValidator);105 messageValidatorRegistry.addSchemaValidator("jsonSchemaValidator", jsonSchemaValidator);106 messageValidatorRegistry.addSchemaValidator("xmlSchemaValidator", xmlSchemaValidator);107 }108 @Test109 public void testFindMessageValidators() throws Exception {110 MessageValidatorRegistry messageValidatorRegistry = new MessageValidatorRegistry();111 Map<String, MessageValidator<? extends ValidationContext>> messageValidators = new HashMap<>();112 messageValidators.put("plainTextMessageValidator", plainTextMessageValidator);113 messageValidatorRegistry.setMessageValidators(messageValidators);114 List<MessageValidator<? extends ValidationContext>> matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage(""));115 Assert.assertNotNull(matchingValidators);116 Assert.assertEquals(matchingValidators.size(), 1L);117 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);118 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage("Hello"));119 Assert.assertNotNull(matchingValidators);120 Assert.assertEquals(matchingValidators.size(), 1L);121 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);122 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage(""));123 Assert.assertNotNull(matchingValidators);124 Assert.assertEquals(matchingValidators.size(), 1L);125 Assert.assertEquals(matchingValidators.get(0).getClass(), DefaultEmptyMessageValidator.class);126 messageValidatorRegistry.addMessageValidator("xmlMessageValidator", xmlMessageValidator);127 messageValidatorRegistry.addMessageValidator("groovyScriptMessageValidator", groovyScriptMessageValidator);128 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage(""));129 Assert.assertNotNull(matchingValidators);130 Assert.assertEquals(matchingValidators.size(), 2L);131 Assert.assertEquals(matchingValidators.get(0), groovyScriptMessageValidator);132 Assert.assertEquals(matchingValidators.get(1), plainTextMessageValidator);133 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.XML.name(), new DefaultMessage(""));134 Assert.assertNotNull(matchingValidators);135 Assert.assertEquals(matchingValidators.size(), 1L);136 Assert.assertEquals(matchingValidators.get(0), xmlMessageValidator);137 }138 @Test139 public void testMessageValidatorRegistryXmlConfig() throws Exception {140 //non XML message type141 List<MessageValidator<? extends ValidationContext>> matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage(""));142 Assert.assertNotNull(matchingValidators);143 Assert.assertEquals(matchingValidators.size(), 3L);144 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);145 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);146 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);147 //XML message type and empty payload148 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.XML.name(), new DefaultMessage(""));149 Assert.assertNotNull(matchingValidators);150 Assert.assertEquals(matchingValidators.size(), 4L);151 Assert.assertEquals(matchingValidators.get(0), xmlMessageValidator);152 Assert.assertEquals(matchingValidators.get(1), xPathMessageValidator);153 Assert.assertEquals(matchingValidators.get(2), groovyXmlMessageValidator);154 Assert.assertEquals(matchingValidators.get(3).getClass(), DefaultMessageHeaderValidator.class);155 //XML message type and non empty payload156 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.XML.name(), new DefaultMessage("<id>12345</id>"));157 Assert.assertNotNull(matchingValidators);158 Assert.assertEquals(matchingValidators.size(), 4L);159 Assert.assertEquals(matchingValidators.get(0), xmlMessageValidator);160 Assert.assertEquals(matchingValidators.get(1), xPathMessageValidator);161 Assert.assertEquals(matchingValidators.get(2), groovyXmlMessageValidator);162 Assert.assertEquals(matchingValidators.get(3).getClass(), DefaultMessageHeaderValidator.class);163 }164 @Test165 public void testMessageValidatorRegistryJsonConfig() throws Exception {166 //JSON message type and empty payload167 List<MessageValidator<? extends ValidationContext>> matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage(""));168 Assert.assertNotNull(matchingValidators);169 Assert.assertEquals(matchingValidators.size(), 4L);170 Assert.assertEquals(matchingValidators.get(0), jsonTextMessageValidator);171 Assert.assertEquals(matchingValidators.get(1), jsonPathMessageValidator);172 Assert.assertEquals(matchingValidators.get(2).getClass(), DefaultMessageHeaderValidator.class);173 Assert.assertEquals(matchingValidators.get(3), groovyJsonMessageValidator);174 //JSON message type and non empty payload175 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage("{ \"id\": 12345 }"));176 Assert.assertNotNull(matchingValidators);177 Assert.assertEquals(matchingValidators.size(), 4L);178 Assert.assertEquals(matchingValidators.get(0), jsonTextMessageValidator);179 Assert.assertEquals(matchingValidators.get(1), jsonPathMessageValidator);180 Assert.assertEquals(matchingValidators.get(2).getClass(), DefaultMessageHeaderValidator.class);181 Assert.assertEquals(matchingValidators.get(3), groovyJsonMessageValidator);182 }183 @Test184 public void testMessageValidatorRegistryPlaintextConfig() throws Exception {185 //Plaintext message type and empty payload186 List<MessageValidator<? extends ValidationContext>> matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage(""));187 Assert.assertNotNull(matchingValidators);188 Assert.assertEquals(matchingValidators.size(), 3L);189 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);190 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);191 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);192 //Plaintext message type and non empty payload193 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage("id=12345"));194 Assert.assertNotNull(matchingValidators);195 Assert.assertEquals(matchingValidators.size(), 3L);196 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);197 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);198 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);199 }200 @Test201 public void testMessageValidatorRegistryFallback() throws Exception {202 List<MessageValidator<? extends ValidationContext>> matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.XML.name(), new DefaultMessage("{ \"id\": 12345 }"));203 Assert.assertNotNull(matchingValidators);204 Assert.assertEquals(matchingValidators.size(), 4L);205 Assert.assertEquals(matchingValidators.get(0), jsonTextMessageValidator);206 Assert.assertEquals(matchingValidators.get(1), jsonPathMessageValidator);207 Assert.assertEquals(matchingValidators.get(2).getClass(), DefaultMessageHeaderValidator.class);208 Assert.assertEquals(matchingValidators.get(3), groovyJsonMessageValidator);209 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage("<id>12345</id>"));210 Assert.assertNotNull(matchingValidators);211 Assert.assertEquals(matchingValidators.size(), 4L);212 Assert.assertEquals(matchingValidators.get(0), xmlMessageValidator);213 Assert.assertEquals(matchingValidators.get(1), xPathMessageValidator);214 Assert.assertEquals(matchingValidators.get(2), groovyXmlMessageValidator);215 Assert.assertEquals(matchingValidators.get(3).getClass(), DefaultMessageHeaderValidator.class);216 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage("<id>12345</id>"));217 Assert.assertNotNull(matchingValidators);218 Assert.assertEquals(matchingValidators.size(), 3L);219 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);220 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);221 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);222 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage("{ \"id\": 12345 }"));223 Assert.assertNotNull(matchingValidators);224 Assert.assertEquals(matchingValidators.size(), 3L);225 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);226 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);227 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);228 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.XML.name(), new DefaultMessage("id=12345"));229 Assert.assertNotNull(matchingValidators);230 Assert.assertEquals(matchingValidators.size(), 3L);231 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);232 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);233 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);234 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage("id=12345"));235 Assert.assertNotNull(matchingValidators);236 Assert.assertEquals(matchingValidators.size(), 3L);237 Assert.assertEquals(matchingValidators.get(0), plainTextMessageValidator);238 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);239 Assert.assertEquals(matchingValidators.get(2), groovyScriptMessageValidator);240 }241 @Test242 public void shouldAddDefaultEmptyMessagePayloadValidator() {243 MessageValidatorRegistry messageValidatorRegistry = new MessageValidatorRegistry();244 List<MessageValidator<? extends ValidationContext>> matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage(""));245 Assert.assertNotNull(matchingValidators);246 Assert.assertEquals(matchingValidators.size(), 1L);247 Assert.assertEquals(matchingValidators.get(0).getClass(), DefaultEmptyMessageValidator.class);248 messageValidatorRegistry.addMessageValidator("jsonTextMessageValidator", jsonTextMessageValidator);249 messageValidatorRegistry.addMessageValidator("headerMessageValidator", new DefaultMessageHeaderValidator());250 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.PLAINTEXT.name(), new DefaultMessage(""));251 Assert.assertNotNull(matchingValidators);252 Assert.assertEquals(matchingValidators.size(), 2L);253 Assert.assertEquals(matchingValidators.get(0).getClass(), DefaultMessageHeaderValidator.class);254 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultEmptyMessageValidator.class);255 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage("{}"));256 Assert.assertNotNull(matchingValidators);257 Assert.assertEquals(matchingValidators.size(), 2L);258 Assert.assertEquals(matchingValidators.get(0), jsonTextMessageValidator);259 Assert.assertEquals(matchingValidators.get(1).getClass(), DefaultMessageHeaderValidator.class);260 try {261 messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage("Hello"));262 Assert.fail("Missing exception due to no proper message validator found");263 } catch (CitrusRuntimeException e) {264 Assert.assertEquals(e.getMessage(), "Failed to find proper message validator for message");265 }266 messageValidatorRegistry.addMessageValidator("plainTextMessageValidator", plainTextMessageValidator);267 matchingValidators = messageValidatorRegistry.findMessageValidators(MessageType.JSON.name(), new DefaultMessage("Hello"));268 Assert.assertNotNull(matchingValidators);269 Assert.assertEquals(matchingValidators.size(), 2L);270 Assert.assertEquals(matchingValidators.get(0).getClass(), DefaultMessageHeaderValidator.class);271 Assert.assertEquals(matchingValidators.get(1), plainTextMessageValidator);272 }273 @Test274 public void testSchemaValidators() throws Exception {275 MessageValidatorRegistry messageValidatorRegistry = new MessageValidatorRegistry();276 Map<String, SchemaValidator<? extends SchemaValidationContext>> schemaValidators = new HashMap<>();277 schemaValidators.put("jsonSchema", jsonSchemaValidator);278 schemaValidators.put("xmlSchema", xmlSchemaValidator);279 messageValidatorRegistry.setSchemaValidators(schemaValidators);280 List<SchemaValidator<? extends SchemaValidationContext>> matchingValidators = messageValidatorRegistry.findSchemaValidators(MessageType.JSON.name(), new DefaultMessage(""));281 Assert.assertNotNull(matchingValidators);282 Assert.assertEquals(matchingValidators.size(), 1L);283 Assert.assertEquals(matchingValidators.get(0), jsonSchemaValidator);284 Optional<SchemaValidator<? extends SchemaValidationContext>> jsonSchema = messageValidatorRegistry.findSchemaValidator("jsonSchema");285 Assert.assertTrue(jsonSchema.isPresent());286 Assert.assertEquals(jsonSchema.get(), jsonSchemaValidator);287 }288}...

Full Screen

Full Screen

Source:MessageValidatorConfig.java Github

copy

Full Screen

...35 private final XpathMessageValidator defaultXpathMessageValidator = new XpathMessageValidator();36 private final JsonTextMessageValidator defaultJsonMessageValidator = new JsonTextMessageValidator();37 private final JsonPathMessageValidator defaultJsonPathMessageValidator = new JsonPathMessageValidator();38 private final PlainTextMessageValidator defaultPlaintextMessageValidator = new PlainTextMessageValidator();39 private final BinaryMessageValidator defaultBinaryMessageValidator = new BinaryMessageValidator();40 private final BinaryBase64MessageValidator defaultBinaryBase64MessageValidator = new BinaryBase64MessageValidator();41 private final GzipBinaryBase64MessageValidator defaultGzipBinaryBase64MessageValidator = new GzipBinaryBase64MessageValidator();42 private final XhtmlMessageValidator defaultXhtmlMessageValidator = new XhtmlMessageValidator();43 private final XhtmlXpathMessageValidator defaultXhtmlXpathMessageValidator = new XhtmlXpathMessageValidator();44 private final GroovyXmlMessageValidator defaultGroovyXmlMessageValidator = new GroovyXmlMessageValidator();45 private final GroovyJsonMessageValidator defaultGroovyJsonMessageValidator = new GroovyJsonMessageValidator();46 private final GroovyScriptMessageValidator defaultGroovyTextMessageValidator = new GroovyScriptMessageValidator();47 @Bean(name = "defaultXmlMessageValidator")48 public DomXmlMessageValidator getDefaultXmlMessageValidator() {49 return defaultXmlMessageValidator;50 }51 @Bean(name = "defaultMessageHeaderValidator")52 public DefaultMessageHeaderValidator getDefaultMessageHeaderValidator() {53 return defaultMessageHeaderValidator;54 }55 @Bean(name = "defaultXpathMessageValidator")56 public XpathMessageValidator getDefaultXpathMessageValidator() {57 return defaultXpathMessageValidator;58 }59 @Bean(name = "defaultJsonMessageValidator")60 public JsonTextMessageValidator getDefaultJsonTextMessageValidator() {61 return defaultJsonMessageValidator;62 }63 @Bean(name = "defaultJsonPathMessageValidator")64 public JsonPathMessageValidator getDefaultJsonPathMessageValidator() {65 return defaultJsonPathMessageValidator;66 }67 @Bean(name = "defaultPlaintextMessageValidator")68 public PlainTextMessageValidator getDefaultPlainTextMessageValidator() {69 return defaultPlaintextMessageValidator;70 }71 @Bean(name = "defaultBinaryMessageValidator")72 public BinaryMessageValidator getDefaultBinaryMessageValidator() {73 return defaultBinaryMessageValidator;74 }75 @Bean(name = "defaultBinaryBase64MessageValidator")76 public BinaryBase64MessageValidator getDefaultBinaryBase64MessageValidator() {77 return defaultBinaryBase64MessageValidator;78 }79 @Bean(name = "defaultGzipBinaryBase64MessageValidator")80 public GzipBinaryBase64MessageValidator getDefaultGzipBinaryBase64MessageValidator() {81 return defaultGzipBinaryBase64MessageValidator;82 }83 @Bean(name = "defaultXhtmlMessageValidator")84 public XhtmlMessageValidator getDefaultXhtmlMessageValidator() {85 return defaultXhtmlMessageValidator;86 }87 @Bean(name = "defaultXhtmlXpathMessageValidator")88 public XhtmlXpathMessageValidator getDefaultXhtmlXpathMessageValidator() {89 return defaultXhtmlXpathMessageValidator;90 }91 @Bean(name = "defaultGroovyXmlMessageValidator")92 public GroovyXmlMessageValidator getDefaultGroovyXmlMessageValidator() {93 return defaultGroovyXmlMessageValidator;94 }95 @Bean(name = "defaultGroovyJsonMessageValidator")96 public GroovyJsonMessageValidator getDefaultGroovyJsonMessageValidator() {97 return defaultGroovyJsonMessageValidator;98 }99 @Bean(name = "defaultGroovyTextMessageValidator")100 public GroovyScriptMessageValidator getDefaultGroovyTextMessageValidator() {101 return defaultGroovyTextMessageValidator;102 }103 @Bean(name = MessageValidatorRegistry.BEAN_NAME)104 public MessageValidatorRegistry getMessageValidatorRegistry() {105 MessageValidatorRegistry citrusMessageValidatorRegistry = new MessageValidatorRegistry();106 citrusMessageValidatorRegistry.getMessageValidators().add(defaultXmlMessageValidator);107 citrusMessageValidatorRegistry.getMessageValidators().add(defaultXpathMessageValidator);108 citrusMessageValidatorRegistry.getMessageValidators().add(defaultGroovyXmlMessageValidator);109 citrusMessageValidatorRegistry.getMessageValidators().add(defaultJsonMessageValidator);110 citrusMessageValidatorRegistry.getMessageValidators().add(defaultJsonPathMessageValidator);111 citrusMessageValidatorRegistry.getMessageValidators().add(defaultPlaintextMessageValidator);112 citrusMessageValidatorRegistry.getMessageValidators().add(defaultMessageHeaderValidator);113 citrusMessageValidatorRegistry.getMessageValidators().add(defaultBinaryMessageValidator);114 citrusMessageValidatorRegistry.getMessageValidators().add(defaultBinaryBase64MessageValidator);115 citrusMessageValidatorRegistry.getMessageValidators().add(defaultGzipBinaryBase64MessageValidator);116 citrusMessageValidatorRegistry.getMessageValidators().add(defaultGroovyJsonMessageValidator);117 citrusMessageValidatorRegistry.getMessageValidators().add(defaultGroovyTextMessageValidator);118 citrusMessageValidatorRegistry.getMessageValidators().add(defaultXhtmlMessageValidator);119 citrusMessageValidatorRegistry.getMessageValidators().add(defaultXhtmlXpathMessageValidator);120 return citrusMessageValidatorRegistry;121 }122}...

Full Screen

Full Screen

Source:BinaryMessageValidator.java Github

copy

Full Screen

...30 * message payload is convertable to an input stream so we can compare the stream data with buffer read.31 * 32 * @author Christoph Deppisch33 */34public class BinaryMessageValidator extends DefaultMessageValidator {35 private static final int BUFFER_SIZE = 1024;36 @Override37 public void validateMessage(Message receivedMessage, Message controlMessage,38 TestContext context, ValidationContext validationContext) throws ValidationException {39 try (InputStream receivedInput = receivedMessage.getPayload(InputStream.class);40 InputStream controlInput = controlMessage.getPayload(InputStream.class)) {41 ReadableByteChannel receivedBytes = Channels.newChannel(receivedInput);42 ReadableByteChannel controlBytes = Channels.newChannel(controlInput);43 ByteBuffer receivedBuffer = ByteBuffer.allocateDirect(BUFFER_SIZE);44 ByteBuffer controlBuffer = ByteBuffer.allocateDirect(BUFFER_SIZE);45 while (true) {46 int n1 = receivedBytes.read(receivedBuffer);47 int n2 = controlBytes.read(controlBuffer);48 if (n1 == -1 || n2 == -1) return;...

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1import com.consol.citrus.context.TestContext;2import com.consol.citrus.exceptions.ValidationException;3import com.consol.citrus.message.Message;4import com.consol.citrus.message.MessageType;5import com.consol.citrus.validation.context.ValidationContext;6import com.consol.citrus.validation.text.BinaryMessageValidator;7public class BinaryMessageValidator extends BinaryMessageValidator {8public void validateMessage(Message receivedMessage, Message controlMessage, TestContext context, ValidationContext validationContext) {9byte[] receivedPayload = receivedMessage.getPayload(byte[].class);10byte[] controlPayload = controlMessage.getPayload(byte[].class);11if (!Arrays.equals(receivedPayload, controlPayload)) {12throw new ValidationException("Binary message validation failed!", "Binary message validation failed!");13}14}15}16import com.consol.citrus.context.TestContext;17import com.consol.citrus.exceptions.ValidationException;18import com.consol.citrus.message.Message;19import com.consol.citrus.message.MessageType;20import com.consol.citrus.validation.context.ValidationContext;21import com.consol.citrus.validation.text.BinaryMessageValidator;22public class BinaryMessageValidator extends BinaryMessageValidator {23public void validateMessage(Message receivedMessage, Message controlMessage, TestContext context, ValidationContext validationContext) {24byte[] receivedPayload = receivedMessage.getPayload(byte[].class);25byte[] controlPayload = controlMessage.getPayload(byte[].class);26if (!Arrays.equals(receivedPayload, controlPayload)) {27throw new ValidationException("Binary message validation failed!", "Binary message validation failed!");28}29}30}31import com.consol.citrus.context.TestContext;32import com.consol.citrus.exceptions.ValidationException;33import com.consol.citrus.message.Message;34import com.consol.citrus.message.MessageType;35import com.consol.citrus.validation.context.ValidationContext;36import com.consol.citrus.validation.text.BinaryMessageValidator;37public class BinaryMessageValidator extends BinaryMessageValidator {

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;2import com.consol.citrus.validation.text.BinaryMessageValidator;3import org.springframework.core.io.ClassPathResource;4import org.testng.annotations.Test;5public class 4 extends TestNGCitrusTestDesigner {6 public void configure() {7 http()8 .client("httpClient")9 .send()10 .post("/upload")11 .contentType("application/json")12 .payload(new ClassPathResource("request.json"));13 http()14 .client("httpClient")15 .receive()16 .response(HttpStatus.OK)17 .messageType(MessageType.BINARY)18 .validate(binaryMessageValidator()19 .controlMessage(new ClassPathResource("response.json"))20 .ignoreBytes(0, 2)21 .ignoreBytes(4, 5));22 }23}

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1import com.consol.citrus.dsl.runner.TestRunner;2import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;3import org.testng.annotations.Test;4public class 4 extends TestNGCitrusTestDesigner {5 public void 4() {6 variable("message", "Hello World!");7 variable("messageLength", "12");8 TestRunner runner = createTestRunner();9 runner.echo("${message}");10 runner.run(binaryMessageValidator()11 .messageType("text")12 .controlMessage("${message}")13 .extractFromPayload("${messageLength}", "messageLength"));14 runner.echo("${messageLength}");15 }16}

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1package com.consol.citrus.samples;2import com.consol.citrus.dsl.builder.BuilderSupport;3import com.consol.citrus.dsl.builder.ReceiveMessageActionBuilder;4import com.consol.citrus.dsl.runner.TestRunner;5import com.consol.citrus.dsl.runner.TestRunnerSupport;6import com.consol.citrus.dsl.validation.ValidationContext;7import com.consol.citrus.dsl.validation.ValidationContextSupport;8import com.consol.citrus.samples.message.BinaryMessage;9import com.consol.citrus.samples.message.BinaryMessageValidator;10import com.consol.citrus.samples.message.MessageFactory;11import com.consol.citrus.samples.message.MessageType;12import com.consol.citrus.samples.message.MessageValidator;13import com.consol.citrus.samples.message.MessageValidatorFactory;14import com.consol.citrus.samples.message.MessageValidatorType;15import com.consol.citrus.samples.message.TextMessage;16import com.consol.citrus.samples.message.TextMessageValidator;17import org.springframework.core.io.ClassPathResource;18import org.testng.annotations.Test;19import java.util.HashMap;20import java.util.Map;21import static com.consol.citrus.actions.CreateVariablesAction.Builder.createVariable;22import static com.consol.citrus.actions.EchoAction.Builder.echo;23import static com.consol.citrus.actions.SendMessageAction.Builder.send;24import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.action;25import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.apply;26import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyAction;27import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehavior;28import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorAnd;29import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorOr;30import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorXor;31import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorXorAnd;32import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorXorOr;33import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorXorXor;34import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.applyBehaviorXorXorAnd;35import static com.consol.citrus.dsl.builder.BuilderSupport.BuilderSupportBuilder.apply

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;4import com.consol.citrus.validation.text.BinaryMessageValidator;5import org.springframework.core.io.ClassPathResource;6import org.testng.annotations.Test;7public class BinaryMessageValidationIT extends TestNGCitrusTestRunner {8 public void binaryMessageValidation() {9 variable("message", "Hello Citrus!");10 http()11 .client("httpClient")12 .send()13 .post("/test")14 .contentType("application/octet-stream")15 .payload("${message}");16 http()17 .client("httpClient")18 .receive()19 .response(HttpStatus.OK)20 .validator(new BinaryMessageValidator())21 .payload(new ClassPathResource("files/4.txt"));22 }23}24package com.consol.citrus.samples;25import com.consol.citrus.annotations.CitrusTest;26import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;27import com.consol.citrus.validation.json.JsonMessageValidator;28import org.springframework.core.io.ClassPathResource;29import org.testng.annotations.Test;30public class JsonMessageValidationIT extends TestNGCitrusTestRunner {31 public void jsonMessageValidation() {32 variable("message", "Hello Citrus!");33 http()34 .client("httpClient")35 .send()36 .post("/test")37 .contentType("application/json")38 .payload("{ \"message\": \"${message}\"}");39 http()40 .client("httpClient")41 .receive()42 .response(HttpStatus.OK)43 .validator(new JsonMessageValidator())44 .payload(new ClassPathResource("files/5.json"));45 }46}47package com.consol.citrus.samples;48import com.consol.citrus.annotations.CitrusTest;49import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;50import com.consol.citrus.validation.xml.XmlMessageValidator;51import org.springframework.core.io

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1import com.consol.citrus.validation.text.BinaryMessageValidator;2import com.consol.citrus.validation.text.BinaryValidationContext;3import com.consol.citrus.validation.MessageValidatorRegistry;4import com.consol.citrus.validation.MessageValidator;5import com.consol.citrus.validation.MessageValidatorContext;6import com.consol.citrus.message.Message;7import com.consol.citrus.context.TestContext;8import com.consol.citrus.exceptions.ValidationException;9import com.consol.citrus.exceptions.CitrusRuntimeException;10import java.util.Map;11import java.util.HashMap;12import java.util.List;13import java.util.ArrayList;14import java.io.IOException;15import java.io.File;16import java.io.FileInputStream;17import java.io.ByteArrayInputStream;18import java.io.InputStream;19import java.io

Full Screen

Full Screen

BinaryMessageValidator

Using AI Code Generation

copy

Full Screen

1public class BinaryMessageValidator extends AbstractMessageValidator<BinaryMessage> {2 public boolean supportsMessageType(String messageType, Object message) {3 return messageType.equals("binary");4 }5 public void validateMessagePayload(BinaryMessage message, Object messagePayload, MessageValidationContext validationContext) {6 }7}

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.

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 methods in BinaryMessageValidator

Test Your Web Or Mobile Apps On 3000+ Browsers

Signup for free

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful