Toggle navigation
Home
java.lang.String to org.wildfly.common.function.ExceptionSupplier<java.lang.instrument.IllegalClassFormatException, org.jboss.as.test.clustering.ejb.EJBDirectory>
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'wildfly'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> External
Mapping:
Add or Remove Method invocation
this.configurator.apply(() -> { try (EJBDirectory directory=new RemoteEJBDirectory(this.module)){ Incrementor bean=directory.lookupStateless(this.beanClass,Incrementor.class); Thread.sleep(CLIENT_TOPOLOGY_UPDATE_WAIT); List<String> results=new ArrayList<>(COUNT); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.add(result.getNode()); Thread.sleep(INVOCATION_WAIT); } for ( String node : NODES) { int frequency=Collections.frequency(results,node); assertTrue(String.valueOf(frequency) + " invocations were routed to " + node,frequency > 0); } undeploy(DEPLOYMENT_1); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } Assert.assertEquals(0,Collections.frequency(results,NODE_1)); Assert.assertEquals(COUNT,Collections.frequency(results,NODE_2)); deploy(DEPLOYMENT_1); Thread.sleep(CLIENT_TOPOLOGY_UPDATE_WAIT); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } for ( String node : NODES) { int frequency=Collections.frequency(results,node); assertTrue(String.valueOf(frequency) + " invocations were routed to " + node,frequency > 0); } stop(CONTAINER_2); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } Assert.assertEquals(COUNT,Collections.frequency(results,NODE_1)); Assert.assertEquals(0,Collections.frequency(results,NODE_2)); start(CONTAINER_2); Thread.sleep(CLIENT_TOPOLOGY_UPDATE_WAIT); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } for ( String node : NODES) { int frequency=Collections.frequency(results,node); assertTrue(String.valueOf(frequency) + " invocations were routed to " + node,frequency > 0); } } return null; } )
to
this.configurator.apply(() -> { try (EJBDirectory directory=this.directoryProvider.get()){ Incrementor bean=directory.lookupStateless(this.beanClass,Incrementor.class); Thread.sleep(CLIENT_TOPOLOGY_UPDATE_WAIT); List<String> results=new ArrayList<>(COUNT); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.add(result.getNode()); Thread.sleep(INVOCATION_WAIT); } for ( String node : NODES) { int frequency=Collections.frequency(results,node); assertTrue(String.valueOf(frequency) + " invocations were routed to " + node,frequency > 0); } undeploy(DEPLOYMENT_1); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } Assert.assertEquals(0,Collections.frequency(results,NODE_1)); Assert.assertEquals(COUNT,Collections.frequency(results,NODE_2)); deploy(DEPLOYMENT_1); Thread.sleep(CLIENT_TOPOLOGY_UPDATE_WAIT); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } for ( String node : NODES) { int frequency=Collections.frequency(results,node); assertTrue(String.valueOf(frequency) + " invocations were routed to " + node,frequency > 0); } stop(CONTAINER_2); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } Assert.assertEquals(COUNT,Collections.frequency(results,NODE_1)); Assert.assertEquals(0,Collections.frequency(results,NODE_2)); start(CONTAINER_2); Thread.sleep(CLIENT_TOPOLOGY_UPDATE_WAIT); for (int i=0; i < COUNT; ++i) { Result<Integer> result=bean.increment(); results.set(i,result.getNode()); Thread.sleep(INVOCATION_WAIT); } for ( String node : NODES) { int frequency=Collections.frequency(results,node); assertTrue(String.valueOf(frequency) + " invocations were routed to " + node,frequency > 0); } } return null; } )
Rename Variable
module
to
directoryProvider
module
to
directoryProvider
module
to
directoryProvider