How to use Consumer method of mock.contract.Consumer class

Best Karate code snippet using mock.contract.Consumer.Consumer

Source:ContractRegistryTests.java

...191		componentMock = new ComponentMock("Component 1");192193		ConnectorMock consumerMock;194		consumerMock =195				new ConnectorMock("Consumer 1", componentMock, ConnectorType.CONSUMER);196197		Contract contract;198		contract = this.createTestContract(TEST_CONTRACT_01);199200		ResourceManagerMock resourceManagerMock;201		resourceManagerMock = new ResourceManagerMock();202		ContractRegistry contractRegistry;203		contractRegistry =204				new ContractRegistry(resourceManagerMock, triggerRegistry);205206		/* Add the contract. */207		try {208			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,209					consumerMock, Role.CONSUMER);210		}211212		catch (TreatyException e) {213			fail("Unexpected TreatyException: " + e.getMessage());214		}215		// end catch.216217		assertFalse(contractRegistry.getContracts(consumerMock, Role.LEGISLATOR)218				.contains(contract));219		/* The registry should know the contract. */220		assertTrue(contractRegistry.getContracts(consumerMock, Role.CONSUMER)221				.contains(contract));222		/* The contract should have constraints. */223		assertFalse(contractRegistry.getContracts(consumerMock, Role.CONSUMER)224				.iterator().next().getConstraints().isEmpty());225		assertFalse(contractRegistry.getContracts(consumerMock, Role.SUPPLIER)226				.contains(contract));227228		/* The consumer should be set as consumer of the contract. */229		assertEquals(consumerMock, contractRegistry.getContracts(consumerMock,230				Role.CONSUMER).iterator().next().getConsumer());231232		/* Remove the contract. */233		try {234			contractRegistry.updateContract(UpdateType.REMOVE_CONTRACT, contract,235					consumerMock, Role.CONSUMER);236		}237238		catch (TreatyException e) {239			fail("Unexpected TreatyException: " + e.getMessage());240		}241		// end catch.242243		assertEquals(0, contractRegistry244				.getContracts(consumerMock, Role.LEGISLATOR).size());245		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.CONSUMER)246				.size());247		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.SUPPLIER)248				.size());249	}250251	/**252	 * <p>253	 * Tests the method254	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}255	 * by adding a {@link Role#CONSUMER} {@link Contract} with an256	 * {@link ConnectorType#SUPPLIER} to the {@link ContractRegistry}.257	 * </p>258	 */259	@Test260	public void testUpdateRegistry03() {261262		ComponentMock componentMock;263		componentMock = new ComponentMock("Component 1");264265		ConnectorMock supplierMock;266		supplierMock =267				new ConnectorMock("Supplier 1", componentMock, ConnectorType.SUPPLIER);268269		Contract contract;270		contract = this.createTestContract(TEST_CONTRACT_01);271272		ResourceManagerMock resourceManagerMock;273		resourceManagerMock = new ResourceManagerMock();274		ContractRegistry contractRegistry;275		contractRegistry =276				new ContractRegistry(resourceManagerMock, triggerRegistry);277278		/* Add the contract. */279		try {280			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,281					supplierMock, Role.CONSUMER);282			fail("Expected TreatyException was not thrown.");283		}284285		catch (TreatyException e) {286			/* Expected exception. */287		}288		// end catch.289	}290291	/**292	 * <p>293	 * Tests the method294	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}295	 * by adding and removing a {@link Role#SUPPLIER} {@link Contract} to the296	 * {@link ContractRegistry}.297	 * </p>298	 */299	@Test300	public void testUpdateRegistry04() {301302		ComponentMock componentMock;303		componentMock = new ComponentMock("Component 1");304305		ConnectorMock supplierMock;306		supplierMock =307				new ConnectorMock("Supplier 1", componentMock, ConnectorType.SUPPLIER);308309		Contract contract;310		contract = this.createTestContract(TEST_CONTRACT_01);311312		ResourceManagerMock resourceManagerMock;313		resourceManagerMock = new ResourceManagerMock();314		ContractRegistry contractRegistry;315		contractRegistry =316				new ContractRegistry(resourceManagerMock, triggerRegistry);317318		/* Add the contract. */319		try {320			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,321					supplierMock, Role.SUPPLIER);322		}323324		catch (TreatyException e) {325			fail("Unexpected TreatyException: " + e.getMessage());326		}327		// end catch.328329		assertFalse(contractRegistry.getContracts(supplierMock, Role.LEGISLATOR)330				.contains(contract));331		assertFalse(contractRegistry.getContracts(supplierMock, Role.CONSUMER)332				.contains(contract));333		/* The registry should know the contract. */334		assertTrue(contractRegistry.getContracts(supplierMock, Role.SUPPLIER)335				.contains(contract));336		/* The contract should have constraints. */337		assertFalse(contractRegistry.getContracts(supplierMock, Role.SUPPLIER)338				.iterator().next().getConstraints().isEmpty());339340		/* The supplier should be set as supplier of the contract. */341		assertEquals(supplierMock, contractRegistry.getContracts(supplierMock,342				Role.SUPPLIER).iterator().next().getSupplier());343344		/* Remove the contract. */345		try {346			contractRegistry.updateContract(UpdateType.REMOVE_CONTRACT, contract,347					supplierMock, Role.SUPPLIER);348		}349350		catch (TreatyException e) {351			fail("Unexpected TreatyException: " + e.getMessage());352		}353		// end catch.354355		assertEquals(0, contractRegistry356				.getContracts(supplierMock, Role.LEGISLATOR).size());357		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.CONSUMER)358				.size());359		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.SUPPLIER)360				.size());361	}362363	/**364	 * <p>365	 * Tests the method366	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}367	 * by adding a {@link Role#SUPPLIER} {@link Contract} with an368	 * {@link ConnectorType#CONSUMER} to the {@link ContractRegistry}.369	 * </p>370	 */371	@Test372	public void testUpdateRegistry05() {373374		ComponentMock componentMock;375		componentMock = new ComponentMock("Component 1");376377		ConnectorMock consumerMock;378		consumerMock =379				new ConnectorMock("Consumer 1", componentMock, ConnectorType.CONSUMER);380381		Contract contract;382		contract = this.createTestContract(TEST_CONTRACT_01);383384		ResourceManagerMock resourceManagerMock;385		resourceManagerMock = new ResourceManagerMock();386		ContractRegistry contractRegistry;387		contractRegistry =388				new ContractRegistry(resourceManagerMock, triggerRegistry);389390		/* Add the contract. */391		try {392			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,393					consumerMock, Role.SUPPLIER);394			fail("Expected TreatyException was not thrown.");395		}396397		catch (TreatyException e) {398			/* Expected exception. */399		}400		// end catch.401	}402403	/**404	 * <p>405	 * Tests the method406	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}407	 * by adding and removing a {@link Role#LEGISLATOR} and a408	 * {@link Role#CONSUMER} {@link Contract} to the {@link ContractRegistry}.409	 * </p>410	 */411	@Test412	public void testUpdateRegistry06() {413414		ComponentMock componentMock;415		componentMock = new ComponentMock("Component 1");416417		ConnectorMock legistlatorMock;418		legistlatorMock =419				new ConnectorMock("Legislator 1", componentMock, ConnectorType.SUPPLIER);420421		ConnectorMock consumerMock;422		consumerMock =423				new ConnectorMock("Consumer 1", componentMock, ConnectorType.CONSUMER);424425		Contract contract;426		contract = this.createTestContract(TEST_CONTRACT_01);427428		ResourceManagerMock resourceManagerMock;429		resourceManagerMock = new ResourceManagerMock();430		ContractRegistry contractRegistry;431		contractRegistry =432				new ContractRegistry(resourceManagerMock, triggerRegistry);433434		/* Add the legislator contract and the consumer contract. */435		try {436			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,437					legistlatorMock, Role.LEGISLATOR);438			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,439					consumerMock, Role.CONSUMER);440		}441442		catch (TreatyException e) {443			fail("Unexpected TreatyException: " + e.getMessage());444		}445		// end catch.446447		/* The registry should know the contract. */448		assertTrue(contractRegistry.getContracts(legistlatorMock, Role.LEGISLATOR)449				.contains(contract));450		/* The contract should have constraints. */451		assertFalse(contractRegistry.getContracts(legistlatorMock, Role.LEGISLATOR)452				.iterator().next().getConstraints().isEmpty());453454		assertFalse(contractRegistry.getContracts(consumerMock, Role.LEGISLATOR)455				.contains(contract));456457		assertFalse(contractRegistry.getContracts(legistlatorMock, Role.CONSUMER)458				.contains(contract));459460		/*461		 * The consumer's contract should have the legislator's contract as462		 * definition.463		 */464		assertEquals(contract, contractRegistry.getContracts(consumerMock,465				Role.CONSUMER).iterator().next().getDefinition());466467		/* The consumer's contract should have constraints. */468		assertFalse(contractRegistry.getContracts(consumerMock, Role.CONSUMER)469				.iterator().next().getConstraints().isEmpty());470471		/* Remove the contracts. */472		try {473			contractRegistry.updateContract(UpdateType.REMOVE_CONTRACT, contract,474					legistlatorMock, Role.LEGISLATOR);475		}476477		catch (TreatyException e) {478			fail("Unexpected TreatyException: " + e.getMessage());479		}480		// end catch.481482		assertEquals(0, contractRegistry.getContracts(legistlatorMock,483				Role.LEGISLATOR).size());484		assertEquals(0, contractRegistry.getContracts(legistlatorMock,485				Role.CONSUMER).size());486		assertEquals(0, contractRegistry.getContracts(legistlatorMock,487				Role.SUPPLIER).size());488489		assertEquals(0, contractRegistry490				.getContracts(consumerMock, Role.LEGISLATOR).size());491		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.CONSUMER)492				.size());493		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.SUPPLIER)494				.size());495	}496497	/**498	 * <p>499	 * Tests the method500	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}501	 * by adding and removing a {@link Role#LEGISLATOR} and a502	 * {@link Role#SUPPLIER} {@link Contract} to the {@link ContractRegistry}.503	 * </p>504	 */505	@Test506	public void testUpdateRegistry07() {507508		ComponentMock componentMock;509		componentMock = new ComponentMock("Component 1");510511		ConnectorMock legistlatorMock;512		legistlatorMock =513				new ConnectorMock("Legislator 1", componentMock, ConnectorType.SUPPLIER);514515		ConnectorMock supplierMock;516		supplierMock =517				new ConnectorMock("Supplier 1", componentMock, ConnectorType.SUPPLIER);518519		Contract contract;520		contract = this.createTestContract(TEST_CONTRACT_01);521522		ResourceManagerMock resourceManagerMock;523		resourceManagerMock = new ResourceManagerMock();524		ContractRegistry contractRegistry;525		contractRegistry =526				new ContractRegistry(resourceManagerMock, triggerRegistry);527528		/* Add the legislator contract and the supplier contract. */529		try {530			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,531					legistlatorMock, Role.LEGISLATOR);532			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,533					supplierMock, Role.SUPPLIER);534		}535536		catch (TreatyException e) {537			fail("Unexpected TreatyException: " + e.getMessage());538		}539		// end catch.540541		assertTrue(contractRegistry.getContracts(legistlatorMock, Role.LEGISLATOR)542				.contains(contract));543		assertFalse(contractRegistry.getContracts(supplierMock, Role.LEGISLATOR)544				.contains(contract));545		assertFalse(contractRegistry.getContracts(legistlatorMock, Role.CONSUMER)546				.contains(contract));547548		/*549		 * The supplier's contract should have the legislator's contract as550		 * definition.551		 */552		assertEquals(contract, contractRegistry.getContracts(supplierMock,553				Role.SUPPLIER).iterator().next().getDefinition());554555		/* The supplier's contract should have constraints. */556		assertFalse(contractRegistry.getContracts(supplierMock, Role.SUPPLIER)557				.iterator().next().getConstraints().isEmpty());558559		/* Remove the contracts. */560		try {561			contractRegistry.updateContract(UpdateType.REMOVE_CONTRACT, contract,562					legistlatorMock, Role.LEGISLATOR);563		}564565		catch (TreatyException e) {566			fail("Unexpected TreatyException: " + e.getMessage());567		}568		// end catch.569570		assertEquals(0, contractRegistry.getContracts(legistlatorMock,571				Role.LEGISLATOR).size());572		assertEquals(0, contractRegistry.getContracts(legistlatorMock,573				Role.CONSUMER).size());574		assertEquals(0, contractRegistry.getContracts(legistlatorMock,575				Role.SUPPLIER).size());576577		assertEquals(0, contractRegistry578				.getContracts(supplierMock, Role.LEGISLATOR).size());579		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.CONSUMER)580				.size());581		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.SUPPLIER)582				.size());583	}584585	/**586	 * <p>587	 * Tests the method588	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}589	 * by adding and removing a {@link Role#LEGISLATOR}, a {@link Role#CONSUMER}590	 * and a {@link Role#SUPPLIER} {@link Contract} to the591	 * {@link ContractRegistry}.592	 * </p>593	 */594	@Test595	public void testUpdateRegistry08() {596597		ComponentMock componentMock;598		componentMock = new ComponentMock("Component 1");599600		ConnectorMock legistlatorMock;601		legistlatorMock =602				new ConnectorMock("Legislator 1", componentMock, ConnectorType.SUPPLIER);603604		ConnectorMock consumerMock;605		consumerMock =606				new ConnectorMock("Consumer 1", componentMock, ConnectorType.CONSUMER);607608		ConnectorMock supplierMock;609		supplierMock =610				new ConnectorMock("Supplier 1", componentMock, ConnectorType.SUPPLIER);611612		Contract contract;613		contract = this.createTestContract(TEST_CONTRACT_01);614615		ResourceManagerMock resourceManagerMock;616		resourceManagerMock = new ResourceManagerMock();617		ContractRegistry contractRegistry;618		contractRegistry =619				new ContractRegistry(resourceManagerMock, triggerRegistry);620621		/*622		 * Add the legislator contract, the consumer contract and the supplier623		 * contract.624		 */625		try {626			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,627					legistlatorMock, Role.LEGISLATOR);628			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,629					consumerMock, Role.CONSUMER);630			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry631					.getContracts(consumerMock, Role.CONSUMER).iterator().next(),632					supplierMock, Role.SUPPLIER);633		}634635		catch (TreatyException e) {636			fail("Unexpected TreatyException: " + e.getMessage());637		}638		// end catch.639640		assertTrue(contractRegistry.getContracts(legistlatorMock, Role.LEGISLATOR)641				.contains(contract));642		assertFalse(contractRegistry.getContracts(consumerMock, Role.LEGISLATOR)643				.contains(contract));644		assertFalse(contractRegistry.getContracts(supplierMock, Role.LEGISLATOR)645				.contains(contract));646		assertFalse(contractRegistry.getContracts(legistlatorMock, Role.CONSUMER)647				.contains(contract));648649		/*650		 * The consumer's contract should have the legislator's contract as651		 * definition.652		 */653		assertEquals(contract, contractRegistry.getContracts(consumerMock,654				Role.CONSUMER).iterator().next().getDefinition());655656		/* The consumer's contract should have constraints. */657		assertFalse(contractRegistry.getContracts(consumerMock, Role.CONSUMER)658				.iterator().next().getConstraints().isEmpty());659660		/*661		 * The supplier's contract should have the consumer's contract as662		 * definition.663		 */664		assertEquals(contractRegistry.getContracts(consumerMock, Role.CONSUMER)665				.iterator().next(), contractRegistry.getContracts(supplierMock,666				Role.SUPPLIER).iterator().next().getDefinition());667668		/* The supplier's contract should have constraints. */669		assertFalse(contractRegistry.getContracts(supplierMock, Role.SUPPLIER)670				.iterator().next().getConstraints().isEmpty());671672		/* Remove the contracts. */673		try {674			contractRegistry.updateContract(UpdateType.REMOVE_CONTRACT, contract,675					legistlatorMock, Role.LEGISLATOR);676		}677678		catch (TreatyException e) {679			fail("Unexpected TreatyException: " + e.getMessage());680		}681		// end catch.682683		assertEquals(0, contractRegistry.getContracts(legistlatorMock,684				Role.LEGISLATOR).size());685		assertEquals(0, contractRegistry.getContracts(legistlatorMock,686				Role.CONSUMER).size());687		assertEquals(0, contractRegistry.getContracts(legistlatorMock,688				Role.SUPPLIER).size());689690		assertEquals(0, contractRegistry691				.getContracts(consumerMock, Role.LEGISLATOR).size());692		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.CONSUMER)693				.size());694		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.SUPPLIER)695				.size());696697		assertEquals(0, contractRegistry698				.getContracts(supplierMock, Role.LEGISLATOR).size());699		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.CONSUMER)700				.size());701		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.SUPPLIER)702				.size());703	}704705	/**706	 * <p>707	 * Tests the method708	 * {@link ContractRegistry#updateContract(net.java.treaty.contractregistry.ContractRegistry.UpdateType, net.java.treaty.Contract, net.java.treaty.Connector, net.java.treaty.Role)}709	 * by adding and removing a {@link Role#LEGISLATOR}, a {@link Role#CONSUMER}710	 * and a {@link Role#SUPPLIER} {@link Contract} to the711	 * {@link ContractRegistry}.712	 * </p>713	 */714	@Test715	public void testUpdateRegistry09() {716717		ComponentMock componentMock;718		componentMock = new ComponentMock("Component 1");719720		ConnectorMock legistlatorMock;721		legistlatorMock =722				new ConnectorMock("Legislator 1", componentMock, ConnectorType.SUPPLIER);723724		ConnectorMock consumerMock;725		consumerMock =726				new ConnectorMock("Consumer 1", componentMock, ConnectorType.CONSUMER);727728		ConnectorMock supplierMock;729		supplierMock =730				new ConnectorMock("Supplier 1", componentMock, ConnectorType.SUPPLIER);731732		Contract contract;733		contract = this.createTestContract(TEST_CONTRACT_01);734735		ResourceManagerMock resourceManagerMock;736		resourceManagerMock = new ResourceManagerMock();737		ContractRegistry contractRegistry;738		contractRegistry =739				new ContractRegistry(resourceManagerMock, triggerRegistry);740741		/*742		 * Add the legislator contract, the consumer contract and the supplier743		 * contract.744		 */745		try {746			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,747					legistlatorMock, Role.LEGISLATOR);748			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,749					supplierMock, Role.SUPPLIER);750			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry751					.getContracts(supplierMock, Role.SUPPLIER).iterator().next(),752					consumerMock, Role.CONSUMER);753		}754755		catch (TreatyException e) {756			fail("Unexpected TreatyException: " + e.getMessage());757		}758		// end catch.759760		assertTrue(contractRegistry.getContracts(legistlatorMock, Role.LEGISLATOR)761				.contains(contract));762		assertFalse(contractRegistry.getContracts(consumerMock, Role.LEGISLATOR)763				.contains(contract));764		assertFalse(contractRegistry.getContracts(supplierMock, Role.LEGISLATOR)765				.contains(contract));766		assertFalse(contractRegistry.getContracts(legistlatorMock, Role.SUPPLIER)767				.contains(contract));768769		/*770		 * The supplier's contract should have the legislator's contract as771		 * definition.772		 */773		assertEquals(contract, contractRegistry.getContracts(supplierMock,774				Role.SUPPLIER).iterator().next().getDefinition());775776		/* The supplier's contract should have constraints. */777		assertFalse(contractRegistry.getContracts(supplierMock, Role.SUPPLIER)778				.iterator().next().getConstraints().isEmpty());779780		/*781		 * The consumer's contract should have the supplier's contract as782		 * definition.783		 */784		assertEquals(contractRegistry.getContracts(supplierMock, Role.SUPPLIER)785				.iterator().next(), contractRegistry.getContracts(consumerMock,786				Role.CONSUMER).iterator().next().getDefinition());787788		/* The consumer's contract should have constraints. */789		assertFalse(contractRegistry.getContracts(consumerMock, Role.CONSUMER)790				.iterator().next().getConstraints().isEmpty());791792		/* Remove the contracts. */793		try {794			contractRegistry.updateContract(UpdateType.REMOVE_CONTRACT, contract,795					legistlatorMock, Role.LEGISLATOR);796		}797798		catch (TreatyException e) {799			fail("Unexpected TreatyException: " + e.getMessage());800		}801		// end catch.802803		assertEquals(0, contractRegistry.getContracts(legistlatorMock,804				Role.LEGISLATOR).size());805		assertEquals(0, contractRegistry.getContracts(legistlatorMock,806				Role.CONSUMER).size());807		assertEquals(0, contractRegistry.getContracts(legistlatorMock,808				Role.SUPPLIER).size());809810		assertEquals(0, contractRegistry811				.getContracts(consumerMock, Role.LEGISLATOR).size());812		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.CONSUMER)813				.size());814		assertEquals(0, contractRegistry.getContracts(consumerMock, Role.SUPPLIER)815				.size());816817		assertEquals(0, contractRegistry818				.getContracts(supplierMock, Role.LEGISLATOR).size());819		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.CONSUMER)820				.size());821		assertEquals(0, contractRegistry.getContracts(supplierMock, Role.SUPPLIER)822				.size());823	}824825	/**826	 * <p>827	 * Tests the method828	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}829	 * .830	 * </p>831	 */832	@Test833	public void testGetAffectedContracts01() throws TreatyException {834835		ComponentMock consumerComponentMock;836		consumerComponentMock = new ComponentMock("Consumer Component 1");837838		ComponentMock supplier1ComponentMock;839		supplier1ComponentMock = new ComponentMock("Supplier Component 1");840841		ComponentMock supplier2ComponentMock;842		supplier2ComponentMock = new ComponentMock("Supplier Component 2");843844		ConnectorMock consumerMock;845		consumerMock =846				new ConnectorMock("Consumer 1", consumerComponentMock,847						ConnectorType.CONSUMER);848849		ConnectorMock supplierMock1;850		supplierMock1 =851				new ConnectorMock("Supplier 1", supplier1ComponentMock,852						ConnectorType.SUPPLIER);853854		ConnectorMock supplierMock2;855		supplierMock2 =856				new ConnectorMock("Supplier 2", supplier2ComponentMock,857						ConnectorType.SUPPLIER);858859		Contract contract;860		contract = this.createTestContract(TEST_CONTRACT_01);861862		ResourceManagerMock resourceManagerMock;863		resourceManagerMock = new ResourceManagerMock();864		ContractRegistry contractRegistry;865		contractRegistry =866				new ContractRegistry(resourceManagerMock, triggerRegistry);867868		/* Add the consumer contract. */869		try {870			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,871					consumerMock, Role.CONSUMER);872		}873874		catch (TreatyException e) {875			fail("Unexpected TreatyException: " + e.getMessage());876		}877		// end catch.878879		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,880				consumerComponentMock).size());881		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,882				supplier1ComponentMock).size());883		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,884				supplier2ComponentMock).size());885886		/* Add a supplier contract. */887		try {888			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,889					supplierMock1, Role.SUPPLIER);890		}891892		catch (TreatyException e) {893			fail("Unexpected TreatyException: " + e.getMessage());894		}895		// end catch.896897		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,898				consumerComponentMock).size());899		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,900				supplier1ComponentMock).size());901		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,902				supplier2ComponentMock).size());903904		/* Add a supplier contract. */905		try {906			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,907					supplierMock2, Role.SUPPLIER);908		}909910		catch (TreatyException e) {911			fail("Unexpected TreatyException: " + e.getMessage());912		}913		// end catch.914915		assertEquals(2, contractRegistry.getAffectedContracts(trigger1,916				consumerComponentMock).size());917		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,918				supplier1ComponentMock).size());919		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,920				supplier2ComponentMock).size());921	}922923	/**924	 * <p>925	 * Tests the method926	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}927	 * .928	 * </p>929	 */930	@Test931	public void testGetAffectedContracts02() throws TreatyException {932933		ComponentMock consumer1ComponentMock;934		consumer1ComponentMock = new ComponentMock("Consumer Component 1");935936		ComponentMock consumer2ComponentMock;937		consumer2ComponentMock = new ComponentMock("Consumer Component 2");938939		ComponentMock supplier1ComponentMock;940		supplier1ComponentMock = new ComponentMock("Supplier Component 1");941942		ConnectorMock consumerMock1;943		consumerMock1 =944				new ConnectorMock("Consumer 1", consumer1ComponentMock,945						ConnectorType.CONSUMER);946947		ConnectorMock consumerMock2;948		consumerMock2 =949				new ConnectorMock("Consumer 2", consumer2ComponentMock,950						ConnectorType.CONSUMER);951952		ConnectorMock supplierMock1;953		supplierMock1 =954				new ConnectorMock("Supplier 1", supplier1ComponentMock,955						ConnectorType.SUPPLIER);956957		Contract contract;958		contract = this.createTestContract(TEST_CONTRACT_01);959960		ResourceManagerMock resourceManagerMock;961		resourceManagerMock = new ResourceManagerMock();962		ContractRegistry contractRegistry;963		contractRegistry =964				new ContractRegistry(resourceManagerMock, triggerRegistry);965966		/* Add the supplier contract. */967		try {968			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,969					supplierMock1, Role.SUPPLIER);970		}971972		catch (TreatyException e) {973			fail("Unexpected TreatyException: " + e.getMessage());974		}975		// end catch.976977		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,978				consumer1ComponentMock).size());979		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,980				supplier1ComponentMock).size());981		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,982				consumer2ComponentMock).size());983984		/* Add a consumer contract. */985		try {986			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,987					consumerMock1, Role.CONSUMER);988		}989990		catch (TreatyException e) {991			fail("Unexpected TreatyException: " + e.getMessage());992		}993		// end catch.994995		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,996				consumer1ComponentMock).size());997		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,998				supplier1ComponentMock).size());999		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1000				consumer2ComponentMock).size());10011002		/* Add a consumer contract. */1003		try {1004			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1005					consumerMock2, Role.CONSUMER);1006		}10071008		catch (TreatyException e) {1009			fail("Unexpected TreatyException: " + e.getMessage());1010		}1011		// end catch.10121013		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1014				consumer1ComponentMock).size());1015		assertEquals(2, contractRegistry.getAffectedContracts(trigger1,1016				supplier1ComponentMock).size());1017		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1018				consumer2ComponentMock).size());1019	}10201021	/**1022	 * <p>1023	 * Tests the method1024	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}1025	 * .1026	 * </p>1027	 */1028	@Test1029	public void testGetAffectedContracts03() throws TreatyException {10301031		ComponentMock legislator1ComponentMock;1032		legislator1ComponentMock = new ComponentMock("Legislator Component 1");10331034		ComponentMock consumer1ComponentMock;1035		consumer1ComponentMock = new ComponentMock("Consumer Component 1");10361037		ComponentMock supplier1ComponentMock;1038		supplier1ComponentMock = new ComponentMock("Supplier Component 1");10391040		ComponentMock supplier2ComponentMock;1041		supplier2ComponentMock = new ComponentMock("Supplier Component 2");10421043		ConnectorMock legislator1Mock;1044		legislator1Mock =1045				new ConnectorMock("Legislator 1", legislator1ComponentMock,1046						ConnectorType.CONSUMER);10471048		ConnectorMock consumer1Mock;1049		consumer1Mock =1050				new ConnectorMock("Consumer 1", consumer1ComponentMock,1051						ConnectorType.CONSUMER);10521053		ConnectorMock supplierMock1;1054		supplierMock1 =1055				new ConnectorMock("Supplier 1", supplier1ComponentMock,1056						ConnectorType.SUPPLIER);10571058		ConnectorMock supplierMock2;1059		supplierMock2 =1060				new ConnectorMock("Supplier 2", supplier2ComponentMock,1061						ConnectorType.SUPPLIER);10621063		Contract contract;1064		contract = this.createTestContract(TEST_CONTRACT_01);10651066		ResourceManagerMock resourceManagerMock;1067		resourceManagerMock = new ResourceManagerMock();1068		ContractRegistry contractRegistry;1069		contractRegistry =1070				new ContractRegistry(resourceManagerMock, triggerRegistry);10711072		/* Add the legislator contract. */1073		try {1074			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1075					legislator1Mock, Role.LEGISLATOR);1076		}10771078		catch (TreatyException e) {1079			fail("Unexpected TreatyException: " + e.getMessage());1080		}1081		// end catch.10821083		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1084				legislator1ComponentMock).size());1085		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1086				consumer1ComponentMock).size());1087		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1088				supplier1ComponentMock).size());1089		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1090				supplier2ComponentMock).size());10911092		/* Add the consumer contract. */1093		try {1094			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1095					consumer1Mock, Role.CONSUMER);1096		}10971098		catch (TreatyException e) {1099			fail("Unexpected TreatyException: " + e.getMessage());1100		}1101		// end catch.11021103		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1104				legislator1ComponentMock).size());1105		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1106				consumer1ComponentMock).size());1107		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1108				supplier1ComponentMock).size());1109		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1110				supplier2ComponentMock).size());11111112		/* Add a supplier contract. */1113		try {1114			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry1115					.getContracts(consumer1Mock, Role.CONSUMER).iterator().next(),1116					supplierMock1, Role.SUPPLIER);1117		}11181119		catch (TreatyException e) {1120			fail("Unexpected TreatyException: " + e.getMessage());1121		}1122		// end catch.11231124		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1125				legislator1ComponentMock).size());1126		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1127				consumer1ComponentMock).size());1128		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1129				supplier1ComponentMock).size());1130		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1131				supplier2ComponentMock).size());11321133		/* Add a supplier contract. */1134		try {1135			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry1136					.getContracts(consumer1Mock, Role.CONSUMER).iterator().next(),1137					supplierMock2, Role.SUPPLIER);1138		}11391140		catch (TreatyException e) {1141			fail("Unexpected TreatyException: " + e.getMessage());1142		}1143		// end catch.11441145		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1146				legislator1ComponentMock).size());1147		assertEquals(2, contractRegistry.getAffectedContracts(trigger1,1148				consumer1ComponentMock).size());1149		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1150				supplier1ComponentMock).size());1151		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1152				supplier2ComponentMock).size());1153	}11541155	/**1156	 * <p>1157	 * Tests the method1158	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}1159	 * .1160	 * </p>1161	 */1162	@Test1163	public void testGetAffectedContracts04() throws TreatyException {11641165		ComponentMock legislator1ComponentMock;1166		legislator1ComponentMock = new ComponentMock("Legislator Component 1");11671168		ComponentMock consumer1ComponentMock;1169		consumer1ComponentMock = new ComponentMock("Consumer Component 1");11701171		ComponentMock consumer2ComponentMock;1172		consumer2ComponentMock = new ComponentMock("Consumer Component 2");11731174		ComponentMock supplier1ComponentMock;1175		supplier1ComponentMock = new ComponentMock("Supplier Component 1");11761177		ConnectorMock legislator1Mock;1178		legislator1Mock =1179				new ConnectorMock("Legislator 1", legislator1ComponentMock,1180						ConnectorType.CONSUMER);11811182		ConnectorMock consumerMock1;1183		consumerMock1 =1184				new ConnectorMock("Consumer 1", consumer1ComponentMock,1185						ConnectorType.CONSUMER);11861187		ConnectorMock consumerMock2;1188		consumerMock2 =1189				new ConnectorMock("Consumer 2", consumer2ComponentMock,1190						ConnectorType.CONSUMER);11911192		ConnectorMock supplierMock1;1193		supplierMock1 =1194				new ConnectorMock("Supplier 1", supplier1ComponentMock,1195						ConnectorType.SUPPLIER);11961197		Contract contract;1198		contract = this.createTestContract(TEST_CONTRACT_01);11991200		ResourceManagerMock resourceManagerMock;1201		resourceManagerMock = new ResourceManagerMock();1202		ContractRegistry contractRegistry;1203		contractRegistry =1204				new ContractRegistry(resourceManagerMock, triggerRegistry);12051206		/* Add the legislator contract. */1207		try {1208			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1209					legislator1Mock, Role.LEGISLATOR);1210		}12111212		catch (TreatyException e) {1213			fail("Unexpected TreatyException: " + e.getMessage());1214		}1215		// end catch.12161217		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1218				legislator1ComponentMock).size());1219		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1220				supplier1ComponentMock).size());1221		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1222				consumer1ComponentMock).size());1223		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1224				consumer2ComponentMock).size());12251226		/* Add the supplier contract. */1227		try {1228			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1229					supplierMock1, Role.SUPPLIER);1230		}12311232		catch (TreatyException e) {1233			fail("Unexpected TreatyException: " + e.getMessage());1234		}1235		// end catch.12361237		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1238				legislator1ComponentMock).size());1239		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1240				supplier1ComponentMock).size());1241		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1242				consumer1ComponentMock).size());1243		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1244				consumer2ComponentMock).size());12451246		/* Add a consumer contract. */1247		try {1248			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry1249					.getContracts(supplierMock1, Role.SUPPLIER).iterator().next(),1250					consumerMock1, Role.CONSUMER);1251		}12521253		catch (TreatyException e) {1254			fail("Unexpected TreatyException: " + e.getMessage());1255		}1256		// end catch.12571258		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1259				legislator1ComponentMock).size());1260		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1261				supplier1ComponentMock).size());1262		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1263				consumer1ComponentMock).size());1264		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1265				consumer2ComponentMock).size());12661267		/* Add a consumer contract. */1268		try {1269			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry1270					.getContracts(supplierMock1, Role.SUPPLIER).iterator().next(),1271					consumerMock2, Role.CONSUMER);1272		}12731274		catch (TreatyException e) {1275			fail("Unexpected TreatyException: " + e.getMessage());1276		}1277		// end catch.12781279		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1280				legislator1ComponentMock).size());1281		assertEquals(2, contractRegistry.getAffectedContracts(trigger1,1282				supplier1ComponentMock).size());1283		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1284				consumer1ComponentMock).size());1285		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1286				consumer2ComponentMock).size());1287	}12881289	/**1290	 * <p>1291	 * Tests the method1292	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}1293	 * .1294	 * </p>1295	 */1296	@Test1297	public void testGetAffectedContracts05() throws TreatyException {12981299		ComponentMock consumerComponentMock;1300		consumerComponentMock = new ComponentMock("Consumer Component 1");13011302		ComponentMock supplier1ComponentMock;1303		supplier1ComponentMock = new ComponentMock("Supplier Component 1");13041305		ComponentMock supplier2ComponentMock;1306		supplier2ComponentMock = new ComponentMock("Supplier Component 2");13071308		ConnectorMock consumerMock;1309		consumerMock =1310				new ConnectorMock("Consumer 1", consumerComponentMock,1311						ConnectorType.CONSUMER);13121313		ConnectorMock supplierMock1;1314		supplierMock1 =1315				new ConnectorMock("Supplier 1", supplier1ComponentMock,1316						ConnectorType.SUPPLIER);13171318		ConnectorMock supplierMock2;1319		supplierMock2 =1320				new ConnectorMock("Supplier 2", supplier2ComponentMock,1321						ConnectorType.SUPPLIER);13221323		Contract contract;1324		contract = this.createTestContract(TEST_CONTRACT_01);13251326		ResourceManagerMock resourceManagerMock;1327		resourceManagerMock = new ResourceManagerMock();1328		ContractRegistry contractRegistry;1329		contractRegistry =1330				new ContractRegistry(resourceManagerMock, triggerRegistry);13311332		/* Add the consumer contract. */1333		try {1334			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1335					consumerMock, Role.CONSUMER);1336		}13371338		catch (TreatyException e) {1339			fail("Unexpected TreatyException: " + e.getMessage());1340		}1341		// end catch.13421343		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1344				consumerComponentMock).size());1345		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1346				supplier1ComponentMock).size());1347		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1348				supplier2ComponentMock).size());1349		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1350				consumerComponentMock).size());1351		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1352				supplier1ComponentMock).size());1353		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1354				supplier2ComponentMock).size());13551356		/* Add a supplier contract. */1357		try {1358			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1359					supplierMock1, Role.SUPPLIER);1360		}13611362		catch (TreatyException e) {1363			fail("Unexpected TreatyException: " + e.getMessage());1364		}1365		// end catch.13661367		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1368				consumerComponentMock).size());1369		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1370				supplier1ComponentMock).size());1371		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1372				supplier2ComponentMock).size());1373		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1374				consumerComponentMock).size());1375		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1376				supplier1ComponentMock).size());1377		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1378				supplier2ComponentMock).size());13791380		/* Add a supplier contract. */1381		try {1382			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1383					supplierMock2, Role.SUPPLIER);1384		}13851386		catch (TreatyException e) {1387			fail("Unexpected TreatyException: " + e.getMessage());1388		}1389		// end catch.13901391		assertEquals(2, contractRegistry.getAffectedContracts(trigger1,1392				consumerComponentMock).size());1393		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1394				supplier1ComponentMock).size());1395		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1396				supplier2ComponentMock).size());1397		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1398				consumerComponentMock).size());1399		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1400				supplier1ComponentMock).size());1401		assertEquals(0, contractRegistry.getAffectedContracts(trigger2,1402				supplier2ComponentMock).size());1403	}14041405	/**1406	 * <p>1407	 * Tests the method1408	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}1409	 * .1410	 * </p>1411	 * 1412	 * <p>1413	 * Tests the method using a trigger that is defined as default trigger and1414	 * thus must not be defined in the {@link Contract}.1415	 * </p>1416	 */1417	@Test1418	public void testGetAffectedContracts06() throws TreatyException {14191420		ComponentMock consumerComponentMock;1421		consumerComponentMock = new ComponentMock("Consumer Component 1");14221423		ComponentMock supplier1ComponentMock;1424		supplier1ComponentMock = new ComponentMock("Supplier Component 1");14251426		ComponentMock supplier2ComponentMock;1427		supplier2ComponentMock = new ComponentMock("Supplier Component 2");14281429		ConnectorMock consumerMock;1430		consumerMock =1431				new ConnectorMock("Consumer 1", consumerComponentMock,1432						ConnectorType.CONSUMER);14331434		ConnectorMock supplierMock1;1435		supplierMock1 =1436				new ConnectorMock("Supplier 1", supplier1ComponentMock,1437						ConnectorType.SUPPLIER);14381439		ConnectorMock supplierMock2;1440		supplierMock2 =1441				new ConnectorMock("Supplier 2", supplier2ComponentMock,1442						ConnectorType.SUPPLIER);14431444		Contract contract;1445		contract = this.createTestContract(TEST_CONTRACT_01);14461447		ResourceManagerMock resourceManagerMock;1448		resourceManagerMock = new ResourceManagerMock();1449		ContractRegistry contractRegistry;1450		contractRegistry =1451				new ContractRegistry(resourceManagerMock, triggerRegistry);14521453		/* Add the consumer contract. */1454		try {1455			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1456					consumerMock, Role.CONSUMER);1457		}14581459		catch (TreatyException e) {1460			fail("Unexpected TreatyException: " + e.getMessage());1461		}1462		// end catch.14631464		assertEquals(0, contractRegistry.getAffectedContracts(defaultTrigger,1465				consumerComponentMock).size());1466		assertEquals(0, contractRegistry.getAffectedContracts(defaultTrigger,1467				supplier1ComponentMock).size());1468		assertEquals(0, contractRegistry.getAffectedContracts(defaultTrigger,1469				supplier2ComponentMock).size());14701471		/* Add a supplier contract. */1472		try {1473			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1474					supplierMock1, Role.SUPPLIER);1475		}14761477		catch (TreatyException e) {1478			fail("Unexpected TreatyException: " + e.getMessage());1479		}1480		// end catch.14811482		assertEquals(1, contractRegistry.getAffectedContracts(defaultTrigger,1483				consumerComponentMock).size());1484		assertEquals(1, contractRegistry.getAffectedContracts(defaultTrigger,1485				supplier1ComponentMock).size());1486		assertEquals(0, contractRegistry.getAffectedContracts(defaultTrigger,1487				supplier2ComponentMock).size());14881489		/* Add a supplier contract. */1490		try {1491			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1492					supplierMock2, Role.SUPPLIER);1493		}14941495		catch (TreatyException e) {1496			fail("Unexpected TreatyException: " + e.getMessage());1497		}1498		// end catch.14991500		assertEquals(2, contractRegistry.getAffectedContracts(defaultTrigger,1501				consumerComponentMock).size());1502		assertEquals(1, contractRegistry.getAffectedContracts(defaultTrigger,1503				supplier1ComponentMock).size());1504		assertEquals(1, contractRegistry.getAffectedContracts(defaultTrigger,1505				supplier2ComponentMock).size());1506	}15071508	/**1509	 * <p>1510	 * Tests the method1511	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}1512	 * .1513	 * </p>1514	 * 1515	 * <p>1516	 * Tests the method using a trigger that is not defined in the1517	 * {@link Contract} but has a super trigger that is defined in the1518	 * {@link Contract}.1519	 * </p>1520	 */1521	@Test1522	public void testGetAffectedContracts07() throws TreatyException {15231524		ComponentMock consumerComponentMock;1525		consumerComponentMock = new ComponentMock("Consumer Component 1");15261527		ComponentMock supplier1ComponentMock;1528		supplier1ComponentMock = new ComponentMock("Supplier Component 1");15291530		ComponentMock supplier2ComponentMock;1531		supplier2ComponentMock = new ComponentMock("Supplier Component 2");15321533		ConnectorMock consumerMock;1534		consumerMock =1535				new ConnectorMock("Consumer 1", consumerComponentMock,1536						ConnectorType.CONSUMER);15371538		ConnectorMock supplierMock1;1539		supplierMock1 =1540				new ConnectorMock("Supplier 1", supplier1ComponentMock,1541						ConnectorType.SUPPLIER);15421543		ConnectorMock supplierMock2;1544		supplierMock2 =1545				new ConnectorMock("Supplier 2", supplier2ComponentMock,1546						ConnectorType.SUPPLIER);15471548		Contract contract;1549		contract = this.createTestContract(TEST_CONTRACT_02);15501551		ResourceManagerMock resourceManagerMock;1552		resourceManagerMock = new ResourceManagerMock();1553		ContractRegistry contractRegistry;1554		contractRegistry =1555				new ContractRegistry(resourceManagerMock, triggerRegistry);15561557		/* Add the consumer contract. */1558		try {1559			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1560					consumerMock, Role.CONSUMER);1561		}15621563		catch (TreatyException e) {1564			fail("Unexpected TreatyException: " + e.getMessage());1565		}1566		// end catch.15671568		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1569				consumerComponentMock).size());1570		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1571				supplier1ComponentMock).size());1572		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1573				supplier2ComponentMock).size());15741575		/* Add a supplier contract. */1576		try {1577			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1578					supplierMock1, Role.SUPPLIER);1579		}15801581		catch (TreatyException e) {1582			fail("Unexpected TreatyException: " + e.getMessage());1583		}1584		// end catch.15851586		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1587				consumerComponentMock).size());1588		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1589				supplier1ComponentMock).size());1590		assertEquals(0, contractRegistry.getAffectedContracts(trigger1,1591				supplier2ComponentMock).size());15921593		/* Add a supplier contract. */1594		try {1595			contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,1596					supplierMock2, Role.SUPPLIER);1597		}15981599		catch (TreatyException e) {1600			fail("Unexpected TreatyException: " + e.getMessage());1601		}1602		// end catch.16031604		assertEquals(2, contractRegistry.getAffectedContracts(trigger1,1605				consumerComponentMock).size());1606		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1607				supplier1ComponentMock).size());1608		assertEquals(1, contractRegistry.getAffectedContracts(trigger1,1609				supplier2ComponentMock).size());1610	}16111612	/**1613	 * <p>1614	 * Tests the method1615	 * {@link ContractRegistry#getAffectedContracts(net.java.treaty.event.LifeCycleEvent)}1616	 * .1617	 * </p>1618	 * 1619	 * <p>1620	 * Tests the method using a trigger that is not defined in the1621	 * {@link Contract} but is a super trigger of the trigger that is defined in1622	 * the {@link Contract}.1623	 * </p>1624	 */1625	@Test1626	public void testGetAffectedContracts08() throws TreatyException {16271628		ComponentMock consumerComponentMock;1629		consumerComponentMock = new ComponentMock("Consumer Component 1");16301631		ComponentMock supplier1ComponentMock;1632		supplier1ComponentMock = new ComponentMock("Supplier Component 1");16331634		ComponentMock supplier2ComponentMock;1635		supplier2ComponentMock = new ComponentMock("Supplier Component 2");16361637		ConnectorMock consumerMock;1638		consumerMock =1639				new ConnectorMock("Consumer 1", consumerComponentMock,1640						ConnectorType.CONSUMER);16411642		ConnectorMock supplierMock1;1643		supplierMock1 =1644				new ConnectorMock("Supplier 1", supplier1ComponentMock,1645						ConnectorType.SUPPLIER);16461647		ConnectorMock supplierMock2;1648		supplierMock2 =1649				new ConnectorMock("Supplier 2", supplier2ComponentMock,1650						ConnectorType.SUPPLIER);16511652		Contract contract;1653		contract = this.createTestContract(TEST_CONTRACT_01);
...

