Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

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

Best Citrus code snippet using com.consol.citrus.dsl.builder.ReceiveMessageBuilder.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:ReceiveMessageBuilder.java

...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     * @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.dsl.builder.ReceiveMessageBuilder;3import com.consol.citrus.message.MessageType;4import com.consol.citrus.testng.AbstractTestNGUnitTest;5import org.testng.annotations.Test;6public class extractFromHeaderTest extends AbstractTestNGUnitTest {7    public void testExtractFromHeader() {8        MockBuilder builder = new MockBuilder(applicationContext) {9            public void configure() {10                receive("fooEndpoint")11                    .payload("<TestRequestMessage><text>Hello World!</text></TestRequestMessage>")12                    .header("operation", "foo")13                    .extractFromHeader("operation", "operation");14            }15        };16        builder.run(applicationContext);17    }18}19[main] INFO org.springframework.context.support.ClassPathXmlApplicationContext - Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@2d3a7a9e: startup date [Fri Jul 07 14:41:45 IST 2017]; root of context hierarchy

extractFromHeader

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;3import com.consol.citrus.dsl.testng.TestNGCitrusTestBuilder;4import org.testng.annotations.Test;5import java.util.Map;6public class extractFromHeader1 extends TestNGCitrusTestBuilder {7public void extractFromHeader1() {8  variable("header", "myHeader");9  variable("value", "myValue");10  variable("headerName", "myHeaderName");11  variable("headerValue", "myHeaderValue");12  variable("headerName1", "myHeaderName1");13  variable("headerValue1", "myHeaderValue1");14  variable("headerName2", "myHeaderName2");15  variable("headerValue2", "myHeaderValue2");16  variable("headerName3", "myHeaderName3");17  variable("headerValue3", "myHeaderValue3");18  variable("headerName4", "myHeaderName4");19  variable("headerValue4", "myHeaderValue4");20  variable("headerName5", "myHeaderName5");21  variable("headerValue5", "myHeaderValue5");22  variable("headerName6", "myHeaderName6");23  variable("headerValue6", "myHeaderValue6");24  variable("headerName7", "myHeaderName7");25  variable("headerValue7", "myHeaderValue7");26  variable("headerName8", "myHeaderName8");27  variable("headerValue8", "myHeaderValue8");28  variable("headerName9", "myHeaderName9");29  variable("headerValue9", "myHeaderValue9");30  variable("headerName10", "myHeaderName10");31  variable("headerValue10", "myHeaderValue10");32  variable("headerName11", "myHeaderName11");33  variable("headerValue11", "myHeaderValue11");34  variable("headerName12", "myHeaderName12");35  variable("headerValue12", "myHeaderValue12");36  variable("headerName13", "myHeaderName13");37  variable("headerValue13", "myHeaderValue13");38  variable("headerName14", "myHeaderName14");39  variable("headerValue14", "myHeaderValue14");40  variable("headerName15", "myHeaderName15");41  variable("headerValue15", "myHeaderValue15");42  variable("headerName16", "myHeader

extractFromHeader

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import org.testng.annotations.Test;3import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;4public class ExtractFromHeaderTest extends TestNGCitrusTestRunner {5public void extractFromHeader() {6http().client("httpClient")7.send()8.post("/test")9.header("Content-Type", "text/plain")10.payload("Hello Citrus!");11http().client("httpClient")12.receive()13.response(HttpStatus.OK)14.extractFromHeader("Content-Type", "contentType");15echo("Extracted header value: ${contentType}");16}17}

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.