How to use getMessageContentBuilder method of com.consol.citrus.dsl.builder.SendMessageBuilder class

Best Citrus code snippet using com.consol.citrus.dsl.builder.SendMessageBuilder.getMessageContentBuilder

Source:SendMessageBuilder.java Github

copy

Full Screen

...117 * @return118 */119 public T message(Message message) {120 StaticMessageContentBuilder staticMessageContentBuilder = StaticMessageContentBuilder.withMessage(message);121 staticMessageContentBuilder.setMessageHeaders(getMessageContentBuilder().getMessageHeaders());122 getAction().setMessageBuilder(staticMessageContentBuilder);123 return self;124 }125 /**126 * Sets the payload data on the message builder implementation.127 * @param payload128 * @return129 */130 protected void setPayload(String payload) {131 MessageContentBuilder messageContentBuilder = getMessageContentBuilder();132 if (messageContentBuilder instanceof PayloadTemplateMessageBuilder) {133 ((PayloadTemplateMessageBuilder) messageContentBuilder).setPayloadData(payload);134 } else if (messageContentBuilder instanceof StaticMessageContentBuilder) {135 ((StaticMessageContentBuilder) messageContentBuilder).getMessage().setPayload(payload);136 } else {137 throw new CitrusRuntimeException("Unable to set payload on message builder type: " + messageContentBuilder.getClass());138 }139 }140 141 /**142 * Sets the message name.143 * @param name144 * @return145 */146 public T name(String name) {147 getMessageContentBuilder().setMessageName(name);148 return self;149 }150 151 /**152 * Adds message payload data to this builder.153 * @param payload154 * @return155 */156 public T payload(String payload) {157 setPayload(payload);158 return self;159 }160 /**161 * Adds message payload resource to this builder.162 * @param payloadResource163 * @return164 */165 public T payload(Resource payloadResource) {166 return payload(payloadResource, FileUtils.getDefaultCharset());167 }168 /**169 * Adds message payload resource to this builder.170 * @param payloadResource171 * @param charset172 * @return173 */174 public T payload(Resource payloadResource, Charset charset) {175 try {176 setPayload(FileUtils.readToString(payloadResource, charset));177 } catch (IOException e) {178 throw new CitrusRuntimeException("Failed to read payload resource", e);179 }180 return self;181 }182 /**183 * Sets payload POJO object which is marshalled to a character sequence using the given object to xml mapper.184 * @param payload185 * @param marshaller186 * @return187 */188 public T payload(Object payload, Marshaller marshaller) {189 StringResult result = new StringResult();190 191 try {192 marshaller.marshal(payload, result);193 } catch (XmlMappingException e) {194 throw new CitrusRuntimeException("Failed to marshal object graph for message payload", e);195 } catch (IOException e) {196 throw new CitrusRuntimeException("Failed to marshal object graph for message payload", e);197 }198 199 setPayload(result.toString());200 return self;201 }202 /**203 * Sets payload POJO object which is mapped to a character sequence using the given object to json mapper.204 * @param payload205 * @param objectMapper206 * @return207 */208 public T payload(Object payload, ObjectMapper objectMapper) {209 try {210 setPayload(objectMapper.writer().writeValueAsString(payload));211 } catch (JsonProcessingException e) {212 throw new CitrusRuntimeException("Failed to map object graph for message payload", e);213 }214 return self;215 }216 /**217 * Sets payload POJO object which is marshalled to a character sequence using the default object to xml or object218 * to json mapper that is available in Spring bean application context.219 *220 * @param payload221 * @return222 */223 public T payloadModel(Object payload) {224 Assert.notNull(applicationContext, "Citrus application context is not initialized!");225 if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(Marshaller.class))) {226 return payload(payload, applicationContext.getBean(Marshaller.class));227 } else if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(ObjectMapper.class))) {228 return payload(payload, applicationContext.getBean(ObjectMapper.class));229 }230 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");231 }232 /**233 * Sets payload POJO object which is marshalled to a character sequence using the given object to xml mapper that234 * is accessed by its bean name in Spring bean application context.235 *236 * @param payload237 * @param mapperName238 * @return239 */240 public T payload(Object payload, String mapperName) {241 Assert.notNull(applicationContext, "Citrus application context is not initialized!");242 if (applicationContext.containsBean(mapperName)) {243 Object mapper = applicationContext.getBean(mapperName);244 if (Marshaller.class.isAssignableFrom(mapper.getClass())) {245 return payload(payload, (Marshaller) mapper);246 } else if (ObjectMapper.class.isAssignableFrom(mapper.getClass())) {247 return payload(payload, (ObjectMapper) mapper);248 } else {249 throw new CitrusRuntimeException(String.format("Invalid bean type for mapper '%s' expected ObjectMapper or Marshaller but was '%s'", mapperName, mapper.getClass()));250 }251 }252 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");253 }254 /**255 * Adds message header name value pair to this builder's message sending action.256 * @param name257 * @param value258 */259 public T header(String name, Object value) {260 getMessageContentBuilder().getMessageHeaders().put(name, value);261 return self;262 }263 /**264 * Adds message headers to this builder's message sending action.265 * @param headers266 */267 public T headers(Map<String, Object> headers) {268 getMessageContentBuilder().getMessageHeaders().putAll(headers);269 return self;270 }271 /**272 * Adds message header data to this builder's message sending action. Message header data is used in SOAP273 * messages for instance as header XML fragment.274 * @param data275 */276 public T header(String data) {277 getMessageContentBuilder().getHeaderData().add(data);278 return self;279 }280 /**281 * Adds message header data as file resource to this builder's message sending action. Message header data is used in SOAP282 * messages for instance as header XML fragment.283 * @param resource284 */285 public T header(Resource resource) {286 return header(resource, FileUtils.getDefaultCharset());287 }288 /**289 * Adds message header data as file resource to this builder's message sending action. Message header data is used in SOAP290 * messages for instance as header XML fragment.291 * @param resource292 * @param charset293 */294 public T header(Resource resource, Charset charset) {295 try {296 getMessageContentBuilder().getHeaderData().add(FileUtils.readToString(resource, charset));297 } catch (IOException e) {298 throw new CitrusRuntimeException("Failed to read header resource", e);299 }300 return self;301 }302 /**303 * Sets header data POJO object which is marshalled to a character sequence using the given object to xml mapper.304 * @param model305 * @param marshaller306 * @return307 */308 public T headerFragment(Object model, Marshaller marshaller) {309 StringResult result = new StringResult();310 try {311 marshaller.marshal(model, result);312 } catch (XmlMappingException e) {313 throw new CitrusRuntimeException("Failed to marshal object graph for message header data", e);314 } catch (IOException e) {315 throw new CitrusRuntimeException("Failed to marshal object graph for message header data", e);316 }317 return header(result.toString());318 }319 /**320 * Sets header data POJO object which is mapped to a character sequence using the given object to json mapper.321 * @param model322 * @param objectMapper323 * @return324 */325 public T headerFragment(Object model, ObjectMapper objectMapper) {326 try {327 return header(objectMapper.writer().writeValueAsString(model));328 } catch (JsonProcessingException e) {329 throw new CitrusRuntimeException("Failed to map object graph for message header data", e);330 }331 }332 /**333 * Sets header data POJO object which is marshalled to a character sequence using the default object to xml or object334 * to json mapper that is available in Spring bean application context.335 *336 * @param model337 * @return338 */339 public T headerFragment(Object model) {340 Assert.notNull(applicationContext, "Citrus application context is not initialized!");341 if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(Marshaller.class))) {342 return headerFragment(model, applicationContext.getBean(Marshaller.class));343 } else if (!CollectionUtils.isEmpty(applicationContext.getBeansOfType(ObjectMapper.class))) {344 return headerFragment(model, applicationContext.getBean(ObjectMapper.class));345 }346 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");347 }348 /**349 * Sets header data POJO object which is marshalled to a character sequence using the given object to xml mapper that350 * is accessed by its bean name in Spring bean application context.351 *352 * @param model353 * @param mapperName354 * @return355 */356 public T headerFragment(Object model, String mapperName) {357 Assert.notNull(applicationContext, "Citrus application context is not initialized!");358 if (applicationContext.containsBean(mapperName)) {359 Object mapper = applicationContext.getBean(mapperName);360 if (Marshaller.class.isAssignableFrom(mapper.getClass())) {361 return headerFragment(model, (Marshaller) mapper);362 } else if (ObjectMapper.class.isAssignableFrom(mapper.getClass())) {363 return headerFragment(model, (ObjectMapper) mapper);364 } else {365 throw new CitrusRuntimeException(String.format("Invalid bean type for mapper '%s' expected ObjectMapper or Marshaller but was '%s'", mapperName, mapper.getClass()));366 }367 }368 throw new CitrusRuntimeException("Unable to find default object mapper or marshaller in application context");369 }370 /**371 * Sets a explicit message type for this send action.372 * @param messageType373 * @return374 */375 public T messageType(MessageType messageType) {376 messageType(messageType.name());377 return self;378 }379 /**380 * Sets a explicit message type for this send action.381 * @param messageType382 * @return383 */384 public T messageType(String messageType) {385 this.messageType = messageType;386 getAction().setMessageType(messageType);387 return self;388 }389 /**390 * Get message builder, if already registered or create a new message builder and register it391 *392 * @return the message builder in use393 */394 protected AbstractMessageContentBuilder getMessageContentBuilder() {395 if (getAction().getMessageBuilder() != null && getAction().getMessageBuilder() instanceof AbstractMessageContentBuilder) {396 return (AbstractMessageContentBuilder) getAction().getMessageBuilder();397 } else {398 PayloadTemplateMessageBuilder messageBuilder = new PayloadTemplateMessageBuilder();399 getAction().setMessageBuilder(messageBuilder);400 return messageBuilder;401 }402 }403 /**404 * Extract message header entry as variable before message is sent.405 * @param headerName406 * @param variable407 * @return408 */...

