import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
public void testPact(@Observes(precedence = -50) EventContext<Test> testEventContext, Deployment deployment)
    throws Throwable {

    final Test event = testEventContext.getEvent();
    final TestClass testClass = event.getTestClass();

    // We need to check this because in case of embedded containers this class is executed too
    if (RunModeUtils.isRunAsClient(deployment, testClass, event.getTestMethod())) {

        final PactVerification pactVerification = event.getTestMethod().getAnnotation(PactVerification.class);

        if (pactVerification == null) {
            logger.log(Level.INFO,
                String.format(
                    "Method %s is not annotated with %s annotation and it is going to be executed as normal junit test.",
                    event.getTestMethod().getName(), PactVerification.class.getName()));
            testEventContext.proceed();
            return;
        }

        executeConsumerTest(testEventContext, testClass, pactVerification);
    } else {
        // We are in container and this class is executed in client side so we should only pass the execution and incontainer class will do the job
        testEventContext.proceed();
    }
}
 

import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
private AddonId getAddonEntry(Deployment deployment)
{
   if (!deployedAddons.containsKey(deployment))
   {
      String[] coordinates = deployment.getDescription().getName().split(",");
      AddonId entry;
      if (coordinates.length == 3)
         entry = AddonId.from(coordinates[0], coordinates[1], coordinates[2]);
      else if (coordinates.length == 2)
         entry = AddonId.from(coordinates[0], coordinates[1]);
      else if (coordinates.length == 1)
         entry = AddonId.from(coordinates[0], UUID.randomUUID().toString());
      else
         entry = AddonId.from(UUID.randomUUID().toString(), UUID.randomUUID().toString());

      deployedAddons.put(deployment, entry);
   }
   return deployedAddons.get(deployment);
}
 

import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
/**
 * @see org.jboss.arquillian.container.test.impl.client.container.ClientContainerController#stop(java.lang.String)
 */
@Override
public void stop(String containerQualifier, int timeout) {
    {
        DeploymentScenario scenario = getDeploymentScenario().get();
        if (scenario == null) {
            throw new IllegalArgumentException("No deployment scenario in context");
        }

        ContainerRegistry registry = getContainerRegistry().get();
        if (registry == null) {
            throw new IllegalArgumentException("No container registry in context");
        }

        if (!containerExists(registry.getContainers(), containerQualifier)) {
            throw new IllegalArgumentException("No container with the specified name exists");
        }

        if (!isControllableContainer(registry.getContainers(), containerQualifier)) {
            throw new IllegalArgumentException("Could not start " + containerQualifier + " container. The container life cycle is controlled by Arquillian");
        }

        Container container = getContainerRegistry().get().getContainer(new TargetDescription(containerQualifier));

        List<Deployment> managedDeployments = scenario.startupDeploymentsFor(new TargetDescription(containerQualifier));

        for (Deployment d : managedDeployments) {
            if (d.isDeployed()) {
                log.info("Automatic undeploying of the managed deployment with name " + d.getDescription().getName() +
                        " from the container with name " + container.getName());
                getContainerControllerEvent().fire(new UnDeployDeployment(container, d));
            }
        }

        log.info("Manual stopping of a server instance with timeout=" + timeout);

        getContainerControllerEvent().fire(new StopContainerWithTimeout(container, timeout));
    }
}
 

import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
public void deploy(@Observes final AfterStart event, final ContainerRegistry registry) {
    executeInClassScope(new Callable<Void>() {
        public Void call() throws Exception {
            for (Deployment d : suiteDeploymentScenario.deployments()) {
                deploymentEvent.fire(new DeployDeployment(findContainer(registry, event.getDeployableContainer()), d));
            }
            return null;
        }
    });
}
 

import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
public void undeploy(@Observes final BeforeStop event, final ContainerRegistry registry) {
    executeInClassScope(new Callable<Void>() {
        public Void call() throws Exception {
            for (Deployment d : suiteDeploymentScenario.deployments()) {
                deploymentEvent.fire(new UnDeployDeployment(findContainer(registry, event.getDeployableContainer()), d));
            }
            return null;
        }
    });
}
 

import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
public void deploy(@Observes final AfterStart event, final ContainerRegistry registry) {

			executeInClassScope(new Callable<Void>() {
				public Void call() throws Exception {

					for (Deployment d : suiteDeploymentScenario.deployments()) {
						deploymentEvent.fire(
								new DeployDeployment(findContainer(registry, event.getDeployableContainer()), d));
					}
					return null;
				}
			});
		}
 

import org.jboss.arquillian.container.spi.client.deployment.Deployment; //导入依赖的package包/类
public void undeploy(@Observes final BeforeStop event, final ContainerRegistry registry) {

			executeInClassScope(new Callable<Void>() {
				public Void call() throws Exception {

					for (Deployment d : suiteDeploymentScenario.deployments()) {
						deploymentEvent.fire(
								new UnDeployDeployment(findContainer(registry, event.getDeployableContainer()), d));
					}
					return null;
				}
			});
		}