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

Copied to Clipboard!

How to use trace method of com.consol.citrus.dsl.builder.HttpServerActionBuilder class

Best Citrus code snippet using com.consol.citrus.dsl.builder.HttpServerActionBuilder.trace

Source:VisibilityMetadataAggregatorIT.java

1/*2 * Copyright 2006-2016 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.opentext.bn.content;17import java.io.ByteArrayOutputStream;18import java.io.IOException;19import java.nio.file.Files;20import java.nio.file.Paths;21import java.util.ArrayList;22import java.util.Collections;23import java.util.List;24import java.util.Map;25import java.util.UUID;26import org.apache.avro.generic.GenericDatumWriter;27import org.apache.avro.generic.GenericRecord;28import org.apache.avro.io.DatumWriter;29import org.apache.avro.io.NoWrappingJsonEncoder;30import org.apache.avro.specific.SpecificDatumWriter;31import org.apache.avro.specific.SpecificRecord;32import org.json.JSONException;33import org.skyscreamer.jsonassert.JSONAssert;34import org.skyscreamer.jsonassert.JSONCompareMode;35import org.skyscreamer.jsonassert.comparator.DefaultComparator;36import org.springframework.beans.factory.annotation.Autowired;37import org.springframework.beans.factory.annotation.Qualifier;38import org.springframework.http.HttpStatus;39import org.springframework.http.MediaType;40import org.testng.Assert;41import org.testng.annotations.Optional;42import org.testng.annotations.Parameters;43import org.testng.annotations.Test;44import com.consol.citrus.annotations.CitrusResource;45import com.consol.citrus.annotations.CitrusTest;46import com.consol.citrus.context.TestContext;47import com.consol.citrus.dsl.builder.BuilderSupport;48import com.consol.citrus.dsl.builder.HttpActionBuilder;49import com.consol.citrus.dsl.builder.HttpServerActionBuilder;50import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerReceiveActionBuilder;51import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSendActionBuilder;52import com.consol.citrus.dsl.builder.HttpServerRequestActionBuilder;53import com.consol.citrus.dsl.builder.HttpServerResponseActionBuilder;54import com.consol.citrus.dsl.endpoint.CitrusEndpoints;55import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;56import com.consol.citrus.endpoint.EndpointAdapter;57import com.consol.citrus.exceptions.ValidationException;58import com.consol.citrus.http.client.HttpClient;59import com.consol.citrus.http.message.HttpMessageHeaders;60import com.consol.citrus.http.server.HttpServer;61import com.consol.citrus.kafka.endpoint.KafkaEndpoint;62import com.consol.citrus.kafka.message.KafkaMessage;63import com.consol.citrus.message.DefaultMessage;64import com.consol.citrus.message.Message;65import com.consol.citrus.message.MessageType;66import com.consol.citrus.validation.callback.AbstractValidationCallback;67import com.consol.citrus.validation.json.JsonMappingValidationCallback;68import com.fasterxml.jackson.annotation.JsonIgnore;69import com.fasterxml.jackson.databind.DeserializationFeature;70import com.fasterxml.jackson.databind.ObjectMapper;71import com.fasterxml.jackson.databind.SerializationFeature;72import com.opentext.bn.content.cmd.models.CmdConstants;73import com.opentext.bn.content.lens.models.Token;74import com.opentext.bn.content.lens.models.Transactions;75import com.opentext.bn.content.lens.models.Payload;76import com.opentext.bn.content.lens.models.Payloads;77import com.opentext.bn.content.lens.models.Process;78import com.opentext.bn.content.lens.models.Processes;79import com.opentext.bn.content.lens.models.Step;80import com.opentext.bn.converters.avro.entity.ContentErrorEvent;81import com.opentext.bn.converters.avro.entity.DeliveryCompletedEvent;82import com.opentext.bn.converters.avro.entity.DeliveryErrorEvent;83import com.opentext.bn.converters.avro.entity.DeliveryReadyForPickupEvent;84import com.opentext.bn.converters.avro.entity.DocumentEvent;85import com.opentext.bn.converters.avro.entity.EnvelopeEvent;86import com.opentext.bn.converters.avro.entity.FileIntrospectedEvent;87import com.opentext.bn.converters.avro.entity.ReceiveCompletedEvent;88import com.opentext.bn.converters.avro.entity.ReceiveErrorEvent;89import com.opentext.bn.converters.avro.entity.TransactionContext;90public class VisibilityMetadataAggregatorIT extends TestNGCitrusTestRunner {91	@Autowired92	@Qualifier("eventInjectorClient")93	private HttpClient eventInjectorClient;94	@Autowired95	@Qualifier("cmdClient")96	private HttpClient cmdClient;97	@Autowired98	@Qualifier("lensServer1")99	private HttpServer lensServer;100	@Autowired101	@Qualifier("citrusKafkaEndpoint")102	private KafkaEndpoint citrusKafkaEndpoint;103	@Autowired104	@Qualifier("receiveCompletedKafkaEndpoint")105	private KafkaEndpoint receiveCompletedKafkaEndpoint;106	107	@Autowired108	@Qualifier("receiveErrorKafkaEndpoint")109	private KafkaEndpoint receiveErrorKafkaEndpoint;110	@Autowired111	@Qualifier("deliverycompletedKafkaEndpoint")112	private KafkaEndpoint deliverycompletedKafkaEndpoint;113	114	@Autowired115	@Qualifier("deliveryErrorKafkaEndpoint")116	private KafkaEndpoint deliveryErrorKafkaEndpoint;117	118	@Autowired119	@Qualifier("deliveryReadyForPickupKafkaEndpoint")120	private KafkaEndpoint deliveryReadyForPickupKafkaEndpoint;121	@Autowired122	@Qualifier("documentKafkaEndpoint")123	private KafkaEndpoint documentKafkaEndpoint;124	@Autowired125	@Qualifier("envelopeKafkaEndpoint")126	private KafkaEndpoint envelopeKafkaEndpoint;127	@Autowired128	@Qualifier("fileKafkaEndpoint")129	private KafkaEndpoint fileKafkaEndpoint;130	@Autowired131	@Qualifier("contentErrorKafkacEndpoint")132	private KafkaEndpoint contentErrorKafkacEndpoint;133	@Autowired134	@Qualifier("cmdResponseAdapter")135	private EndpointAdapter cmdResponseAdapter;136	@Test137	@CitrusTest138	public void process_ReceiveCompletedIT() {139		try {140			String controlFile = "src/test/resources/testfiles/controlFile2.txt";141			String eventJsonString = new String(Files.readAllBytes(Paths.get(controlFile)));142			String transactionId = UUID.randomUUID().toString();143			echo("transactionId: " + transactionId);144			String payloadId = "Q14E-201912000000000"145					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);146			echo("payloadId: " + payloadId);147			String receiveCompletedJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);148			ObjectMapper mapper = new ObjectMapper();149			ReceiveCompletedEvent receiveCompleteEvent = mapper.readValue(receiveCompletedJsonString,150					ReceiveCompletedEvent.class);151			send(sendMessageBuilder -> {152				sendMessageBuilder.endpoint(citrusKafkaEndpoint)153				.message(new KafkaMessage(receiveCompleteEvent).topic("visibility.platform.receivecompleted")154						.messageKey(receiveCompleteEvent.getTransactionContext().getTransactionId()));155			});156			//sleep(30000);157			httpLensServerTokenAction();158			//httpLensServerTokenAction();159			//httpLensServerTokenAction();160			String processFile = "src/test/resources/testfiles/lensProcesses.txt";161			httpLensServerProcessesAction(processFile);162			163			String fileName = "src/test/resources/testfiles/lensTransactions.txt";164			httpLensServerTransactionsAction(fileName);165			httpLensServerPayloadsAction();166			167			//httpLensServerAction();168			receive(receiveMessageBuilder -> {169				receiveMessageBuilder.endpoint(receiveCompletedKafkaEndpoint).validationCallback(170						new JsonMappingValidationCallback<ReceiveCompletedEvent>(ReceiveCompletedEvent.class, mapper) {171							@Override172							public void validate(ReceiveCompletedEvent payload, Map<String, Object> headers,173									TestContext context) {174								String receiveCompletedResponse = null;175								receiveCompletedResponse = convertToJson(payload);176								echo("Payload received - receiveCompletedResponse : " + receiveCompletedResponse);177								try {178									JSONAssert.assertEquals(receiveCompletedJsonString, receiveCompletedResponse,179											JSONCompareMode.LENIENT);180								} catch (JSONException e) {181									e.printStackTrace();182									throw new ValidationException("this test failed : {} ", e);183								}184								Assert.assertNotNull(payload);185								// Assert.assertNotNull("missing transaction Id in the payload: ",186								// payload.getTransactionId());187								Assert.assertNotNull("missing citrus_kafka_messageKey: ",188										String.valueOf(headers.get("citrus_kafka_messageKey")));189								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")),190										transactionId, "transactionid is not matching with kafka key");191								// Compare all properties192								String resultStr = TestHelper.haveSamePropertyValues(receiveCompleteEvent, payload);193								echo("Validation Result: " + resultStr.toString());194								Boolean result = resultStr.isEmpty() ? true : false;195								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),196										"ReceiveCompletedEvent properies not matched: " + resultStr);197							}198						});199			});200		} catch (IOException e) {201			// TODO Auto-generated catch block202			e.printStackTrace();203			throw new ValidationException("this test failed : {} ", e);204		}205	}206	207	@Test208	@CitrusTest209	public void process_ReceiveErrorIT() {210		try {211			String controlFile = "src/test/resources/testfiles/receiveError.txt";212			String eventJsonString = new String(Files.readAllBytes(Paths.get(controlFile)));213			String transactionId = UUID.randomUUID().toString();214			echo("transactionId: " + transactionId);215			String payloadId = "Q14E-201912000000000"216					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);217			echo("payloadId: " + payloadId);218			String receiveErrorJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);219			ObjectMapper mapper = new ObjectMapper();220			ReceiveErrorEvent receiveErrorEvent = mapper.readValue(receiveErrorJsonString, ReceiveErrorEvent.class);221			send(sendMessageBuilder -> {222				sendMessageBuilder.endpoint(citrusKafkaEndpoint)223				.message(new KafkaMessage(receiveErrorEvent).topic("visibility.platform.receiveerror")224						.messageKey(transactionId));225			});226			//sleep(30000);227			228			httpLensServerTokenAction();229			//httpLensServerTokenAction();230			//httpLensServerTokenAction();231			String processFile = "src/test/resources/testfiles/lensProcesses_for_receive_error.txt";232			httpLensServerProcessesAction(processFile);233			String fileName = "src/test/resources/testfiles/lensTransaction_for_receive_error.txt";234			httpLensServerTransactionsAction(fileName);235			httpLensServerPayloadsAction();236			receive(receiveMessageBuilder -> {237				receiveMessageBuilder.endpoint(receiveErrorKafkaEndpoint).validationCallback(238						new JsonMappingValidationCallback<ReceiveErrorEvent>(ReceiveErrorEvent.class, mapper) {239							@Override240							public void validate(ReceiveErrorEvent payload, Map<String, Object> headers, TestContext context) {241								Assert.assertNotNull(payload);242								Assert.assertNotNull("missing citrus_kafka_messageKey: ", String.valueOf(headers.get("citrus_kafka_messageKey")));243								//Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")), transactionId, "transactionid is not matching with kafka key");244								// Compare all properties245								String resultStr = TestHelper.haveSamePropertyValues(receiveErrorEvent, payload);246								echo("Validation Result: " + resultStr.toString());247								Boolean result = resultStr.isEmpty() ? true : false;248								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),249										"ReceiveErrorEvent properies not matched: " + resultStr);250							}251						});252			});253		} catch (IOException e) {254			// TODO Auto-generated catch block255			e.printStackTrace();256			throw new ValidationException("this test failed : {} ", e);257		}258	}259	260	@Test261	@CitrusTest262	public void process_DeliveryCompletedIT() {263		try {264			String controlFile = "src/test/resources/testfiles/deliveryCompleted.txt";265			String eventJsonString = new String(Files.readAllBytes(Paths.get(controlFile)));266			String transactionId = UUID.randomUUID().toString();267			echo("transactionId: " + transactionId);268			String payloadId = "Q14E-201912000000000"269					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);270			echo("payloadId: " + payloadId);271			String deliveryCompletedJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);272			ObjectMapper mapper = new ObjectMapper();273			DeliveryCompletedEvent deliveryCompletedEvent = mapper.readValue(deliveryCompletedJsonString, DeliveryCompletedEvent.class);274			send(sendMessageBuilder -> {275				sendMessageBuilder.endpoint(citrusKafkaEndpoint)276				.message(new KafkaMessage(deliveryCompletedEvent).topic("visibility.platform.deliverycompleted")277						.messageKey(deliveryCompletedEvent.getTransactionContext().getTransactionId()));278			});279			//sleep(30000);280			receive(receiveMessageBuilder -> {281				receiveMessageBuilder.endpoint(deliverycompletedKafkaEndpoint).validationCallback(282						new JsonMappingValidationCallback<DeliveryCompletedEvent>(DeliveryCompletedEvent.class, mapper) {283							@Override284							public void validate(DeliveryCompletedEvent payload, Map<String, Object> headers, TestContext context) {285								Assert.assertNotNull(payload);286								Assert.assertNotNull("missing citrus_kafka_messageKey: ", String.valueOf(headers.get("citrus_kafka_messageKey")));287								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")), transactionId, "transactionid is not matching with kafka key");288								// Compare all properties289								String resultStr = TestHelper.haveSamePropertyValues(deliveryCompletedEvent, payload);290								echo("Validation Result: " + resultStr.toString());291								Boolean result = resultStr.isEmpty() ? true : false;292								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),293										"DeliveryCompletedEvent properies not matched: " + resultStr);294							}295						});296			});297		} catch (IOException e) {298			// TODO Auto-generated catch block299			e.printStackTrace();300			throw new ValidationException("this test failed : {} ", e);301		}302	}303	304	305	@Test306	@CitrusTest307	public void process_DeliveryErrorIT() {308		try {309			String controlFile = "src/test/resources/testfiles/deliveryError.txt";310			String eventJsonString = new String(Files.readAllBytes(Paths.get(controlFile)));311			String transactionId = UUID.randomUUID().toString();312			echo("transactionId: " + transactionId);313			String payloadId = "Q14E-201912000000000"314					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);315			echo("payloadId: " + payloadId);316			String deliveryErrorJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);317			ObjectMapper mapper = new ObjectMapper();318			DeliveryErrorEvent deliveryErrorEvent = mapper.readValue(deliveryErrorJsonString, DeliveryErrorEvent.class);319			send(sendMessageBuilder -> {320				sendMessageBuilder.endpoint(citrusKafkaEndpoint)321				.message(new KafkaMessage(deliveryErrorEvent).topic("visibility.platform.deliveryerror")322						.messageKey(deliveryErrorEvent.getTransactionContext().getTransactionId()));323			});324			//sleep(30000);325			receive(receiveMessageBuilder -> {326				receiveMessageBuilder.endpoint(deliveryErrorKafkaEndpoint).validationCallback(327						new JsonMappingValidationCallback<DeliveryErrorEvent>(DeliveryErrorEvent.class, mapper) {328							@Override329							public void validate(DeliveryErrorEvent payload, Map<String, Object> headers, TestContext context) {330								Assert.assertNotNull(payload);331								Assert.assertNotNull("missing citrus_kafka_messageKey: ", String.valueOf(headers.get("citrus_kafka_messageKey")));332								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")), transactionId, "transactionid is not matching with kafka key");333								// Compare all properties334								String resultStr = TestHelper.haveSamePropertyValues(deliveryErrorEvent, payload);335								echo("Validation Result: " + resultStr.toString());336								Boolean result = resultStr.isEmpty() ? true : false;337								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),338										"DeliveryErrorEvent properies not matched: " + resultStr);339							}340						});341			});342		} catch (IOException e) {343			// TODO Auto-generated catch block344			e.printStackTrace();345			throw new ValidationException("this test failed : {} ", e);346		}347	}348	349	@Test350	@CitrusTest351	public void process_DeliveryReadyForPickupIT() {352		try {353			String controlFile = "src/test/resources/testfiles/deliveryError.txt";354			String eventJsonString = new String(Files.readAllBytes(Paths.get(controlFile)));355			String transactionId = UUID.randomUUID().toString();356			echo("transactionId: " + transactionId);357			String payloadId = "Q14E-201912000000000"358					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);359			echo("payloadId: " + payloadId);360			String deliveryReadyForPickupJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);361			ObjectMapper mapper = new ObjectMapper();362			DeliveryReadyForPickupEvent deliveryErrorEvent = mapper.readValue(deliveryReadyForPickupJsonString, DeliveryReadyForPickupEvent.class);363			send(sendMessageBuilder -> {364				sendMessageBuilder.endpoint(citrusKafkaEndpoint)365				.message(new KafkaMessage(deliveryErrorEvent).topic("visibility.platform.deliveryreadyforpickup")366						.messageKey(deliveryErrorEvent.getTransactionContext().getTransactionId()));367			});368			//sleep(30000);369			receive(receiveMessageBuilder -> {370				receiveMessageBuilder.endpoint(deliveryReadyForPickupKafkaEndpoint).validationCallback(371						new JsonMappingValidationCallback<DeliveryReadyForPickupEvent>(DeliveryReadyForPickupEvent.class, mapper) {372							@Override373							public void validate(DeliveryReadyForPickupEvent payload, Map<String, Object> headers, TestContext context) {374								Assert.assertNotNull(payload);375								Assert.assertNotNull("missing citrus_kafka_messageKey: ", String.valueOf(headers.get("citrus_kafka_messageKey")));376								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")), transactionId, "transactionid is not matching with kafka key");377								// Compare all properties378								String resultStr = TestHelper.haveSamePropertyValues(deliveryErrorEvent, payload);379								echo("Validation Result: " + resultStr.toString());380								Boolean result = resultStr.isEmpty() ? true : false;381								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),382										"DeliveryReadyForPickupEvent properies not matched: " + resultStr);383							}384						});385			});386		} catch (IOException e) {387			// TODO Auto-generated catch block388			e.printStackTrace();389			throw new ValidationException("this test failed : {} ", e);390		}391	}392	393	394	395	396	397	private void httpLensServerTokenAction() {398		echo("Start Receive Lens Server for Token");399		http(httpActionBuilder -> httpActionBuilder 400				.server(lensServer) 401				.receive()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            @Override615            public void validate(final String payload, final Map<String, Object> headers, final TestContext context) {616            	Assert.assertNotNull(payload);617            	String authorizationFromHeader = (String)headers.get("Authorization");618            	String authorizationExpected = TestHelper.getLensAuthorizationFromToken();619            	System.out.println("payloadsValidationCallback - payload: " + payload);620            	System.out.println("payloadsValidationCallback - Authorization: " + authorizationFromHeader + ", " + authorizationExpected);621            	            	622            	Payloads payloads = null;				623            	try {624					ObjectMapper mapper = new ObjectMapper();625		           	payloads = mapper.readValue(payload, Payloads.class);	626				} catch (IOException e) {627					// TODO Auto-generated catch block628					e.printStackTrace();629				}630				631				for(int i = 0; i < payloads.getPayloads().size(); i++) {632					Payload processPayload = payloads.getPayloads().get(i);633					Payload processExpected = TestHelper.getLensPayload(i);634					635	            	Assert.assertNotNull(processPayload);636	             	Assert.assertNotNull(processExpected);637	            	Assert.assertEquals(String.valueOf(headers.get("Authorization")), TestHelper.getLensAuthorizationFromToken(), "Authorization is not matching with Token response");638	            		            	639	            	// Check not null or empty for Payload640	                Assert.assertNotNull(processPayload.getTransactionId());641	            	Assert.assertNotNull(processPayload.getSize());642	            	Assert.assertNotNull(processPayload.getDate());643	            	Assert.assertNotNull(processPayload.getExpireDate());644	            	Assert.assertNotNull(processPayload.getCallbackURI());645	                646	            	// Compare all properties for Process except ...647	            	List<String> efTransaction = new ArrayList<String>(); 648					efTransaction.add("transactionId"); 649					efTransaction.add("size");650					efTransaction.add("callbackURI"); 651					efTransaction.add("date"); 652					efTransaction.add("expireDate");653					String resultStrTransaction = TestHelper.haveSamePropertyValuesExcludeFields(processPayload, processExpected, efTransaction);654					echo("Validation Result - Lens Payload: " + resultStrTransaction.toString()); 655					Boolean resultProcess =  resultStrTransaction.isEmpty()? true: false;656					Assert.assertEquals(Boolean.TRUE.toString(), resultProcess.toString(), "Lens UI Payload properies not matched: " + resultStrTransaction);657	            	Assert.assertEquals(processPayload.getName(), processExpected.getName(), "Lens Payload name is not matching");658				}659             }660        };661    }662	@Test663	@CitrusTest664	public void process_CMDRestCallIT() {665		try {666			String controlFile = "src/test/resources/testfiles/controlFile2.txt";667			String eventJsonString = new String(Files.readAllBytes(Paths.get(controlFile)));668			String transactionId = UUID.randomUUID().toString();669			echo("transactionId: " + transactionId);670			String payloadId = "Q14E-201912000000000"671					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);672			echo("payloadId: " + payloadId);673			String receiveCompletedJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);674			ObjectMapper mapper = new ObjectMapper();675			ReceiveCompletedEvent receiveCompleteEvent = mapper.readValue(receiveCompletedJsonString,676					ReceiveCompletedEvent.class);677			TransactionContext transactionContext = receiveCompleteEvent.getTransactionContext();678			String receiverInfo = transactionContext.getReceiverAddress();679			String senderInfo = transactionContext.getSenderAddress();680			int receiverIndex = receiverInfo.indexOf(":");681			int senderIndex = senderInfo.indexOf(":");682			String senderQualifier = senderInfo.substring(0, senderIndex);683			String senderAddress = senderInfo.substring(senderIndex + 1);684			String receiverQualifier = receiverInfo.substring(0, receiverIndex);685			String receiverAddress = receiverInfo.substring(receiverIndex + 1);686			echo("receiverAddress: " + receiverAddress + ", receiverQualifier: " + receiverQualifier687					+ ", senderAddress: " + senderAddress + ", senderQualifier: " + senderQualifier);688			// CMD REST Call 1 - buid Look Up By Addr689			// http://qtotcra.qa.gxsonline.net:8080/communitymasterdata/rest/v1/resolver/rootParentsByAddresses?senderAddress=ADHUBMDCS&senderQualifier=MS&receiverAddress=ADPARTMDCS&receiverQualifier=MS690			echo("Start CMD Call 1 - buid Look Up By Addr");691			String buidLookUpByAddr = "/resolver/rootParentsByAddresses?senderAddress=" + senderAddress692					+ "&senderQualifier=" + senderQualifier + "&receiverAddress=" + receiverAddress693					+ "&receiverQualifier=" + receiverQualifier;694			String senderAddressBuIdExpected = "GC22698817YV";695			String receiverAddressBuIdExpected = "GC28464997QM";696			http(httpActionBuilder -> httpActionBuilder.client(cmdClient).send().get(buidLookUpByAddr)697					.header(CmdConstants.IM_PRINCIPAL_TYPE, CmdConstants.CMD_PRINCIPAL_TYPE)698					.header(CmdConstants.IM_COMMUNITY_ID, CmdConstants.CMD_COMMUNITY_ID)699					.header(CmdConstants.IM_SERVICE_INSTANCE_ID, CmdConstants.CMD_INSTANCE_ID)700					.accept(MediaType.APPLICATION_JSON_VALUE).contentType("application/json"));701			http(httpActionBuilder -> httpActionBuilder.client(cmdClient).receive().response(HttpStatus.OK)702					.messageType(MessageType.JSON)703					.extractFromPayload("$.senderAddressBuId", "senderAddressBuIdReceived")704					.extractFromPayload("$.receiverAddressBuId", "receiverAddressBuIdReceived")705					.validate("$.senderAddressBuId", senderAddressBuIdExpected)706					.validate("$.receiverAddressBuId", receiverAddressBuIdExpected));707			echo("senderAddressBuIdReceived - ${senderAddressBuIdReceived};   receiverAddressBuIdReceived - ${receiverAddressBuIdReceived} ");708			echo("Finish CMD Call 1 - buid Look Up By Addr");709			// CMD REST Call 2 - Company Name Lookup By Sender BUID710			// http://qtotcra.qa.gxsonline.net:8080/communitymasterdata/rest/v1/businessUnits/GC22698817YV711			echo("Start CMD Call 2 - Company Name Lookup By Sender BUID");712			String companyNameLookup = "/businessUnits/" + senderAddressBuIdExpected;713			String companyNameExpected = "AD-TGMSHUBCOMP";714			http(httpActionBuilder -> httpActionBuilder.client(cmdClient).send().get(companyNameLookup)715					.header(CmdConstants.IM_PRINCIPAL_TYPE, CmdConstants.CMD_PRINCIPAL_TYPE)716					.header(CmdConstants.IM_COMMUNITY_ID, CmdConstants.CMD_COMMUNITY_ID)717					.header(CmdConstants.IM_SERVICE_INSTANCE_ID, CmdConstants.CMD_INSTANCE_ID)718					.accept(MediaType.APPLICATION_JSON_VALUE).contentType("application/json"));719			http(httpActionBuilder -> httpActionBuilder.client(cmdClient).receive().response(HttpStatus.OK)720					.messageType(MessageType.JSON).extractFromPayload("$.name", "companyNameReceived")721					.validate("$.name", companyNameExpected));722			echo("companyNameReceived - ${companyNameReceived}");723			echo("Finish CMD Call 2 - Company Name Lookup By BUID");724			// CMD REST Call 3 - Company Name Lookup By Receiver BUID725			// http://qtotcra.qa.gxsonline.net:8080/communitymasterdata/rest/v1/businessUnits/GC22698817YV726			echo("Start CMD REST Call 3 - Company Name Lookup By Receiver BUID");727			String companyNameLookup2 = "/businessUnits/" + receiverAddressBuIdExpected;728			String companyNameExpected2 = "AD-TGMSPARTCOMP1";729			http(httpActionBuilder -> httpActionBuilder730					.client(cmdClient)731					.send()732					.get(companyNameLookup2)733					.header(CmdConstants.IM_PRINCIPAL_TYPE, CmdConstants.CMD_PRINCIPAL_TYPE)734					.header(CmdConstants.IM_COMMUNITY_ID, CmdConstants.CMD_COMMUNITY_ID)735					.header(CmdConstants.IM_SERVICE_INSTANCE_ID, CmdConstants.CMD_INSTANCE_ID)736					.accept(MediaType.APPLICATION_JSON_VALUE).contentType("application/json")737					);738			http(httpActionBuilder -> httpActionBuilder739					.client(cmdClient)740					.receive()741					.response(HttpStatus.OK)742					.messageType(MessageType.JSON)743					.extractFromPayload("$.name", "companyNameReceived2")744					.validate("$.name", companyNameExpected2)745					);746			echo("companyNameReceived2 - ${companyNameReceived2}");747			echo("Finish CMD REST Call 3 - Company Name Lookup By Receiver BUID");748		} catch (IOException e) {749			// TODO Auto-generated catch block750			e.printStackTrace();751			throw new ValidationException("this test failed : {} ", e);752		}753	}754	@Test755	@CitrusTest756	public void process_FileIntrospectedEventIT() {757		try {758			String testFilePath = "src/test/resources/testfiles/fileIntrospected.txt";759			String eventJsonString = new String(Files.readAllBytes(Paths.get(testFilePath)));760			System.out.println("fileIntrospectedEventJsonString 1: " + eventJsonString);761			String transactionId = UUID.randomUUID().toString();762			echo("transactionId: " + transactionId);763			String payloadId = "Q14E-201912000000000"764					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);765			echo("payloadId: " + payloadId);766			eventJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);767			System.out.println("fileIntrospectedEventJsonString 2: " + eventJsonString);768			ObjectMapper mapper = new ObjectMapper();769			FileIntrospectedEvent envelope = mapper.readValue(eventJsonString, FileIntrospectedEvent.class);770			System.out.println("Envelope Send:");771			System.out.println(TestHelper.toString(envelope));772			send(sendMessageBuilder -> {773				sendMessageBuilder.endpoint(citrusKafkaEndpoint).message(774						new KafkaMessage(envelope).topic("visibility.introspection.file").messageKey(transactionId));775			});776			777			httpLensServerTokenAction();778			String fileName = "src/test/resources/testfiles/lensTransaction_for_File.txt";779			httpLensServerTransactionsAction(fileName);780			receive(receiveMessageBuilder -> {781				receiveMessageBuilder.endpoint(fileKafkaEndpoint).messageType(MessageType.BINARY)782				.message(new KafkaMessage(envelope).messageKey(transactionId)).validationCallback(783						new JsonMappingValidationCallback<FileIntrospectedEvent>(FileIntrospectedEvent.class,784								mapper) {785							@Override786							public void validate(FileIntrospectedEvent payload, Map<String, Object> headers,787									TestContext context) {788								System.out.println("Payload Receive:");789								System.out.println(TestHelper.toString(payload));790								Assert.assertNotNull(payload);791								Assert.assertNotNull("missing transaction Id in the payload: ",792										payload.getTransactionId());793								Assert.assertNotNull("missing citrus_kafka_messageKey: ",794										String.valueOf(headers.get("citrus_kafka_messageKey")));795								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")),796										payload.getTransactionId(),797										"transactionid is not matching with kafka key");798								// Compare all properties799								String resultStr = TestHelper.haveSamePropertyValues(envelope, payload);800								echo("Validation Result: " + resultStr.toString());801								Boolean result = resultStr.isEmpty() ? true : false;802								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),803										"FileIntrospectedEvent properies not matched: " + resultStr);804							}805						});806			});807		} catch (IOException e) { // TODO Auto-generated catch block808			e.printStackTrace();809		}810	}811	@Test812	@CitrusTest813	public void process_EnvelopeIntrospectedEventIT() {814		try {815			String testFilePath = "src/test/resources/testfiles/envelopeIntrospected.txt";816			String eventJsonString = new String(Files.readAllBytes(Paths.get(testFilePath)));817			System.out.println("envelopeIntrospectedEventJsonString 1: " + eventJsonString);818			String transactionId = UUID.randomUUID().toString();819			echo("transactionId: " + transactionId);820			String payloadId = "Q14E-201912000000000"821					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);822			echo("payloadId: " + payloadId);823			eventJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);824			System.out.println("envelopeIntrospectedEventJsonString 2: " + eventJsonString);825			ObjectMapper mapper = new ObjectMapper();826			EnvelopeEvent envelope = mapper.readValue(eventJsonString, EnvelopeEvent.class);827			send(sendMessageBuilder -> {828				sendMessageBuilder.endpoint(citrusKafkaEndpoint).message(new KafkaMessage(envelope)829						.topic("visibility.introspection.envelope").messageKey(transactionId));830			});831			832			httpLensServerTokenAction();833			String fileName = "src/test/resources/testfiles/lensTransaction_for_File.txt";834			httpLensServerTransactionsAction(fileName);835			receive(receiveMessageBuilder -> {836				receiveMessageBuilder.endpoint(envelopeKafkaEndpoint).messageType(MessageType.BINARY)837				.message(new KafkaMessage(envelope).messageKey(transactionId)).validationCallback(838						new JsonMappingValidationCallback<EnvelopeEvent>(EnvelopeEvent.class, mapper) {839							@Override840							public void validate(EnvelopeEvent payload, Map<String, Object> headers,841									TestContext context) {842								Assert.assertNotNull(payload);843								Assert.assertNotNull("missing transaction Id in the payload: ",844										payload.getTransactionId());845								Assert.assertNotNull("missing citrus_kafka_messageKey: ",846										String.valueOf(headers.get("citrus_kafka_messageKey")));847								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")),848										payload.getTransactionId(),849										"transactionid is not matching with kafka key");850								// Compare all properties851								String resultStr = TestHelper.haveSamePropertyValues(envelope, payload);852								echo("Validation Result: " + resultStr.toString());853								Boolean result = resultStr.isEmpty() ? true : false;854								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),855										"FileIntrospectedEvent properies not matched: " + resultStr);856							}857						});858			});859		} catch (IOException e) { // TODO Auto-generated catch block860			e.printStackTrace();861		}862	}863	@Test864	@CitrusTest865	public void process_DocumentIntrospectedEventIT() {866		try {867			String testFilePath = "src/test/resources/testfiles/documentIntrospected.txt";868			String eventJsonString = new String(Files.readAllBytes(Paths.get(testFilePath)));869			System.out.println("documentIntrospectedEventJsonString 1: " + eventJsonString);870			String transactionId = UUID.randomUUID().toString();871			echo("transactionId: " + transactionId);872			String payloadId = "Q14E-201912000000000"873					+ UUID.randomUUID().toString().replaceAll("[^0-9]", "").substring(0, 12);874			echo("payloadId: " + payloadId);875			eventJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, payloadId);876			System.out.println("documentIntrospectedEventJsonString 2: " + eventJsonString);877			ObjectMapper mapper = new ObjectMapper();878			DocumentEvent envelope = mapper.readValue(eventJsonString, DocumentEvent.class);879			send(sendMessageBuilder -> {880				sendMessageBuilder.endpoint(citrusKafkaEndpoint).message(new KafkaMessage(envelope)881						.topic("visibility.introspection.document").messageKey(transactionId));882			});883			receive(receiveMessageBuilder -> {884				receiveMessageBuilder.endpoint(documentKafkaEndpoint).messageType(MessageType.BINARY)885				.message(new KafkaMessage(envelope).messageKey(transactionId)).validationCallback(886						new JsonMappingValidationCallback<DocumentEvent>(DocumentEvent.class, mapper) {887							@Override888							public void validate(DocumentEvent payload, Map<String, Object> headers,889									TestContext context) {890								Assert.assertNotNull(payload);891								Assert.assertNotNull("missing transaction Id in the payload: ",892										payload.getTransactionId());893								Assert.assertNotNull("missing citrus_kafka_messageKey: ",894										String.valueOf(headers.get("citrus_kafka_messageKey")));895								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")),896										payload.getTransactionId(),897										"transactionid is not matching with kafka key");898								// Compare all properties899								String resultStr = TestHelper.haveSamePropertyValues(envelope, payload);900								echo("Validation Result: " + resultStr.toString());901								Boolean result = resultStr.isEmpty() ? true : false;902								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),903										"FileIntrospectedEvent properies not matched: " + resultStr);904							}905						});906			});907		} catch (IOException e) { // TODO Auto-generated catch block908			e.printStackTrace();909		}910	}911	@Test912	@CitrusTest913	public void process_ContentErrorEventIT() {914		try {915			String testFilePath = "src/test/resources/testfiles/contentError.txt";916			String eventJsonString = new String(Files.readAllBytes(Paths.get(testFilePath)));917			System.out.println("contentErrorEventJsonString 1: " + eventJsonString);918			String transactionId = UUID.randomUUID().toString();919			echo("transactionId: " + transactionId);920			eventJsonString = TestHelper.setVariableValues(eventJsonString, transactionId, "");921			System.out.println("contentErrorEventJsonString 2: " + eventJsonString);922			ObjectMapper mapper = new ObjectMapper();923			ContentErrorEvent envelope = mapper.readValue(eventJsonString, ContentErrorEvent.class);924			send(sendMessageBuilder -> {925				sendMessageBuilder.endpoint(citrusKafkaEndpoint).message(new KafkaMessage(envelope)926						.topic("visibility.introspection.contenterror").messageKey(transactionId));927			});928			receive(receiveMessageBuilder -> {929				receiveMessageBuilder.endpoint(contentErrorKafkacEndpoint).messageType(MessageType.BINARY)930				.message(new KafkaMessage(envelope).messageKey(transactionId)).validationCallback(931						new JsonMappingValidationCallback<ContentErrorEvent>(ContentErrorEvent.class, mapper) {932							@Override933							public void validate(ContentErrorEvent payload, Map<String, Object> headers,934									TestContext context) {935								Assert.assertNotNull(payload);936								Assert.assertNotNull("missing transaction Id in the payload: ",937										payload.getTransactionId());938								Assert.assertNotNull("missing citrus_kafka_messageKey: ",939										String.valueOf(headers.get("citrus_kafka_messageKey")));940								Assert.assertEquals(String.valueOf(headers.get("citrus_kafka_messageKey")),941										payload.getTransactionId(),942										"transactionid is not matching with kafka key");943								// Compare all properties944								String resultStr = TestHelper.haveSamePropertyValues(envelope, payload);945								echo("Validation Result: " + resultStr.toString());946								Boolean result = resultStr.isEmpty() ? true : false;947								Assert.assertEquals(Boolean.TRUE.toString(), result.toString(),948										"FileIntrospectedEvent properies not matched: " + resultStr);949							}950						});951			});952		} catch (IOException e) { // TODO Auto-generated catch block953			e.printStackTrace();954		}955	}956	public String writeJson(ReceiveCompletedEvent receiveEvent) throws IOException {957		abstract class IgnoreSchemaProperty {958			// You have to use the correct package for JsonIgnore,959			// fasterxml or codehaus960			@JsonIgnore961			abstract void getSchema();962		}963		ObjectMapper om = new ObjectMapper();964		om.enable(SerializationFeature.INDENT_OUTPUT);965		om.enable(SerializationFeature.WRITE_ENUMS_USING_INDEX);966		om.enable(DeserializationFeature.UNWRAP_SINGLE_VALUE_ARRAYS);967		om.enable(DeserializationFeature.ACCEPT_EMPTY_ARRAY_AS_NULL_OBJECT);968		om.addMixIn(ReceiveCompletedEvent.class, IgnoreSchemaProperty.class);969		String controlFileString = om.writer().writeValueAsString(receiveEvent);970		return controlFileString;971	}972	public String convertToJson(ReceiveCompletedEvent record) {973		try {974			ByteArrayOutputStream outputStream = new ByteArrayOutputStream();975			NoWrappingJsonEncoder jsonEncoder = new NoWrappingJsonEncoder(record.getSchema(), outputStream);976			DatumWriter<GenericRecord> writer = record instanceof SpecificRecord977					? new SpecificDatumWriter<>(record.getSchema())978							: new GenericDatumWriter<>(record.getSchema());979					writer.write(record, jsonEncoder);980					jsonEncoder.flush();981					return outputStream.toString();982		} catch (IOException e) {983			throw new ValidationException("Failed to convert to JSON.", e);984		}985	}986}...

Source:HttpActionBuilder.java

...194        }195        /**196         * Receive Http TRACE request as server.197         */198        public HttpServerRequestActionBuilder trace() {199            return new HttpServerRequestActionBuilder(delegate.trace());200        }201        /**202         * Receive Http TRACE request as server.203         */204        public HttpServerRequestActionBuilder trace(String path) {205            return new HttpServerRequestActionBuilder(delegate.trace(path));206        }207        /**208         * Receive Http PATCH request as server.209         */210        public HttpServerRequestActionBuilder patch() {211            return new HttpServerRequestActionBuilder(delegate.patch());212        }213        /**214         * Receive Http PATCH request as server.215         */216        public HttpServerRequestActionBuilder patch(String path) {217            return new HttpServerRequestActionBuilder(delegate.patch(path));218        }219    }220    public static class HttpClientActionBuilder implements TestActionBuilder.DelegatingTestActionBuilder<TestAction>, ReferenceResolverAware {221        private final com.consol.citrus.http.actions.HttpClientActionBuilder delegate;222        public HttpClientActionBuilder(com.consol.citrus.http.actions.HttpClientActionBuilder delegate) {223            this.delegate = delegate;224        }225        /**226         * Sends Http requests as client.227         */228        public HttpClientSendActionBuilder send() {229            return new HttpClientSendActionBuilder(delegate.send());230        }231        /**232         * Receives Http response messages as client.233         */234        public HttpClientReceiveActionBuilder receive() {235            return new HttpClientReceiveActionBuilder(delegate.receive());236        }237        /**238         * Sets the bean reference resolver.239         * @param referenceResolver240         */241        public HttpClientActionBuilder withReferenceResolver(ReferenceResolver referenceResolver) {242            delegate.withReferenceResolver(referenceResolver);243            return this;244        }245        @Override246        public void setReferenceResolver(ReferenceResolver referenceResolver) {247            delegate.setReferenceResolver(referenceResolver);248        }249        @Override250        public TestActionBuilder<?> getDelegate() {251            return delegate.getDelegate();252        }253        @Override254        public TestAction build() {255            return delegate.build();256        }257    }258    public static class HttpClientSendActionBuilder {259        private final com.consol.citrus.http.actions.HttpClientActionBuilder.HttpClientSendActionBuilder delegate;260        public HttpClientSendActionBuilder(com.consol.citrus.http.actions.HttpClientActionBuilder.HttpClientSendActionBuilder delegate) {261            this.delegate = delegate;262        }263        /**264         * Sends Http GET request as client to server.265         */266        public HttpClientRequestActionBuilder get() {267            return new HttpClientRequestActionBuilder(delegate.get());268        }269        /**270         * Sends Http GET request as client to server.271         */272        public HttpClientRequestActionBuilder get(String path) {273            return new HttpClientRequestActionBuilder(delegate.get(path));274        }275        /**276         * Sends Http POST request as client to server.277         */278        public HttpClientRequestActionBuilder post() {279            return new HttpClientRequestActionBuilder(delegate.post());280        }281        /**282         * Sends Http POST request as client to server.283         */284        public HttpClientRequestActionBuilder post(String path) {285            return new HttpClientRequestActionBuilder(delegate.post(path));286        }287        /**288         * Sends Http PUT request as client to server.289         */290        public HttpClientRequestActionBuilder put() {291            return new HttpClientRequestActionBuilder(delegate.put());292        }293        /**294         * Sends Http PUT request as client to server.295         */296        public HttpClientRequestActionBuilder put(String path) {297            return new HttpClientRequestActionBuilder(delegate.put(path));298        }299        /**300         * Sends Http DELETE request as client to server.301         */302        public HttpClientRequestActionBuilder delete() {303            return new HttpClientRequestActionBuilder(delegate.delete());304        }305        /**306         * Sends Http DELETE request as client to server.307         */308        public HttpClientRequestActionBuilder delete(String path) {309            return new HttpClientRequestActionBuilder(delegate.delete(path));310        }311        /**312         * Sends Http HEAD request as client to server.313         */314        public HttpClientRequestActionBuilder head() {315            return new HttpClientRequestActionBuilder(delegate.head());316        }317        /**318         * Sends Http HEAD request as client to server.319         */320        public HttpClientRequestActionBuilder head(String path) {321            return new HttpClientRequestActionBuilder(delegate.head(path));322        }323        /**324         * Sends Http OPTIONS request as client to server.325         */326        public HttpClientRequestActionBuilder options() {327            return new HttpClientRequestActionBuilder(delegate.options());328        }329        /**330         * Sends Http OPTIONS request as client to server.331         */332        public HttpClientRequestActionBuilder options(String path) {333            return new HttpClientRequestActionBuilder(delegate.options(path));334        }335        /**336         * Sends Http TRACE request as client to server.337         */338        public HttpClientRequestActionBuilder trace() {339            return new HttpClientRequestActionBuilder(delegate.trace());340        }341        /**342         * Sends Http TRACE request as client to server.343         */344        public HttpClientRequestActionBuilder trace(String path) {345            return new HttpClientRequestActionBuilder(delegate.trace(path));346        }347        /**348         * Sends Http PATCH request as client to server.349         */350        public HttpClientRequestActionBuilder patch() {351            return new HttpClientRequestActionBuilder(delegate.patch());352        }353        /**354         * Sends Http PATCH request as client to server.355         */356        public HttpClientRequestActionBuilder patch(String path) {357            return new HttpClientRequestActionBuilder(delegate.patch(path));358        }359    }...

