import org.jboss.arquillian.test.spi.TestMethodExecutor; //导入依赖的package包/类
@Override
public ContainerMethodExecutor getExecutor(FurnaceProtocolConfiguration protocolConfiguration,
         ProtocolMetaData metaData, CommandCallback callback)
{
   if (metaData == null)
   {
      return new ContainerMethodExecutor()
      {
         @Override
         public TestResult invoke(TestMethodExecutor arg0)
         {
            return TestResult.skipped();
         }
      };
   }

   Collection<FurnaceHolder> contexts = metaData.getContexts(FurnaceHolder.class);
   if (contexts.size() == 0)
   {
      throw new IllegalArgumentException(
               "No " + Furnace.class.getName() + " found in " + ProtocolMetaData.class.getName() + ". " +
                        "Furnace protocol can not be used");
   }
   return new FurnaceTestMethodExecutor(protocolConfiguration, contexts.iterator().next());
}
 

import org.jboss.arquillian.test.spi.TestMethodExecutor; //导入依赖的package包/类
@Override
public ContainerMethodExecutor getExecutor(ForgeProtocolConfiguration protocolConfiguration,
         ProtocolMetaData metaData, CommandCallback callback)
{
   if (metaData == null)
   {
      return new ContainerMethodExecutor()
      {
         @Override
         public TestResult invoke(TestMethodExecutor arg0)
         {
            return new TestResult(Status.SKIPPED);
         }
      };
   }

   Collection<FurnaceHolder> contexts = metaData.getContexts(FurnaceHolder.class);
   if (contexts.size() == 0)
   {
      throw new IllegalArgumentException(
               "No " + Furnace.class.getName() + " found in " + ProtocolMetaData.class.getName() + ". " +
                        "Furnace protocol can not be used");
   }
   return new ForgeTestMethodExecutor(protocolConfiguration, contexts.iterator().next());
}
 

import org.jboss.arquillian.test.spi.TestMethodExecutor; //导入依赖的package包/类
/**
 * {@inheritDoc}
 *
 * @see org.jboss.arquillian.container.test.spi.ContainerMethodExecutor#invoke(org.jboss.arquillian.test.spi.TestMethodExecutor)
 */
@Override
public TestResult invoke(final TestMethodExecutor testMethodExecutor) {

    assert testMethodExecutor != null : "Test method executor is required";

    // Build the String request according to the wire protocol
    final StringBuilder builder = new StringBuilder();
    builder.append(WireProtocol.COMMAND_TEST_PREFIX);
    builder.append(testMethodExecutor.getInstance().getClass().getName());
    builder.append(SPACE);
    builder.append(testMethodExecutor.getMethod().getName());
    builder.append(WireProtocol.COMMAND_EOF_DELIMITER);
    final String testCommand = builder.toString();
    final PrintWriter writer = this.context.getWriter();

    // Request
    writer.write(testCommand);
    writer.flush();

    try {
        // Read response
        final ObjectInputStream response = new ObjectInputStream(
                new NoCloseInputStream(context.getSocketInstream()));
        final TestResult testResult = (TestResult) response.readObject();
        response.close();
        return testResult;

    } catch (final IOException ioe) {
        throw new RuntimeException("Could not get test results", ioe);
    } catch (final ClassNotFoundException cnfe) {
        throw new RuntimeException("test result not on the client classpath", cnfe);
    }
}
 

import org.jboss.arquillian.test.spi.TestMethodExecutor; //导入依赖的package包/类
private String toFqn(ExecutionEvent event) {
    final TestMethodExecutor executor = event.getExecutor();
    final Object test = executor.getInstance();
    final Method method = executor.getMethod();
    return test.getClass().getName() + "#" + method.getName();
}