Full Screen

Full Screen

getMessageContentBuilder

Using AI Code Generation

copy

Full Screen

1import com.consol.citrus.dsl.builder.SendMessageBuilder;2import com.consol.citrus.dsl.runner.TestRunner;3import com.consol.citrus.dsl.runner.TestRunnerSupport;4import com.consol.citrus.message.MessageType;5import com.consol.citrus.message.builder.MessageContentBuilder;6public class TestRunnerGetMessageContentBuilder implements TestRunnerSupport {7 public void execute(TestRunner runner) {8 .send("sendMessageEndpoint")9 .message()10 .type(MessageType.PLAINTEXT)11 .body("Hello Citrus!")12 .header("operation", "greet");13 }14 public static void main(String[] args) {15 new TestRunnerGetMessageContentBuilder().execute();16 }17}18import com.consol.citrus.dsl.builder.SendMessageActionBuilder;19import com.consol.citrus.dsl.runner.TestRunner;20import com.consol.citrus.dsl.runner.TestRunnerSupport;21import com.consol.citrus.message.MessageType;22import com.consol.citrus.message.builder.MessageContentBuilder;23public class TestRunnerGetMessageContentBuilder implements TestRunnerSupport {24 public void execute(TestRunner runner) {25 .send(sendMessageActionBuilder -> sendMessageActionBuilder26 .endpoint("sendMessageEndpoint")27 .messageType(MessageType.PLAINTEXT)28 .payload("Hello Citrus!")29 .header("operation", "greet")30 );31 }32 public static void main(String[] args) {33 new TestRunnerGetMessageContentBuilder().execute();34 }35}36import com.consol.citrus.dsl.builder.SendMessageBuilder;37import com.consol.citrus.dsl.runner.TestRunner;38import com.consol.citrus.dsl.runner.TestRunnerSupport;39import com.consol.citrus.message.MessageType;40import com.consol.citrus.message.builder.MessageContentBuilder;41public class TestRunnerGetMessageContentBuilder implements TestRunnerSupport {42 public void execute(TestRunner runner) {43 .send("sendMessageEndpoint")44 .message()45 .type(MessageType.PLAINTEXT)46 .body("Hello Citrus!")47 .header("operation", "greet");48 }49 public static void main(String[] args

Full Screen

Full Screen

getMessageContentBuilder

Using AI Code Generation

copy

Full Screen

1com.consol.citrus.dsl.builder.SendMessageBuilder getMessageContentBuilder()2com.consol.citrus.dsl.builder.ReceiveMessageBuilder getMessageContentBuilder()3com.consol.citrus.dsl.builder.SendSoapMessageBuilder getMessageContentBuilder()4com.consol.citrus.dsl.builder.ReceiveSoapMessageBuilder getMessageContentBuilder()5com.consol.citrus.dsl.builder.SendSoapFaultBuilder getMessageContentBuilder()6com.consol.citrus.dsl.builder.ReceiveSoapFaultBuilder getMessageContentBuilder()7com.consol.citrus.dsl.builder.SendHttpRequestBuilder getMessageContentBuilder()8com.consol.citrus.dsl.builder.ReceiveHttpRequestBuilder getMessageContentBuilder()9com.consol.citrus.dsl.builder.SendHttpResponseBuilder getMessageContentBuilder()10com.consol.citrus.dsl.builder.ReceiveHttpResponseBuilder getMessageContentBuilder()11com.consol.citrus.dsl.builder.SendTcpMessageBuilder getMessageContentBuilder()

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