Source:HttpServerActionBuilder.java

...188        }189        /**190         * Receive Http TRACE request as server.191         */192        public HttpServerRequestActionBuilder trace() {193            return request(HttpMethod.TRACE, null);194        }195        /**196         * Receive Http TRACE request as server.197         */198        public HttpServerRequestActionBuilder trace(String path) {199            return request(HttpMethod.TRACE, path);200        }201        /**202         * Receive Http PATCH request as server.203         */204        public HttpServerRequestActionBuilder patch() {205            return request(HttpMethod.PATCH, null);206        }207        /**208         * Receive Http PATCH request as server.209         */210        public HttpServerRequestActionBuilder patch(String path) {211            return request(HttpMethod.PATCH, path);212        }...

trace

Using AI Code Generation

1import com.consol.citrus.dsl.builder.HttpServerActionBuilder;2import com.consol.citrus.dsl.builder.HttpServerResponseActionBuilder;3import com.consol.citrus.dsl.runner.TestRunner;4import com.consol.citrus.http.message.HttpMessage;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.testng.CitrusParameters;7import com.consol.citrus.validation.json.JsonTextMessageValidationContext;8import com.consol.citrus.validation.script.GroovyJsonMessageValidationContext;9import com.consol.citrus.validation.xml.XmlTextMessageValidationContext;10import org.testng.annotations.Test;11import java.util.HashMap;12import java.util.Map;13public class 3 {14    public void 3() {15        TestRunner runner = TestRunner.create();16        runner.http(builder -> builder.server("httpServer")17                .receive()18                .post("/test")19                .payload("<TestRequest><Message>Hello Citrus!</Message></TestRequest>")20                .header("operation", "sayHello")21                .extractFromHeader("citrus_jms_messageId", "correlation_id")22                .extractFromPayload("/TestRequest/Message", "m

trace

Using AI Code Generation

1package org.citrusframework.demo;2import org.springframework.context.annotation.Bean;3import org.springframework.context.annotation.Configuration;4import org.springframework.context.annotation.Import;5import com.consol.citrus.dsl.design.TestDesigner;6import com.consol.citrus.dsl.design.TestDesignerBeforeSuiteSupport;7import com.consol.citrus.dsl.runner.TestRunner;8import com.consol.citrus.dsl.runner.TestRunnerBeforeSuiteSupport;9import com.consol.citrus.http.server.HttpServer;10import com.consol.citrus.http.server.HttpServerBuilder;11import com.consol.citrus.http.server.HttpServerConfiguration;12@Import({ com.consol.citrus.dsl.CitrusEndpoints.class})13public class CitrusConfig extends TestRunnerBeforeSuiteSupport {14    public HttpServer httpServer() {15        return CitrusEndpoints.http()16            .server()17            .port(8080)18            .autoStart(true)19            .build();20    }21}22package org.citrusframework.demo;23import org.springframework.context.annotation.Bean;24import org.springframework.context.annotation.Configuration;25import org.springframework.context.annotation.Import;26import com.consol.citrus.dsl.design.TestDesigner;27import com.consol.citrus.dsl.design.TestDesignerBeforeSuiteSupport;28import com.consol.citrus.dsl.runner.TestRunner;29import com.consol.citrus.dsl.runner.TestRunnerBeforeSuiteSupport;30import com.consol.citrus.http.config.annotation.HttpServerConfig;31import com.consol.citrus.http.server.HttpServer;32import com.consol.citrus.http.server.HttpServerBuilder;33import com.consol.citrus.http.server.HttpServerConfiguration;34@Import({ com.consol.citrus.dsl.CitrusEndpoints.class})35public class CitrusConfig extends TestRunnerBeforeSuiteSupport {36    @HttpServerConfig(port = 8080)37    public HttpServer httpServer() {38        return CitrusEndpoints.http()39            .server()40            .autoStart(true)41            .build();42    }43}44package org.citrusframework.demo;45import org.springframework.context.annotation.Bean;46import org.springframework.context.annotation.Configuration;47import org.springframework.context.annotation.Import;48import com.consol.citrus

trace

Using AI Code Generation

1public class 3 {2    public static void main(String[] args) {3        HttpServerBuilder httpServerBuilder = httpServer().port(8080);4        httpServerBuilder.autoStart(true);5        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());6        httpServerBuilder.autoStart(true);7        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());8        httpServerBuilder.timeout(60000);9        httpServerBuilder.autoStart(true);10        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());11        httpServerBuilder.autoStart(true);12        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());13        httpServerBuilder.timeout(60000);14        httpServerBuilder.autoStart(true);15        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());16        httpServerBuilder.timeout(60000);17        httpServerBuilder.autoStart(true);18        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());19        httpServerBuilder.timeout(60000);20        httpServerBuilder.autoStart(true);21        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());22        httpServerBuilder.timeout(60000);23        httpServerBuilder.autoStart(true);24        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());25        httpServerBuilder.timeout(60000);26        httpServerBuilder.autoStart(true);27        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());28        httpServerBuilder.timeout(60000);29        httpServerBuilder.autoStart(true);30        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());31        httpServerBuilder.timeout(60000);32        httpServerBuilder.autoStart(true);33        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());34        httpServerBuilder.timeout(60000);35        httpServerBuilder.autoStart(true);36        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());37        httpServerBuilder.timeout(60000);38        httpServerBuilder.autoStart(true);39        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());40        httpServerBuilder.timeout(60000);41        httpServerBuilder.autoStart(true);42        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());43        httpServerBuilder.timeout(60000);44        httpServerBuilder.autoStart(true);45        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());46        httpServerBuilder.timeout(60000);47        httpServerBuilder.autoStart(true);48        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());49        httpServerBuilder.autoStart(true);50        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint());51        httpServerBuilder.timeout(60000);52        httpServerBuilder.autoStart(true);53        httpServerBuilder.endpoint(httpServerBuilder.buildEndpoint

trace

Using AI Code Generation

1package com.consol.citrus.dsl.design;2import com.consol.citrus.dsl.design.TestDesigner;3import com.consol.citrus.dsl.design.TestDesignerBeforeTestSupport;4import com.consol.citrus.http.message.HttpMessage;5import com.consol.citrus.testng.spring.TestNGCitrusSpringSupport;6import org.springframework.beans.factory.annotation.Autowired;7import org.springframework.core.io.ClassPathResource;8import org.testng.annotations.Test;9public class 3 extends TestNGCitrusSpringSupport {10    private TestDesigner designer;11    public void 3() {12        designer.http()13                .server(designer.httpServerBuilder()14                        .port(8080)15                        .autoStart(true))16                .receive(designer.httpActionBuilder()17                        .post()18                        .message(designer.httpMessageBuilder()19                                .version("HTTP/1.1")20                                .contentType("text/plain")21                                .payload(new ClassPathResource("request.xml"))))22                .send(designer.httpActionBuilder()23                        .response(HttpMessage.OK)24                        .message(designer.httpMessageBuilder()25                                .version("HTTP/1.1")26                                .contentType("text/plain")27                                .payload(new ClassPathResource("response.xml"))))28                .trace();29    }30}31package com.consol.citrus.dsl.design;32import com.consol.citrus.dsl.design.TestDesigner;33import com.consol.citrus.dsl.design.TestDesignerBeforeTestSupport;34import com.consol.citrus.http.message.HttpMessage;35import com.consol.citrus.testng.spring.TestNGCitrusSpringSupport;36import org.springframework.beans.factory.annotation.Autowired;37import org.springframework.core.io.ClassPathResource;38import org.testng.annotations.Test;39public class 4 extends TestNGCitrusSpringSupport {40    private TestDesigner designer;41    public void 4() {42        designer.http()43                .server(designer.httpServerBuilder()44                        .port(8080)45                        .autoStart(true))

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.