Source:ContractNegotiationIntegrationTest.java

...259        consumerNegotiationId = null;260        // Create an initial contract offer and two counter offers261        ContractOffer initialOffer = getContractOffer();262        ContractOffer counterOffer = getCounterOffer();263        ContractOffer consumerCounterOffer = getConsumerCounterOffer();264        // Mock validation of initial offer on provider side => counter offer265        when(validationService.validate(token, initialOffer)).thenReturn(Result.success(null));266        //Mock validation of counter offer on consumer side => counter offer267        when(validationService.validate(token, counterOffer, initialOffer)).thenReturn(Result.success(null));268        //Mock validation of second counter offer on provider side => accept269        when(validationService.validate(token, consumerCounterOffer, counterOffer)).thenReturn(Result.success(null));270        // Mock validation of agreement on consumer side271        when(validationService.validate(eq(token), any(ContractAgreement.class),272                eq(consumerCounterOffer))).thenReturn(true);273        // Create and register listeners for provider and consumer274        providerObservable.registerListener(negotiationListenerMock);275        consumerObservable.registerListener(negotiationListenerMock);276        // Start provider and consumer negotiation managers277        providerManager.start();278        consumerManager.start();279        // Create an initial request and trigger consumer manager280        ContractOfferRequest request = ContractOfferRequest.Builder.newInstance()281                .connectorId("connectorId")282                .connectorAddress("connectorAddress")283                .contractOffer(initialOffer)284                .protocol("protocol")285                .build();286        consumerManager.initiate(request);287        // Wait for negotiation to finish with time out at 15 seconds288        await().atMost(DEFAULT_TEST_TIMEOUT)289                .pollInterval(DEFAULT_POLL_INTERVAL)290                .untilAsserted(() -> {291                    var consumerNegotiation = consumerStore.find(consumerNegotiationId);292                    var providerNegotiation = providerStore.findForCorrelationId(consumerNegotiationId);293                    // Assert that provider and consumer have the same number of offers stored294                    assertNegotiations(consumerNegotiation, providerNegotiation, 3);295                    // Assert that initial offer is the same296                    assertThat(consumerNegotiation.getContractOffers().get(0)).isEqualTo(providerNegotiation.getContractOffers().get(0));297                    // Assert that first counter offer is the same298                    assertThat(consumerNegotiation.getContractOffers().get(1)).isEqualTo(providerNegotiation.getContractOffers().get(1));299                    // Assert that second counter offer is the same300                    assertThat(consumerNegotiation.getLastContractOffer()).isEqualTo(providerNegotiation.getLastContractOffer());301                    // Assert that same agreement is stored on both sides302                    assertThat(consumerNegotiation.getContractAgreement()).isNotNull();303                    assertThat(consumerNegotiation.getContractAgreement()).isEqualTo(providerNegotiation.getContractAgreement());304                    verify(validationService, atLeastOnce()).validate(token, initialOffer);305                    verify(validationService, atLeastOnce()).validate(token, counterOffer, initialOffer);306                    verify(validationService, atLeastOnce()).validate(token, consumerCounterOffer, counterOffer);307                    verify(validationService, atLeastOnce()).validate(eq(token), any(ContractAgreement.class), eq(consumerCounterOffer));308                    verify(negotiationListenerMock, times(2)).preConfirmed(any());309                });310        // Stop provider and consumer negotiation managers311        providerManager.stop();312        consumerManager.stop();313    }314    @Test315    @Disabled316    void testNegotiation_consumerCounterOfferDeclined() {317        consumerNegotiationId = null;318        // Create an initial contract offer and two counter offers319        ContractOffer initialOffer = getContractOffer();320        ContractOffer counterOffer = getCounterOffer();321        ContractOffer consumerCounterOffer = getConsumerCounterOffer();322        // Mock validation of initial offer on provider side => counter offer323        when(validationService.validate(token, initialOffer)).thenReturn(Result.success(null));324        //Mock validation of counter offer on consumer side => counter offer325        when(validationService.validate(token, counterOffer, initialOffer)).thenReturn(Result.success(null));326        //Mock validation of second counter offer on provider side => decline327        when(validationService.validate(token, consumerCounterOffer, counterOffer)).thenReturn(Result.success(null));328        // Create and register listeners for provider and consumer329        providerObservable.registerListener(negotiationListenerMock);330        consumerObservable.registerListener(negotiationListenerMock);331        // Start provider and consumer negotiation managers332        providerManager.start();333        consumerManager.start();334        // Create an initial request and trigger consumer manager335        ContractOfferRequest request = ContractOfferRequest.Builder.newInstance()...

