import org.elasticsearch.index.reindex.ReindexPlugin; //导入依赖的package包/类
@Test
public void testInstallPluginTwice() {
    for (Class<? extends Plugin> plugin : Arrays.asList(ReindexPlugin.class, PercolatorPlugin.class, MustachePlugin.class)) {
        try {
            new PreBuiltTransportClient(Settings.EMPTY, plugin);
            fail("exception expected");
        } catch (IllegalArgumentException ex) {
            assertTrue("Expected message to start with [plugin already exists: ] but was instead [" + ex.getMessage() + "]",
                    ex.getMessage().startsWith("plugin already exists: "));
        }
    }
}
 

import org.elasticsearch.index.reindex.ReindexPlugin; //导入依赖的package包/类
public final ClusterInfo startCluster(final NodeSettingsSupplier nodeSettingsSupplier, ClusterConfiguration clusterConfiguration, int timeout, Integer nodes)
		throws Exception {
    
	if (!esNodes.isEmpty()) {
		throw new RuntimeException("There are still " + esNodes.size() + " nodes instantiated, close them first.");
	}

	FileUtils.deleteDirectory(new File("data/"+clustername));

	List<NodeSettings> internalNodeSettings = clusterConfiguration.getNodeSettings();

	for (int i = 0; i < internalNodeSettings.size(); i++) {
		NodeSettings setting = internalNodeSettings.get(i);
		
		Node node = new PluginAwareNode(
				getMinimumNonSgNodeSettingsBuilder(i, setting.masterNode, setting.dataNode, setting.tribeNode, internalNodeSettings.size(), clusterConfiguration.getMasterNodes())
						.put(nodeSettingsSupplier == null ? Settings.Builder.EMPTY_SETTINGS : nodeSettingsSupplier.get(i)).build(),
				Netty4Plugin.class, SearchGuardPlugin.class, MatrixAggregationPlugin.class, MustachePlugin.class, ParentJoinPlugin.class, PercolatorPlugin.class, ReindexPlugin.class);
		System.out.println(node.settings());
		node.start();
		esNodes.add(node);
		Thread.sleep(200);
	}
	ClusterInfo cInfo = waitForCluster(ClusterHealthStatus.GREEN, TimeValue.timeValueSeconds(timeout), nodes == null?esNodes.size():nodes.intValue());
	cInfo.numNodes = internalNodeSettings.size();
	cInfo.clustername = clustername;
	return cInfo;
}