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

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

Source:VisibilityMetadataAggregatorIT.java

...402				.post()403				.contentType("application/json;charset=UTF-8") 404				.accept("application/json")405				.selector(Collections.singletonMap(HttpMessageHeaders.HTTP_REQUEST_URI, "/api/1/token"))406				.extractFromHeader("citrus_http_request_uri", "receive_citrus_http_request_uri")407				);408		echo("Token_receive_citrus_http_request_uri - ${receive_citrus_http_request_uri}");409		echo("Stop Receive Lens Server for Token");410		echo("Start Send Lens Server for Token");411		http(httpActionBuilder -> httpActionBuilder 412				.server(lensServer)413				.send()		414				.response(HttpStatus.OK) 415				.payload(TestHelper.getLensAccessToken())416				.contentType("application/json;charset=UTF-8")	417				//.extractFromHeader("citrus_http_request_uri", "send_citrus_http_request_uri")418				);419		echo("Stop Send Lens Server for Token");420		//echo("Token_send_citrus_http_request_uri - ${send_citrus_http_request_uri}");421	}422	423	private void httpLensServerProcessesAction(String fileName) {424		http(httpActionBuilder -> httpActionBuilder 425				.server(lensServer) 426				.receive()427				.post()428				.contentType("application/json;charset=UTF-8") 429				.accept("application/json")430				.selector(Collections.singletonMap(HttpMessageHeaders.HTTP_REQUEST_URI, "/api/1/processes"))431				.extractFromHeader("citrus_http_request_uri", "receive_citrus_http_request_uri")432				.validationCallback(processesValidationCallback(fileName))433				);434		echo("Processes_receive_citrus_http_request_uri - ${receive_citrus_http_request_uri}");435		http(httpActionBuilder -> httpActionBuilder 436				.server(lensServer)437				.send()		438				.response(HttpStatus.OK) 439				.contentType("application/json;charset=UTF-8")	440				);		441	}442	443	private AbstractValidationCallback<String> processesValidationCallback(String fileName) {444        return new AbstractValidationCallback<String>() {445            @Override446            public void validate(final String payload, final Map<String, Object> headers, final TestContext context) {447            	Assert.assertNotNull(payload);448            	String authorizationFromHeader = (String)headers.get("Authorization");449            	String authorizationExpected = TestHelper.getLensAuthorizationFromToken();450            	System.out.println("processesValidationCallback - payload: " + payload);451            	System.out.println("processesValidationCallback - Authorization: " + authorizationFromHeader + ", " + authorizationExpected);452            	            	453            	Processes processes = null;				454            	try {455					ObjectMapper mapper = new ObjectMapper();456		           	processes = mapper.readValue(payload, Processes.class);	457				} catch (IOException e) {458					// TODO Auto-generated catch block459					e.printStackTrace();460				}461				462				for(int i = 0; i < processes.getProcesses().size(); i++) {463					Process processPayload = processes.getProcesses().get(i);464					Process processExpected = TestHelper.getLensProcess(fileName, i);465					466	            	Assert.assertNotNull(processPayload);467	             	Assert.assertNotNull(processExpected);468	            	Assert.assertEquals(String.valueOf(headers.get("Authorization")), TestHelper.getLensAuthorizationFromToken(), "Authorization is not matching with Token response");469	               	                470	                // Check not null or empty for Process471	                Assert.assertNotNull(processPayload.getTransactionId());472	            	Assert.assertNotNull(processPayload.getDate());473	            	Assert.assertNotNull(processPayload.getExpires());474	            	Assert.assertNotNull(processPayload.getVersion());475	            	//Assert.assertNotNull(processPayload.getSteps());476	                477	            	// Compare all properties for Process except ...478	            	List<String> efProcess = new ArrayList<String>(); 479					efProcess.add("transactionId"); 480					efProcess.add("date");481					efProcess.add("expires"); 482					efProcess.add("version"); 483					efProcess.add("steps"); 484					String resultStrProcess = TestHelper.haveSamePropertyValuesExcludeFields(processPayload, processExpected, efProcess);485					echo("Validation Result - Lens Process: " + resultStrProcess.toString()); 486					Boolean resultProcess =  resultStrProcess.isEmpty()? true: false;487					Assert.assertEquals(Boolean.TRUE.toString(), resultProcess.toString(), "Lens UI Process properies not matched: " + resultStrProcess);488					489					for(int j = 0; j < processPayload.getSteps().size(); j++) {490						Step stepPayload = processPayload.getSteps().get(j);491						Step stepExpected = processExpected.getSteps().get(j);492						493						Assert.assertNotNull(stepPayload.getDate());	494						Assert.assertNotNull(stepPayload.getId());	495						Assert.assertNotNull(stepPayload.getMetadata());	496						// Compare all properties for Steps except ...497		            	List<String> efStep = new ArrayList<String>(); 498						efStep.add("date");499						efStep.add("id"); 500						efStep.add("metadata"); 501						String resultStrStep = TestHelper.haveSamePropertyValuesExcludeFields(stepPayload, stepExpected, efStep);502						echo("Validation Result - Lens Process Step: " + resultStrStep.toString()); 503						Boolean resultStep =  resultStrStep.isEmpty()? true: false;504						Assert.assertEquals(Boolean.TRUE.toString(), resultStep.toString(), "Lens UI Process properies not matched: " + resultStrStep);505						506						// Compare MetaData507		            	Assert.assertEquals(processPayload.getSteps().get(0).getMetadata().get("protocol"), processExpected.getSteps().get(0).getMetadata().get("protocol"), "Step metadat protocol is not matching");508		            	Assert.assertEquals(processPayload.getSteps().get(0).getMetadata().get("deliveryReceipt"), processExpected.getSteps().get(0).getMetadata().get("deliveryReceipt"), "Step metadat deliveryReceipt is not matching");509		            	Assert.assertEquals(processPayload.getSteps().get(0).getMetadata().get("remoteHost"), processExpected.getSteps().get(0).getMetadata().get("remoteHost"), "Step metadat remoteHost is not matching");510		            	Assert.assertEquals(processPayload.getSteps().get(0).getMetadata().get("serviceName"), processExpected.getSteps().get(0).getMetadata().get("serviceName"), "Step metadat serviceName is not matching");511					}512				}513             }514        };515    }516	517	private void httpLensServerTransactionsAction(String fileName) {518		http(httpActionBuilder -> httpActionBuilder 519				.server(lensServer) 520				.receive()521				.post()522				.contentType("application/json;charset=UTF-8") 523				.accept("application/json")524				.selector(Collections.singletonMap(HttpMessageHeaders.HTTP_REQUEST_URI, "/api/1/transactions"))525				.extractFromHeader("citrus_http_request_uri", "receive_citrus_http_request_uri")526				.validationCallback(transactionsValidationCallback(fileName))527				);528		echo("Transactions_receive_citrus_http_request_uri - ${receive_citrus_http_request_uri}");529		http(httpActionBuilder -> httpActionBuilder 530				.server(lensServer)531				.send()		532				.response(HttpStatus.OK) 533				.contentType("application/json;charset=UTF-8")534				);535	}536	537	private AbstractValidationCallback<String> transactionsValidationCallback(String fileName) {538        return new AbstractValidationCallback<String>() {539            @Override540            public void validate(final String payload, final Map<String, Object> headers, final TestContext context) {541            	Assert.assertNotNull(payload);542            	String authorizationFromHeader = (String)headers.get("Authorization");543            	String authorizationExpected = TestHelper.getLensAuthorizationFromToken();544            	System.out.println("transactionsValidationCallback - payload: " + payload);545            	System.out.println("transactionsValidationCallback - Authorization: " + authorizationFromHeader + ", " + authorizationExpected);546            	            	547            	Transactions transactions = null;				548            	try {549					ObjectMapper mapper = new ObjectMapper();550					transactions = mapper.readValue(payload, Transactions.class);	551				} catch (IOException e) {552					// TODO Auto-generated catch block553					e.printStackTrace();554				}555				556				for(int i = 0; i < transactions.getMessages().size(); i++) {557					com.opentext.bn.content.lens.models.Message transactionPayload = transactions.getMessages().get(i);558					com.opentext.bn.content.lens.models.Message transactionExpected = TestHelper.getLensTransactionMessage(fileName, i);559					560	            	Assert.assertNotNull(transactionPayload);561	             	Assert.assertNotNull(transactionExpected);562	            	Assert.assertEquals(String.valueOf(headers.get("Authorization")), TestHelper.getLensAuthorizationFromToken(), "Authorization is not matching with Token response");563	            	564	            	// Check not null or empty for Transaction565	                Assert.assertNotNull(transactionPayload.getId());566	            	Assert.assertNotNull(transactionPayload.getPublishedtime());567	            	Assert.assertNotNull(transactionPayload.getVersion());568	            	Assert.assertNotNull(transactionPayload.getSendermsgid());569	            	Assert.assertNotNull(transactionPayload.getAdditionalinformation());570	            	Assert.assertNotNull(transactionPayload.getRelatedmsg());571	                572	            	// Compare all properties for Process except ...573	            	List<String> efTransaction = new ArrayList<String>(); 574					efTransaction.add("id"); 575					efTransaction.add("publishedtime");576					efTransaction.add("arrivaltime"); 577					efTransaction.add("version"); 578					efTransaction.add("sendermsgid");579					efTransaction.add("statusdate");580					efTransaction.add("relatedmsg");581					efTransaction.add("additionalinformation");582					String resultStrTransaction = TestHelper.haveSamePropertyValuesExcludeFields(transactionPayload, transactionExpected, efTransaction);583					echo("Validation Result - Lens Transaction: " + resultStrTransaction.toString()); 584					Boolean resultProcess =  resultStrTransaction.isEmpty()? true: false;585					Assert.assertEquals(Boolean.TRUE.toString(), resultProcess.toString(), "Lens UI Transaction properies not matched: " + resultStrTransaction);586					587				}588             }589        };590    }591	592	private void httpLensServerPayloadsAction() {593		http(httpActionBuilder -> httpActionBuilder 594				.server(lensServer) 595				.receive()596				.post()597				.contentType("application/json;charset=UTF-8") 598				.accept("application/json")599				.selector(Collections.singletonMap(HttpMessageHeaders.HTTP_REQUEST_URI, "/api/1/payloads"))600				.extractFromHeader("citrus_http_request_uri", "receive_citrus_http_request_uri")601				.validationCallback(payloadsValidationCallback())602				);603		echo("Payloads_receive_citrus_http_request_uri - ${receive_citrus_http_request_uri}");604		http(httpActionBuilder -> httpActionBuilder 605				.server(lensServer)606				.send()		607				.response(HttpStatus.OK) 608				.contentType("application/json;charset=UTF-8")	609				);610	}611	612	private AbstractValidationCallback<String> payloadsValidationCallback() {613        return new AbstractValidationCallback<String>() {614            @Override...

Source:SendMessageBuilder.java

...405     * @param headerName406     * @param variable407     * @return408     */409    public T extractFromHeader(String headerName, String variable) {410        if (headerExtractor == null) {411            headerExtractor = new MessageHeaderVariableExtractor();412            getAction().getVariableExtractors().add(headerExtractor);413        }414        415        headerExtractor.getHeaderMappings().put(headerName, variable);416        return self;417    }418    419    /**420     * Extract message element via XPath or JSONPath from payload before message is sent.421     * @param path422     * @param variable423     * @return...

Source:FlightBookingIT.java

...53            .endpoint(royalAirlineServer)54            .payload(new ClassPathResource("templates/RoyalAirlineBookingRequest.xml"))55            .ignore("//fbs:FlightBookingRequestMessage/fbs:bookingId")56            .header("bookingCorrelationId", "${correlationId}")57            .extractFromHeader("X-sequenceNumber", "${sequenceNumber}")58            .extractFromHeader("X-sequenceSize", "${sequenceSize}")59            .extractFromPayload("//fbs:FlightBookingRequestMessage/fbs:bookingId", "${royalAirlineBookingId}"));60        send(sendMessageBuilder -> sendMessageBuilder61            .endpoint(royalAirlineServer)62            .payload(new ClassPathResource("templates/RoyalAirlineBookingResponse.xml"))63            .header("X-sequenceNumber", "${sequenceNumber}")64            .header("X-sequenceSize", "${sequenceSize}")65            .header("bookingCorrelationId", "${correlationId}"));66        receive(receiveMessageBuilder -> receiveMessageBuilder67            .endpoint(smartAirlineBookingRequestEndpoint)68            .payload(new ClassPathResource("templates/SmartAirlineBookingRequest.xml"))69            .ignore("//fbs:FlightBookingRequestMessage/fbs:bookingId")70            .header("bookingCorrelationId", "${correlationId}")71            .extractFromHeader("sequenceNumber", "${sequenceNumber}")72            .extractFromHeader("sequenceSize", "${sequenceSize}")73            .extractFromPayload("//fbs:FlightBookingRequestMessage/fbs:bookingId", "${smartAirlineBookingId}"));74        send(sendMessageBuilder -> sendMessageBuilder75            .endpoint(smartAirlineBookingResponseEndpoint)76            .payload(new ClassPathResource("templates/SmartAirlineBookingResponse.xml"))77            .header("sequenceNumber", "${sequenceNumber}")78            .header("sequenceSize", "${sequenceSize}")79            .header("bookingCorrelationId", "${correlationId}"));80        receive(receiveMessageBuilder -> receiveMessageBuilder81            .endpoint(travelAgencyBookingResponseEndpoint)82            .payload(new ClassPathResource("templates/TravelBookingResponse.xml"))83            .header("bookingCorrelationId", "${correlationId}"));84    }85}...

extractFromHeader

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.message.MessageType;3import com.consol.citrus.testng.AbstractTestNGUnitTest;4import org.testng.annotations.Test;5import static com.consol.citrus.dsl.builder.BuilderSupport.extractFromHeader;6import static com.consol.citrus.dsl.builder.BuilderSupport.header;7import static com.consol.citrus.dsl.builder.BuilderSupport.headers;8import static com.consol.citrus.dsl.builder.BuilderSupport.message;9import static com.consol.citrus.dsl.builder.BuilderSupport.payload;10import static com.consol.citrus.dsl.builder.BuilderSupport.payloadData;11import static com.consol.citrus.dsl.builder.BuilderSupport.payloadResource;12import static com.consol.citrus.dsl.builder.BuilderSupport.send;13public class SendBuilderTest extends AbstractTestNGUnitTest {14    public void testSendBuilderWithPayload() {15        send("foo")16            .payload("Hello Citrus!");17        send("foo")18            .payload("Hello Citrus!")19            .messageType(MessageType.PLAINTEXT);20        send("foo")21            .payload("Hello Citrus!")22            .header("operation", "foo");23        send("foo")24            .payload("Hello Citrus!")25            .headers(headers()26                    .header("operation", "foo")27                    .header("id", "1234"));28        send("foo")29            .payload("Hello Citrus!")30            .header("operation", "foo")31            .header("id", "1234");32        send("foo")33            .payload("Hello Citrus!")34            .header("operation", "foo")35            .header("id", "1234")36            .messageType(MessageType.PLAINTEXT);37        send("foo")38            .payload("Hello Citrus!")39            .header("operation", "foo")40            .header("id", "1234")41            .messageType(MessageType.PLAINTEXT)42            .description("This is a sample send message");43        send("foo")44            .payload("Hello Citrus!")45            .header("operation", "foo")46            .header("id", "1234")47            .description("This is a sample send message");48        send("foo")49            .payload("Hello Citrus!")50            .header("operation", "foo")51            .header("id", "1234")52            .description("This is a sample send message")53            .messageType(MessageType.PLAINTEXT);54        send("

extractFromHeader

Using AI Code Generation

1public class 3 {2    public static void main(String[] args) {3        Citrus citrus = Citrus.newInstance();4        citrus.run(new TestActionBuilder() {5            public void doExecute(TestContext context) {6                extractFromHeader("headerName", "expression");7            }8        });9    }10}11public class 4 {12    public static void main(String[] args) {13        Citrus citrus = Citrus.newInstance();14        citrus.run(new TestActionBuilder() {15            public void doExecute(TestContext context) {16                extractFromHeader("headerName", "expression", "variable");17            }18        });19    }20}21public class 5 {22    public static void main(String[] args) {23        Citrus citrus = Citrus.newInstance();24        citrus.run(new TestActionBuilder() {25            public void doExecute(TestContext context) {26                extractFromHeader("headerName", "expression", "variable", "defaultValue");27            }28        });29    }30}31public class 6 {32    public static void main(String[] args) {33        Citrus citrus = Citrus.newInstance();34        citrus.run(new TestActionBuilder() {35            public void doExecute(TestContext context) {36                extractFromHeader("headerName", "expression", "variable", "defaultValue", "defaultValue");37            }38        });39    }40}41public class 7 {42    public static void main(String[] args) {43        Citrus citrus = Citrus.newInstance();44        citrus.run(new TestActionBuilder() {45            public void doExecute(TestContext context) {46                extractFromHeader("headerName", "expression", "variable", "defaultValue", "defaultValue", "defaultValue");47            }48        });49    }50}

extractFromHeader

Using AI Code Generation

1public class 3 {2    public void configure() {3                .payload("<HelloRequest><Message>Hello World!</Message></HelloRequest>")4                .header("operation", "sayHello")5                .header("citrus_jms_messageId", "1234567890")6                .extractFromHeader("citrus_jms_messageId", "correlationId");7    }8}9public class 4 {10    public void configure() {11                .payload("<HelloResponse><Message>Hello Citrus!</Message></HelloResponse>")12                .header("operation", "sayHello")13                .header("citrus_jms_messageId", "1234567890")14                .extractFromHeader("citrus_jms_messageId", "correlationId");15    }16}17public class 5 {18    public void configure() {19        soap()20            .client("soapClient")21            .send()22            .soapAction("sayHello")23            .payload("<HelloRequest><Message>Hello World!</Message></HelloRequest>")24            .header("citrus_jms_messageId", "1234567890")25            .extractFromHeader("citrus_jms_messageId", "correlationId");26    }27}28public class 6 {29    public void configure() {30        soap()31            .server("soapServer")32            .receive()33            .soapAction("sayHello")34            .payload("<HelloResponse><Message>Hello Citrus!</Message></HelloResponse>")35            .header("citrus_jms_messageId", "1234567890")36            .extractFromHeader("citrus_jms_messageId", "correlationId");37    }38}39public class 7 {40    public void configure() {41        tcp()42            .client("tcpClient")43            .send()44            .payload("Hello World!")

extractFromHeader

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.dsl.builder.SendMessageBuilder;3import com.consol.citrus.dsl.builder.BuilderSupport;4import com.consol.citrus.message.MessageType;5import com.consol.citrus.message.MessageTypeResolver;6public class SendMessageBuilder extends AbstractMessageActionBuilder<SendMessageAction, SendMessageBuilder> {7    public SendMessageBuilder(SendMessageAction action) {8        super(action);9    }10    public static SendMessageBuilder sendMessage() {11        return new SendMessageBuilder(new SendMessageAction());12    }13    public SendMessageBuilder message(String payload) {14        action.setMessage(payload);15        return this;16    }17    public SendMessageBuilder message(Object payload) {18        action.setMessage(payload);19        return this;20    }21    public SendMessageBuilder message(byte[] payload) {22        action.setMessage(payload);23        return this;24    }25    public SendMessageBuilder messageResource(String resourcePath) {26        action.setMessageResource(resourcePath);27        return this;28    }29    public SendMessageBuilder messageResource(String resourcePath, String encoding) {30        action.setMessageResource(resourcePath);31        action.setMessageResourceEncoding(encoding);32        return this;33    }34    public SendMessageBuilder message(String payload, MessageType messageType) {35        action.setMessage(payload);36        action.setMessageType(messageType);37        return this;38    }39    public SendMessageBuilder message(Object payload, MessageType messageType) {

extractFromHeader

Using AI Code Generation

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.http.client.HttpClient;5import com.consol.citrus.message.MessageType;6public class CitrusTest extends TestRunnerSupport {7    public void configure(TestRunner runner) {8        HttpClient client = new HttpClient();9        runner.http(builder -> builder.client(client)10                .send()11                .post()12                .payload("<testRequestMessage>" +13                .contentType("application/xml")14                .extractFromHeader("citrus_http_status_code", "http_status_code")15                .extractFromHeader("citrus_http_version", "http_version"));16        runner.echo("HTTP status code: ${http_status_code}");17        runner.echo("HTTP version: ${http_version}");18        runner.http(builder -> builder.client(client)19                .receive()20                .response(HttpStatus.OK)21                .messageType(MessageType.PLAINTEXT)22                .payload("Hello Citrus!"));23    }24}25import com.consol.citrus.dsl.builder.SendMessageBuilder;26import

extractFromHeader

Using AI Code Generation

1import com.consol.citrus.dsl.builder.SendMessageBuilder;2import com.consol.citrus.dsl.builder.BuilderSupport;3class Test1 {4    public void test1() {5        sendMessage(new SendMessageBuilder() {6            public void configure() {7                endpoint("myEndpoint");8                payload("<TestRequestMessage>" +9                    "</TestRequestMessage>");10                header("operation", "sayHello");11                extractFromHeader("operation", "operation");12            }13        });14    }15}16import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;17import com.consol.citrus.dsl.builder.BuilderSupport;18class Test1 {19    public void test1() {20        receiveMessage(new ReceiveMessageBuilder() {21            public void configure() {22                endpoint("myEndpoint");23                payload("<TestRequestMessage>" +24                    "</TestRequestMessage>");25                header("operation", "sayHello");26                extractFromHeader("operation", "operation");27            }28        });29    }30}31import com.consol.citrus.dsl.builder.SendSoapMessageBuilder;32import com.consol.citrus.dsl.builder.BuilderSupport;33class Test1 {34    public void test1() {35        sendSoap(new SendSoapMessageBuilder() {36            public void configure() {37                endpoint("myEndpoint");38                payload("<TestRequestMessage>" +39                    "</TestRequestMessage>");40                header("operation", "sayHello");41                extractFromHeader("operation", "operation");42            }43        });44    }45}46import com.consol.citrus.dsl.builder.ReceiveSoapMessageBuilder;47import com.consol.citrus.dsl.builder.BuilderSupport;48class Test1 {

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.