Source:TriggeredVerifierTest.java

1/*2 * Copyright (C) 2009 Jens Dietrich3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 6 * Unless required by applicable law or agreed to in writing, software distributed under the License 7 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 8 * See the License for the specific language governing permissions and limitations under the License. 9 */1011package test.net.java.treaty.trigger.verification;1213import static org.junit.Assert.assertFalse;14import static org.junit.Assert.assertNull;15import static org.junit.Assert.assertTrue;16import static org.junit.Assert.fail;1718import java.io.File;19import java.io.IOException;20import java.net.URI;21import java.net.URISyntaxException;22import java.net.URL;23import java.util.Set;2425import net.java.treaty.Component;26import net.java.treaty.Connector;27import net.java.treaty.ConnectorType;28import net.java.treaty.Contract;29import net.java.treaty.ContractReader;30import net.java.treaty.Role;31import net.java.treaty.TreatyException;32import net.java.treaty.contractregistry.ContractRegistry;33import net.java.treaty.contractregistry.ContractRegistry.UpdateType;34import net.java.treaty.trigger.AbstractTriggerVocabulary;35import net.java.treaty.trigger.TriggerRegistry;36import net.java.treaty.trigger.verification.AbstractTriggeredVerifier;37import net.java.treaty.trigger.verification.TriggeredVerifierListener;38import net.java.treaty.xml.XMLContractReader;3940import org.junit.Test;4142import test.net.java.treaty.contractregistry.VocabularyMock;43import test.net.java.treaty.mocks.ComponentMock;44import test.net.java.treaty.mocks.ConnectorMock;45import test.net.java.treaty.mocks.ResourceManagerMock;46import test.net.java.treaty.mocks.TriggerVocabularyMock;47import test.net.java.treaty.mocks.TriggeredVerifierMock;4849/**50 * <p>51 * Test cases to test the class {@link AbstractTriggeredVerifier}.52 * </p>53 * 54 * @author Claas Wilke55 */56public class TriggeredVerifierTest implements TriggeredVerifierListener {5758	/** The location of the {@link Contract} files used for testing. */59	private static final String TEST_CONTRACT_LOCATION =60			"tests/test/net/java/treaty/mocks/";6162	/** The name of a {@link Contract} file used for testing. */63	private static final String TEST_CONTRACT_1 =64			TEST_CONTRACT_LOCATION + "test04.contract";6566	/** The name of a {@link Contract} file used for testing. */67	private static final String TEST_CONTRACT_2 =68			TEST_CONTRACT_LOCATION + "test05.contract";6970	/** The name of a {@link Contract} file used for testing. */71	private static final String TEST_CONTRACT_3 =72			TEST_CONTRACT_LOCATION + "test06.contract";7374	/** The maximum loops to wait for a verification result. */75	private static final int WAIT_TOTAL_LOOPS = 20;7677	/** The time to wait in a loop. */78	private static final long WAIT_PAUSE_LENGTH = 50;7980	/** Contains the verification result used during testing. */81	private Boolean verificationResult;8283	/*84	 * (non-Javadoc)85	 * @see86	 * net.java.treaty.event.verification.TriggeredVerifierListener#verificationFailed87	 * (java.net.URI, net.java.treaty.Contract)88	 */89	public void verificationFailed(URI triggerType, Contract contrac) {9091		this.verificationResult = false;92	}9394	/*95	 * (non-Javadoc)96	 * @seenet.java.treaty.event.verification.TriggeredVerifierListener#97	 * verificationSucceeded(java.net.URI, net.java.treaty.Contract)98	 */99	public void verificationSucceeded(URI triggerType, Contract contrac) {100101		this.verificationResult = true;102	}103104	/**105	 * <p>106	 * A test case testing the Triggered Verification of the107	 * {@link AbstractTriggeredVerifier}.108	 * </p>109	 * 110	 * @throws TreatyException111	 *           If thrown, the test case fails.112	 * @throws URISyntaxException113	 *           If thrown, the test case fails.114	 */115	@Test116	public void testVerification01() throws TreatyException, URISyntaxException {117118		/* Prepare test data. */119		TriggerRegistry triggerRegistry;120		triggerRegistry = new TriggerRegistry();121122		ContractRegistry contractRegistry;123		contractRegistry =124				new ContractRegistry(new ResourceManagerMock(), triggerRegistry);125126		Component consumerComponent;127		consumerComponent = new ComponentMock("consumercomponent");128129		Connector consumer;130		consumer =131				new ConnectorMock("consumercomponent.consumer", consumerComponent,132						ConnectorType.CONSUMER);133134		Component supplierComponent;135		supplierComponent = new ComponentMock("suppliercomponent");136137		Connector supplier;138		supplier =139				new ConnectorMock("suppliercomponent.supplier", supplierComponent,140						ConnectorType.SUPPLIER);141142		Contract contract;143		contract = this.createTestContract(TEST_CONTRACT_1);144145		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,146				consumer, Role.CONSUMER);147		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry148				.getContracts(consumer, Role.CONSUMER).iterator().next(), supplier,149				Role.SUPPLIER);150151		/* Create the verifier. */152		AbstractTriggeredVerifier triggeredVerifier;153		triggeredVerifier = new TriggeredVerifierMock();154155		/* Register as listener. */156		triggeredVerifier.addListener(this);157158		/* Reset the verification result. */159		this.verificationResult = null;160161		/* Trigger verification. */162		URI triggerType;163		triggerType = new URI(TriggerVocabularyMock.NAME_TRIGGER_1);164165		AbstractTriggerVocabulary triggerVocabulary;166		triggerVocabulary = new TriggerVocabularyMock();167		triggerVocabulary.addEventListener(triggeredVerifier);168		triggerRegistry.addTriggerVocabulary(triggerVocabulary);169170		Set<Contract> contracts;171		contracts =172				contractRegistry.getAffectedContracts(triggerType, consumerComponent);173174		triggerVocabulary.notifyEventListners(triggerType, contracts);175176		/* Wait for result. */177		int loops;178		loops = 0;179180		while (verificationResult == null) {181			/* Wait some time to improve CPU performance. */182			try {183				Thread.sleep(WAIT_PAUSE_LENGTH);184			}185186			catch (InterruptedException e) {187				fail("Cannot ensure that testcase behaves determinisitc. Test failed.");188			}189			// end catch.190191			loops++;192			if (loops > WAIT_TOTAL_LOOPS) {193				fail("Verification result was not available.");194			}195			// no else.196		}197198		/* Result should be positive. */199		assertTrue(this.verificationResult);200201		/* Unregister as listener. */202		triggeredVerifier.removeListener(this);203	}204205	/**206	 * <p>207	 * A test case testing the Triggered Verification of the208	 * {@link AbstractTriggeredVerifier}.209	 * </p>210	 * 211	 * @throws TreatyException212	 *           If thrown, the test case fails.213	 * @throws URISyntaxException214	 *           If thrown, the test case fails.215	 */216	@Test217	public void testVerification02() throws TreatyException, URISyntaxException {218219		/* Prepare test data. */220		TriggerRegistry triggerRegistry;221		triggerRegistry = new TriggerRegistry();222223		ContractRegistry contractRegistry;224		contractRegistry =225				new ContractRegistry(new ResourceManagerMock(), triggerRegistry);226227		Component consumerComponent;228		consumerComponent = new ComponentMock("consumercomponent");229230		Connector consumer;231		consumer =232				new ConnectorMock("consumercomponent.consumer", consumerComponent,233						ConnectorType.CONSUMER);234235		Component supplierComponent;236		supplierComponent = new ComponentMock("suppliercomponent");237238		Connector supplier;239		supplier =240				new ConnectorMock("suppliercomponent.supplier", supplierComponent,241						ConnectorType.SUPPLIER);242243		Contract contract;244		contract = this.createTestContract(TEST_CONTRACT_2);245246		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,247				consumer, Role.CONSUMER);248		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry249				.getContracts(consumer, Role.CONSUMER).iterator().next(), supplier,250				Role.SUPPLIER);251252		/* Create the verifier. */253		AbstractTriggeredVerifier triggeredVerifier;254		triggeredVerifier = new TriggeredVerifierMock();255256		/* Register as listener. */257		triggeredVerifier.addListener(this);258259		/* Reset the verification result. */260		this.verificationResult = null;261262		/* Trigger verification. */263		URI triggerType;264		triggerType = new URI(TriggerVocabularyMock.NAME_TRIGGER_2);265266		AbstractTriggerVocabulary triggerVocabulary;267		triggerVocabulary = new TriggerVocabularyMock();268		triggerVocabulary.addEventListener(triggeredVerifier);269		triggerRegistry.addTriggerVocabulary(triggerVocabulary);270271		Set<Contract> contracts;272		contracts =273				contractRegistry.getAffectedContracts(triggerType, consumerComponent);274275		triggerVocabulary.notifyEventListners(triggerType, contracts);276277		/* Wait for result. */278		int loops;279		loops = 0;280281		while (verificationResult == null) {282			/* Wait some time to improve CPU performance. */283			try {284				Thread.sleep(WAIT_PAUSE_LENGTH);285			}286287			catch (InterruptedException e) {288				fail("Cannot ensure that testcase behaves determinisitc. Test failed.");289			}290			// end catch.291292			loops++;293			if (loops > WAIT_TOTAL_LOOPS) {294				fail("Verification result was not available.");295			}296			// no else.297		}298299		/* Result should be negative. */300		assertFalse(this.verificationResult);301302		/* Unregister as listener. */303		triggeredVerifier.removeListener(this);304	}305306	/**307	 * <p>308	 * A test case testing the Triggered Verification of the309	 * {@link AbstractTriggeredVerifier} with a super trigger defined in a310	 * {@link Contract}.311	 * </p>312	 * 313	 * @throws TreatyException314	 *           If thrown, the test case fails.315	 * @throws URISyntaxException316	 *           If thrown, the test case fails.317	 */318	@Test319	public void testVerification03() throws TreatyException, URISyntaxException {320321		/* Prepare test data. */322		TriggerRegistry triggerRegistry;323		triggerRegistry = new TriggerRegistry();324325		ContractRegistry contractRegistry;326		contractRegistry =327				new ContractRegistry(new ResourceManagerMock(), triggerRegistry);328329		Component consumerComponent;330		consumerComponent = new ComponentMock("consumercomponent");331332		Connector consumer;333		consumer =334				new ConnectorMock("consumercomponent.consumer", consumerComponent,335						ConnectorType.CONSUMER);336337		Component supplierComponent;338		supplierComponent = new ComponentMock("suppliercomponent");339340		Connector supplier;341		supplier =342				new ConnectorMock("suppliercomponent.supplier", supplierComponent,343						ConnectorType.SUPPLIER);344345		Contract contract;346		contract = this.createTestContract(TEST_CONTRACT_3);347348		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,349				consumer, Role.CONSUMER);350		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry351				.getContracts(consumer, Role.CONSUMER).iterator().next(), supplier,352				Role.SUPPLIER);353354		/* Create the verifier. */355		AbstractTriggeredVerifier triggeredVerifier;356		triggeredVerifier = new TriggeredVerifierMock();357358		/* Register as listener. */359		triggeredVerifier.addListener(this);360361		/* Reset the verification result. */362		this.verificationResult = null;363364		/* Trigger verification. */365		URI triggerType;366		triggerType = new URI(TriggerVocabularyMock.NAME_PARENT_TRIGGER_1);367368		AbstractTriggerVocabulary triggerVocabulary;369		triggerVocabulary = new TriggerVocabularyMock();370		triggerVocabulary.addEventListener(triggeredVerifier);371		triggerRegistry.addTriggerVocabulary(triggerVocabulary);372373		Set<Contract> contracts;374		contracts =375				contractRegistry.getAffectedContracts(triggerType, consumerComponent);376377		triggerVocabulary.notifyEventListners(triggerType, contracts);378379		/* Wait for result. */380		int loops;381		loops = 0;382383		while (verificationResult == null) {384			/* Wait some time to improve CPU performance. */385			try {386				Thread.sleep(WAIT_PAUSE_LENGTH);387			}388389			catch (InterruptedException e) {390				fail("Cannot ensure that testcase behaves determinisitc. Test failed.");391			}392			// end catch.393394			loops++;395			if (loops > WAIT_TOTAL_LOOPS) {396				fail("Verification result was not available.");397			}398			// no else.399		}400401		/* Result should be positive. */402		assertTrue(this.verificationResult);403404		/* Unregister as listener. */405		triggeredVerifier.removeListener(this);406	}407408	/**409	 * <p>410	 * A test case testing the Triggered Verification of the411	 * {@link AbstractTriggeredVerifier} with a sub trigger of a super trigger412	 * defined in a {@link Contract}.413	 * </p>414	 * 415	 * @throws TreatyException416	 *           If thrown, the test case fails.417	 * @throws URISyntaxException418	 *           If thrown, the test case fails.419	 */420	@Test421	public void testVerification04() throws TreatyException, URISyntaxException {422423		/* Prepare test data. */424		TriggerRegistry triggerRegistry;425		triggerRegistry = new TriggerRegistry();426427		ContractRegistry contractRegistry;428		contractRegistry =429				new ContractRegistry(new ResourceManagerMock(), triggerRegistry);430431		Component consumerComponent;432		consumerComponent = new ComponentMock("consumercomponent");433434		Connector consumer;435		consumer =436				new ConnectorMock("consumercomponent.consumer", consumerComponent,437						ConnectorType.CONSUMER);438439		Component supplierComponent;440		supplierComponent = new ComponentMock("suppliercomponent");441442		Connector supplier;443		supplier =444				new ConnectorMock("suppliercomponent.supplier", supplierComponent,445						ConnectorType.SUPPLIER);446447		Contract contract;448		contract = this.createTestContract(TEST_CONTRACT_3);449450		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,451				consumer, Role.CONSUMER);452		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry453				.getContracts(consumer, Role.CONSUMER).iterator().next(), supplier,454				Role.SUPPLIER);455456		/* Create the verifier. */457		AbstractTriggeredVerifier triggeredVerifier;458		triggeredVerifier = new TriggeredVerifierMock();459460		/* Register as listener. */461		triggeredVerifier.addListener(this);462463		/* Reset the verification result. */464		this.verificationResult = null;465466		/* Should Trigger verification. */467		URI triggerType;468		triggerType = new URI(TriggerVocabularyMock.NAME_TRIGGER_1);469470		AbstractTriggerVocabulary triggerVocabulary;471		triggerVocabulary = new TriggerVocabularyMock();472		triggerVocabulary.addEventListener(triggeredVerifier);473		triggerRegistry.addTriggerVocabulary(triggerVocabulary);474475		Set<Contract> contracts;476		contracts =477				contractRegistry.getAffectedContracts(triggerType, consumerComponent);478479		triggerVocabulary.notifyEventListners(triggerType, contracts);480481		/* Wait for result. */482		int loops;483		loops = 0;484485		while (verificationResult == null) {486			/* Wait some time to improve CPU performance. */487			try {488				Thread.sleep(WAIT_PAUSE_LENGTH);489			}490491			catch (InterruptedException e) {492				fail("Cannot ensure that testcase behaves determinisitc. Test failed.");493			}494			// end catch.495496			loops++;497			if (loops > WAIT_TOTAL_LOOPS) {498				fail("Verification result was not available.");499			}500			// no else.501		}502503		/* Result should be positive. */504		assertTrue(this.verificationResult);505506		/* Unregister as listener. */507		triggeredVerifier.removeListener(this);508	}509510	/**511	 * <p>512	 * A test case testing the Triggered Verification of the513	 * {@link AbstractTriggeredVerifier} with a trigger that is not a sub trigger514	 * of a super trigger defined in a {@link Contract}.515	 * </p>516	 * 517	 * @throws TreatyException518	 *           If thrown, the test case fails.519	 * @throws URISyntaxException520	 *           If thrown, the test case fails.521	 */522	@Test523	public void testVerification05() throws TreatyException, URISyntaxException {524525		/* Prepare test data. */526		TriggerRegistry triggerRegistry;527		triggerRegistry = new TriggerRegistry();528529		ContractRegistry contractRegistry;530		contractRegistry =531				new ContractRegistry(new ResourceManagerMock(), triggerRegistry);532533		Component consumerComponent;534		consumerComponent = new ComponentMock("consumercomponent");535536		Connector consumer;537		consumer =538				new ConnectorMock("consumercomponent.consumer", consumerComponent,539						ConnectorType.CONSUMER);540541		Component supplierComponent;542		supplierComponent = new ComponentMock("suppliercomponent");543544		Connector supplier;545		supplier =546				new ConnectorMock("suppliercomponent.supplier", supplierComponent,547						ConnectorType.SUPPLIER);548549		Contract contract;550		contract = this.createTestContract(TEST_CONTRACT_3);551552		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contract,553				consumer, Role.CONSUMER);554		contractRegistry.updateContract(UpdateType.ADD_CONTRACT, contractRegistry555				.getContracts(consumer, Role.CONSUMER).iterator().next(), supplier,556				Role.SUPPLIER);557558		/* Create the verifier. */559		AbstractTriggeredVerifier triggeredVerifier;560		triggeredVerifier = new TriggeredVerifierMock();561562		/* Register as listener. */563		triggeredVerifier.addListener(this);564565		/* Reset the verification result. */566		this.verificationResult = null;567568		/* Should not Trigger verification. */569		URI triggerType;570		triggerType = new URI(TriggerVocabularyMock.NAME_TRIGGER_2);571572		AbstractTriggerVocabulary triggerVocabulary;573		triggerVocabulary = new TriggerVocabularyMock();574		triggerVocabulary.addEventListener(triggeredVerifier);575		triggerRegistry.addTriggerVocabulary(triggerVocabulary);576577		Set<Contract> contracts;578		contracts =579				contractRegistry.getAffectedContracts(triggerType, consumerComponent);580581		triggerVocabulary.notifyEventListners(triggerType, contracts);582583		/* Wait for result. */584		int loops;585		loops = 0;586587		while (verificationResult == null) {588			/* Wait some time to improve CPU performance. */589			try {590				Thread.sleep(WAIT_PAUSE_LENGTH);591			}592593			catch (InterruptedException e) {594				fail("Cannot ensure that testcase behaves determinisitc. Test failed.");595			}596			// end catch.597598			loops++;599			if (loops > WAIT_TOTAL_LOOPS) {600				break;601			}602			// no else.603		}604605		/* Result should be null. */606		assertNull(this.verificationResult);607608		/* Unregister as listener. */609		triggeredVerifier.removeListener(this);610	}611612	/**613	 * <p>614	 * A helper method that initializes a simple {@link Contract} used during615	 * testing.616	 * </p>617	 * 618	 * @param The619	 *          name of the {@link Contract} file that shall be created.620	 * @return A simple {@link Contract} used during testing.621	 */622	private Contract createTestContract(String fileName) {623624		Contract result;625		result = null;626627		URL location;628		location = null;629630		/* Try to read the contract. */631		try {632			File file;633			file = new File(fileName);634635			location = file.toURI().toURL();636637			ContractReader reader;638			reader = new XMLContractReader();639640			result = reader.read(location.openStream(), VocabularyMock.INSTANCE);641			result.setLocation(location);642		}643644		catch (TreatyException e) {645			fail("Exception loading contract from " + location + ":" + e.getMessage());646		}647648		catch (IOException e) {649			fail("Exception loading contract from " + location + ":" + e.getMessage());650		}651652		return result;653	}
...

Consumer

Using AI Code Generation

1package mock.contract;2import java.util.function.Consumer;3public class ConsumerExample {4	public static void main(String[] args) {5		Consumer<Integer> display = a -> System.out.println(a);6		display.accept(10);7	}8}9package mock.contract;10import java.util.function.Consumer;11public class ConsumerExample {12	public static void main(String[] args) {13		Consumer<Integer> modify = a -> System.out.println(a * 2);14		modify.accept(10);15	}16}17package mock.contract;18import java.util.function.Consumer;19public class ConsumerExample {20	public static void main(String[] args) {21		Consumer<Integer> display = a -> System.out.println(a);22		Consumer<Integer> modify = a -> System.out.println(a * 2);23		display.andThen(modify).accept(10);24	}25}26package mock.contract;27import java.util.function.Consumer;28public class ConsumerExample {29	public static void main(String[] args) {30		Consumer<Integer> display = a -> System.out.println(a);31		Consumer<Integer> modify = a -> System.out.println(a * 2);32		display.andThen(modify).accept(10);33	}34}35package mock.contract;36import java.util.function.Consumer;37public class ConsumerExample {38	public static void main(String[] args) {

Consumer

Using AI Code Generation

1package mock.contract;2import java.util.function.Consumer;3public class ConsumerDemo {4	public static void main(String[] args) {5		Consumer<String> consumer = s -> System.out.println(s);6		consumer.accept("Hello");7	}8}

Consumer

Using AI Code Generation

1package mock.contract;2import java.util.function.Consumer;3public class ConsumerMethod {4    public static void main(String[] args) {5        Consumer<String> c = s -> System.out.println(s);6        c.accept("Hello");7    }8}9package mock.contract;10import java.util.function.Predicate;11public class PredicateMethod {12    public static void main(String[] args) {13        Predicate<Integer> p = i -> i%2==0;14        System.out.println(p.test(10));15    }16}17package mock.contract;18import java.util.function.Function;19public class FunctionMethod {20    public static void main(String[] args) {21        Function<Integer, Integer> f = i -> i*i;22        System.out.println(f.apply(10));23    }24}25package mock.contract;26import java.util.function.Supplier;27public class SupplierMethod {28    public static void main(String[] args) {29        Supplier<String> s = () -> "Hello";30        System.out.println(s.get());31    }32}33package mock.contract;34import java.util.function.UnaryOperator;35public class UnaryOperatorMethod {36    public static void main(String[] args) {37        UnaryOperator<Integer> u = i -> i*i;38        System.out.println(u.apply(10));39    }40}41package mock.contract;42import java.util.function.BinaryOperator;43public class BinaryOperatorMethod {44    public static void main(String[] args) {45        BinaryOperator<Integer> b = (i,j) -> i+j;46        System.out.println(b.apply(10,20));47    }48}49package mock.contract;50import java.util.function.BiConsumer;51public class BiConsumerMethod {52    public static void main(String[] args) {53        BiConsumer<Integer,Integer> b = (i,j) -> System.out.println(i+j);54        b.accept(10,20);55    }56}

Consumer

Using AI Code Generation

1import mock.contract.Consumer;2public class 4 {3public static void main(String[] args) {4Consumer consumer = new Consumer();5consumer.accept("Hello");6}7}8package mock.contract;9public class Consumer {10public void accept(String message) {11System.out.println(message);12}13}

Consumer

Using AI Code Generation

1package mock.contract;2import java.util.function.Consumer;3public class ConsumerDemo {4public static void main(String[] args) {5Consumer<String> c = s -> System.out.println(s);6c.accept("Hello");7}8}9package mock.contract;10import java.util.function.Supplier;11public class SupplierDemo {12public static void main(String[] args) {13Supplier<String> s = () -> "Hello";14System.out.println(s.get());15}16}17package mock.contract;18import java.util.function.Predicate;19public class PredicateDemo {20public static void main(String[] args) {21Predicate<String> p = s -> s.length() > 5;22System.out.println(p.test("Hello"));23}24}25package mock.contract;26import java.util.function.Function;27public class FunctionDemo {28public static void main(String[] args) {29Function<String, Integer> f = s -> s.length();30System.out.println(f.apply("Hello"));31}32}33package mock.contract;34import java.util.function.BiConsumer;35public class BiConsumerDemo {36public static void main(String[] args) {37BiConsumer<String, Integer> b = (s, i) -> System.out.println(s + i);38b.accept("Hello", 5);39}40}41package mock.contract;42import java.util.function.BiFunction;43public class BiFunctionDemo {44public static void main(String[] args) {45BiFunction<String, Integer, String> b = (s, i) -> s + i;46System.out.println(b.apply("Hello", 5));47}48}49package mock.contract;50import java.util.function.BiPredicate;51public class BiPredicateDemo {52public static void main(String[] args) {53BiPredicate<String, String> b = (s1, s2) -> s1.equals(s2);

Consumer

Using AI Code Generation

1package mock.contract;2import java.util.function.Consumer;3public class ConsumerDemo {4public static void main(String[] args) {5Consumer<Integer> c = i -> System.out.println(i);6c.accept(10);7}8}9package mock.contract;10import java.util.function.Supplier;11public class SupplierDemo {12public static void main(String[] args) {13Supplier<Integer> s = () -> 10;14System.out.println(s.get());15}16}17package mock.contract;18import java.util.function.Predicate;19public class PredicateDemo {20public static void main(String[] args) {21Predicate<Integer> p = i -> i > 10;22System.out.println(p.test(20));23}24}25package mock.contract;26import java.util.function.Function;27public class FunctionDemo {28public static void main(String[] args) {29Function<Integer, Integer> f = i -> i * i;30System.out.println(f.apply(10));31}32}33package mock.contract;34import java.util.function.BiConsumer;35public class BiConsumerDemo {36public static void main(String[] args) {37BiConsumer<Integer, Integer> bc = (i, j) -> System.out.println(i + j);38bc.accept(10, 20);39}40}41package mock.contract;42import java.util.function.BiFunction;43public class BiFunctionDemo {44public static void main(String[] args) {45BiFunction<Integer, Integer, Integer> bf = (i, j) -> i + j;46System.out.println(bf.apply(10, 20));47}48}49package mock.contract;50import java.util.function.BiPredicate;51public class BiPredicateDemo {52public static void main(String[] args) {53BiPredicate<Integer, Integer> bp = (i, j) -> i > j;54System.out.println(bp.test(10

Consumer

Using AI Code Generation

1package mock.contract;2import java.util.function.Consumer;3public class ConsumerDemo {4	public static void main(String[] args) {5		Consumer<String> c = s -> System.out.println(s);6		Producer p = new Producer();7		p.produce(c);8	}9}10package mock.contract;11import java.util.function.Consumer;12public class ConsumerDemo {13	public static void main(String[] args) {14		Consumer<String> c = s -> System.out.println(s);15		Producer p = new Producer();16		p.produce(c);17	}18}19package mock.contract;20import java.util.function.Consumer;21public class ConsumerDemo {22	public static void main(String[] args) {23		Consumer<String> c = s -> System.out.println(s);24		Producer p = new Producer();25		p.produce(c);26	}27}28package mock.contract;29import java.util.function.Consumer;30public class ConsumerDemo {31	public static void main(String[] args) {32		Consumer<String> c = s -> System.out.println(s);33		Producer p = new Producer();34		p.produce(c);35	}36}

Consumer

Using AI Code Generation

1public class Consumer {2    public static void main(String[] args) {3        MockContract mockContract = MockContract.load("0x123", web3j, credentials, ManagedTransaction.GAS_PRICE, Contract.GAS_LIMIT);4        mockContract.consume("0x123").send();5    }6}7public class Consumer {8    public static void main(String[] args) {9        MockContract mockContract = MockContract.load("0x123", web3j, credentials, ManagedTransaction.GAS_PRICE, Contract.GAS_LIMIT);10        mockContract.consume("0x123").send();11    }12}13public class Deployer {14    public static void main(String[] args) throws Exception {15        Credentials credentials = WalletUtils.loadCredentials("<your-wallet-password>", "<your-wallet-file-path>");16        MockContract contract = MockContract.deploy(web3j, credentials, ManagedTransaction.GAS_PRICE, Contract.GAS_LIMIT).send();17        System.out.println("Contract Address: " + contract.getContractAddress());18    }19}20public class Consumer {21    public static void main(String[] args) throws Exception {

Consumer

Using AI Code Generation

1import java.util.function.Consumer;2import mock.contract.Consumer;3public class 4 {4public static void main(String[] args) {5Consumer c = new Consumer();6c.accept("Hello");7}8}9Mockito library provides a lot of methods to mock classes and interfaces. The Mockito.mock() method is used to mock a class or an interface. The Mockito.when() method is used to define the behavior of the mock object. The Mockito.verify() method is used to verify the behavior of the mock object. The Mockito.inOrder() method is used to verify the order of the method calls. The Mockito.times() method is used to verify the number of times a method is called. The Mockito.any() method is used to verify the method arguments. The Mockito.spy() method is used to spy on the real objects. The Mockito.doReturn() method is used to define the behavior of the spy object. The Mockito.doThrow() method is used to define the behavior of the spy object. The Mockito.doNothing() method is used to define the behavior of the spy object. The Mockito.doAnswer() method is used to define the behavior of the spy object. The Mockito.doCallRealMethod() method is used to define the behavior of the spy object. The Mockito.doNothing().when() method is used to define the behavior of the spy object. The Mockito.doThrow().when() method is used to define the behavior of the spy object. The Mockito.doAnswer().when() method is used to define the behavior of the spy object. The Mockito.doReturn().when() method is used to define the behavior of the spy object. The Mockito.doCallRealMethod().when() method is used to define the behavior of the spy object. The Mockito.reset() method is used to reset the mock object. The Mockito.never() method is used to verify the behavior of the mock object. The Mockito.times() method is used to verify the behavior of the mock object. The Mockito.atLeastOnce() method is used to verify the behavior of the mock object. The Mockito.atLeast() method is used to verify the behavior of the mock object. The Mockito.atMost() method is used to verify the behavior of the mock object. The Mockito.only() method is used to verify the behavior of the mock object. The Mockito.timeout() method is used to verify the behavior of the mock object. The Mockito.after() method is used to verify the behavior of the mock object. The Mockito.in

Consumer

Using AI Code Generation

1import mock.contract.Consumer;2import mock.contract.Provider;3import mock.contract.ProviderFactory;4import mock.provider.ProviderImpl;5import java.util.function.Consumer;6import java.util.function.Supplier;7public class ConsumerTest {8    public static void main(String[] args) {9        ProviderFactory factory = ProviderImpl::new;10        Provider provider = factory.create();11        Consumer<String> consumer = provider.getConsumer();12        consumer.accept("Hello World");13    }14}15import mock.contract.Provider;16import mock.contract.ProviderFactory;17import mock.provider.ProviderImpl;18import java.util.function.Consumer;19import java.util.function.Supplier;20public class SupplierTest {21    public static void main(String[] args) {22        ProviderFactory factory = ProviderImpl::new;23        Provider provider = factory.create();24        Supplier<String> supplier = provider.getSupplier();25        String value = supplier.get();26        System.out.println(value);27    }28}29import mock.contract.Consumer;30import mock.contract.Provider;31import mock.contract.ProviderFactory;32import mock.provider.ProviderImpl;33import java.util.function.Consumer;34import java.util.function.Supplier;35public class BiConsumerTest {36    public static void main(String[] args) {37        ProviderFactory factory = ProviderImpl::new;38        Provider provider = factory.create();39        Consumer<String, String> consumer = provider.getBiConsumer();40        consumer.accept("Hello", "World");41    }42}43import mock.contract.Provider;44import mock.contract.ProviderFactory;45import mock.provider.ProviderImpl;46import java.util.function.Consumer;47import java.util.function.Supplier;48public class BiFunctionTest {49    public static void main(String[] args) {50        ProviderFactory factory = ProviderImpl::new;51        Provider provider = factory.create();52        BiFunction<String, String, String> biFunction = provider.getBiFunction();53        String value = biFunction.apply("Hello", "World");54        System.out.println(value);55    }56}57import mock.contract.Provider;58import mock.contract.ProviderFactory;59import mock.provider.ProviderImpl;60import java

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.