Java 类org.springframework.context.support.GenericXmlApplicationContext 实例源码

项目:OperatieBRP    文件:AbstractGenerateMojo.java   
@Override
public void execute() throws MojoExecutionException, MojoFailureException {
    // Create test context
    try (final GenericXmlApplicationContext generateContext = new GenericXmlApplicationContext()) {
        generateContext.load("classpath:generate-context.xml");
        generateContext.refresh();

        final DataSource dataSource = generateContext.getBean(DataSource.class);
        final Generator generator = new Generator(getLog(), this::processRecord);

        getLog().info("Loading templates from: " + source.getAbsolutePath());
        getLog().info("Package: " + packageName);
        for (final File file : source.listFiles(this::acceptAllFiles)) {
            generator.generate(dataSource, file, destination, packageName);
        }
    }
}
项目:spring4-understanding    文件:AsyncAnnotationBeanPostProcessorTests.java   
@Test
public void configuredThroughNamespace() {
    GenericXmlApplicationContext context = new GenericXmlApplicationContext();
    context.load(new ClassPathResource("taskNamespaceTests.xml", getClass()));
    context.refresh();
    ITestBean testBean = context.getBean("target", ITestBean.class);
    testBean.test();
    testBean.await(3000);
    Thread asyncThread = testBean.getThread();
    assertTrue(asyncThread.getName().startsWith("testExecutor"));

    TestableAsyncUncaughtExceptionHandler exceptionHandler =
            context.getBean("exceptionHandler", TestableAsyncUncaughtExceptionHandler.class);
    assertFalse("handler should not have been called yet", exceptionHandler.isCalled());

    testBean.failWithVoid();
    exceptionHandler.await(3000);
    Method m = ReflectionUtils.findMethod(TestBean.class, "failWithVoid");
    exceptionHandler.assertCalledWith(m, UnsupportedOperationException.class);
    context.close();
}
项目:spring4-understanding    文件:GroovyAspectIntegrationTests.java   
@Test
public void testJavaBean() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-java-context.xml");
    TestService bean = context.getBean("javaBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (RuntimeException ex) {
        assertEquals("TestServiceImpl", ex.getMessage());
    }
    assertEquals(1, logAdvice.getCountThrows());

}
项目:spring4-understanding    文件:GroovyAspectIntegrationTests.java   
@Test
public void testGroovyBeanInterface() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-groovy-interface-context.xml");
    TestService bean = context.getBean("groovyBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (RuntimeException ex) {
        assertEquals("GroovyServiceImpl", ex.getMessage());
    }
    assertEquals(1, logAdvice.getCountThrows());
}
项目:spring4-understanding    文件:GroovyAspectIntegrationTests.java   
@Test
public void testGroovyBeanDynamic() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-groovy-dynamic-context.xml");
    TestService bean = context.getBean("groovyBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (RuntimeException ex) {
        assertEquals("GroovyServiceImpl", ex.getMessage());
    }
    // No proxy here because the pointcut only applies to the concrete class, not the interface
    assertEquals(0, logAdvice.getCountThrows());
    assertEquals(0, logAdvice.getCountBefore());
}
项目:spring4-understanding    文件:GroovyAspectIntegrationTests.java   
@Test
public void testGroovyBeanProxyTargetClass() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-groovy-proxy-target-class-context.xml");
    TestService bean = context.getBean("groovyBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (TestException ex) {
        assertEquals("GroovyServiceImpl", ex.getMessage());
    }
    assertEquals(1, logAdvice.getCountBefore());
    assertEquals(1, logAdvice.getCountThrows());
}
项目:spring4-understanding    文件:DestroyMethodInferenceTests.java   
@Test
public void xml() {
    ConfigurableApplicationContext ctx = new GenericXmlApplicationContext(
            getClass(), "DestroyMethodInferenceTests-context.xml");
    WithLocalCloseMethod x1 = ctx.getBean("x1", WithLocalCloseMethod.class);
    WithLocalCloseMethod x2 = ctx.getBean("x2", WithLocalCloseMethod.class);
    WithLocalCloseMethod x3 = ctx.getBean("x3", WithLocalCloseMethod.class);
    WithNoCloseMethod x4 = ctx.getBean("x4", WithNoCloseMethod.class);
    WithInheritedCloseMethod x8 = ctx.getBean("x8", WithInheritedCloseMethod.class);

    assertThat(x1.closed, is(false));
    assertThat(x2.closed, is(false));
    assertThat(x3.closed, is(false));
    assertThat(x4.closed, is(false));
    ctx.close();
    assertThat(x1.closed, is(false));
    assertThat(x2.closed, is(true));
    assertThat(x3.closed, is(true));
    assertThat(x4.closed, is(false));
    assertThat(x8.closed, is(false));
}
项目:metaworks_framework    文件:EntityConfiguration.java   
@PostConstruct
public void configureMergedItems() {
    Set<Resource> temp = new LinkedHashSet<Resource>();
    if (mergedEntityContexts != null && !mergedEntityContexts.isEmpty()) {
        for (String location : mergedEntityContexts) {
            temp.add(webApplicationContext.getResource(location));
        }
    }
    if (entityContexts != null) {
        for (Resource resource : entityContexts) {
            temp.add(resource);
        }
    }
    entityContexts = temp.toArray(new Resource[temp.size()]);
    applicationcontext = new GenericXmlApplicationContext(entityContexts);
}
项目:SparkCommerce    文件:EntityConfiguration.java   
@PostConstruct
public void configureMergedItems() {
    Set<Resource> temp = new LinkedHashSet<Resource>();
    if (mergedEntityContexts != null && !mergedEntityContexts.isEmpty()) {
        for (String location : mergedEntityContexts) {
            temp.add(webApplicationContext.getResource(location));
        }
    }
    if (entityContexts != null) {
        for (Resource resource : entityContexts) {
            temp.add(resource);
        }
    }
    entityContexts = temp.toArray(new Resource[temp.size()]);
    applicationcontext = new GenericXmlApplicationContext(entityContexts);
}
项目:SecureBPMN    文件:SpringConfigurationHelper.java   
public static ProcessEngine buildProcessEngine(URL resource) {
  log.fine("==== BUILDING SPRING APPLICATION CONTEXT AND PROCESS ENGINE =========================================");

  ApplicationContext applicationContext = new GenericXmlApplicationContext(new UrlResource(resource));
  Map<String, ProcessEngine> beansOfType = applicationContext.getBeansOfType(ProcessEngine.class);
  if ( (beansOfType==null)
       || (beansOfType.isEmpty())
     ) {
    throw new ActivitiException("no "+ProcessEngine.class.getName()+" defined in the application context "+resource.toString());
  }

  ProcessEngine processEngine = beansOfType.values().iterator().next();

  log.fine("==== SPRING PROCESS ENGINE CREATED ==================================================================");
  return processEngine;
}
项目:blcdemo    文件:EntityConfiguration.java   
@PostConstruct
public void configureMergedItems() {
    Set<Resource> temp = new LinkedHashSet<Resource>();
    if (mergedEntityContexts != null && !mergedEntityContexts.isEmpty()) {
        for (String location : mergedEntityContexts) {
            temp.add(webApplicationContext.getResource(location));
        }
    }
    if (entityContexts != null) {
        for (Resource resource : entityContexts) {
            temp.add(resource);
        }
    }
    entityContexts = temp.toArray(new Resource[temp.size()]);
    applicationcontext = new GenericXmlApplicationContext(entityContexts);
}
项目:civilizer    文件:WebFileBoxTest.java   
private static void renewTestData() {
    ctx = new GenericXmlApplicationContext();
    ctx.load("classpath:datasource-context-h2-embedded.xml");
    ctx.refresh();

    fileEntityDao = ctx.getBean("fileEntityDao", FileEntityDao.class);
    assertNotNull(fileEntityDao);

    try {
        FileUtils.deleteDirectory(new File(filesHomePath));
    } catch (IOException e) {
        e.printStackTrace();
    }

    TestUtil.touchTestFilesForFileBox(fileEntityDao);
}
项目:cosmo    文件:SpringContextInitializerListener.java   
private void enhanceExistingSpringWebApplicationContext(ServletContextEvent sce, WebApplicationContext wac) {

    LOGGER.info("Enhancing existing Spring application context...");

    String cosmoContextLocation = sce.getServletContext().getInitParameter(CONTEXT_PARAM_NAME);

    @SuppressWarnings("resource")
    GenericXmlApplicationContext cosmoAppCtxt = new GenericXmlApplicationContext();
    cosmoAppCtxt.setEnvironment((ConfigurableEnvironment) wac.getEnvironment());
    cosmoAppCtxt.load(cosmoContextLocation);
    cosmoAppCtxt.refresh();
    cosmoAppCtxt.start();

    //make beans that are required from web components (as delegating filter proxy) accesible
    ((AbstractRefreshableWebApplicationContext)wac).getBeanFactory().setParentBeanFactory(cosmoAppCtxt.getBeanFactory());
    LOGGER.info("Enhanced existing Spring application context started");
}
项目:ds4p    文件:ScheduledTaskRunner.java   
/**
 * The main method.
 * 
 * @param args
 *            the arguments
 * @throws Exception
 *             the exception
 */
public static void main(String[] args) throws Exception {
    logger.info("Starting at {}...", new Date().toString());

    try {
        GenericXmlApplicationContext context = new GenericXmlApplicationContext();
        context.load("classpath:/META-INF/spring/applicationContext*.xml");
        context.refresh();
    } catch (Exception e) {
        logger.error("Error occurred:", e);
        throw e;
    }

    while (true) {
    }
}
项目:ds4p    文件:ApplicationContextAnotherIntegrationTest.java   
@Test
public void bootstrapAppFromXml() {
    // Here cannot use WEB-INF/spring/root-context.xml
    GenericXmlApplicationContext context = new GenericXmlApplicationContext();
    context.load("classpath:META-INF/spring/applicationContext*.xml");
    context.refresh();

    assertThat(context, is(notNullValue()));

    // EchoSignPollingService
    EsignaturePollingService esignaturePollingService = (EsignaturePollingService)(context.getBean("esignaturePollingService"));
    assertNotNull(esignaturePollingService);

    // EchoSignPollingService
    //EchoSignPollingService echoSignPollingService = (EchoSignPollingService)(context.getBean("esignaturePollingService"));
    //assertNotNull(echoSignPollingService);
}
项目:epcis    文件:MysqlQueryServiceSpring.java   
public void unsubscribe(String subscriptionID) {
    ApplicationContext ctx = new GenericXmlApplicationContext(
            "classpath:MongoConfig.xml");
    MongoOperations mongoOperation = (MongoOperations) ctx
            .getBean("mongoTemplate");

    // Its size should be 0 or 1
    List<SubscriptionType> subscriptions = mongoOperation.find(new Query(
            Criteria.where("subscriptionID").is(subscriptionID)),
            SubscriptionType.class);

    for (int i = 0; i < subscriptions.size(); i++) {
        SubscriptionType subscription = subscriptions.get(i);
        // Remove from current Quartz
        removeScheduleFromQuartz(subscription);
        // Remove from DB list
        removeScheduleFromDB(mongoOperation, subscription);
    }
    ((AbstractApplicationContext) ctx).close();
}
项目:epcis    文件:MysqlQueryServiceSpring.java   
public String getSubscriptionIDsREST(@PathVariable String queryName) {

        ApplicationContext ctx = new GenericXmlApplicationContext(
                "classpath:MongoConfig.xml");
        MongoOperations mongoOperation = (MongoOperations) ctx
                .getBean("mongoTemplate");

        List<SubscriptionType> allSubscription = mongoOperation.find(new Query(
                Criteria.where("queryName").is(queryName)),
                SubscriptionType.class);

        JSONArray retArray = new JSONArray();
        for (int i = 0; i < allSubscription.size(); i++) {
            SubscriptionType subscription = allSubscription.get(i);
            retArray.put(subscription.getSubscriptionID());
        }
        ((AbstractApplicationContext) ctx).close();
        return retArray.toString(1);
    }
项目:epcis    文件:MysqlQueryServiceSpring.java   
public List<String> getSubscriptionIDs(String queryName) {
    ApplicationContext ctx = new GenericXmlApplicationContext(
            "classpath:MongoConfig.xml");
    MongoOperations mongoOperation = (MongoOperations) ctx
            .getBean("mongoTemplate");

    List<SubscriptionType> allSubscription = mongoOperation.find(new Query(
            Criteria.where("queryName").is(queryName)),
            SubscriptionType.class);
    List<String> retList = new ArrayList<String>();
    for (int i = 0; i < allSubscription.size(); i++) {
        SubscriptionType subscription = allSubscription.get(i);
        retList.add(subscription.getSubscriptionID());
    }
    ((AbstractApplicationContext) ctx).close();
    return retList;
}
项目:class-guard    文件:GroovyAspectIntegrationTests.java   
@Test
public void testJavaBean() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-java-context.xml");
    TestService bean = context.getBean("javaBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (RuntimeException ex) {
        assertEquals("TestServiceImpl", ex.getMessage());
    }
    assertEquals(1, logAdvice.getCountThrows());

}
项目:class-guard    文件:GroovyAspectIntegrationTests.java   
@Test
public void testGroovyBeanInterface() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-groovy-interface-context.xml");
    TestService bean = context.getBean("groovyBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (RuntimeException ex) {
        assertEquals("GroovyServiceImpl", ex.getMessage());
    }
    assertEquals(1, logAdvice.getCountThrows());
}
项目:class-guard    文件:GroovyAspectIntegrationTests.java   
@Test
public void testGroovyBeanDynamic() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-groovy-dynamic-context.xml");
    TestService bean = context.getBean("groovyBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (RuntimeException ex) {
        assertEquals("GroovyServiceImpl", ex.getMessage());
    }
    // No proxy here because the pointcut only applies to the concrete class, not the interface
    assertEquals(0, logAdvice.getCountThrows());
    assertEquals(0, logAdvice.getCountBefore());
}
项目:class-guard    文件:GroovyAspectIntegrationTests.java   
@Test
public void testGroovyBeanProxyTargetClass() {
    context = new GenericXmlApplicationContext(getClass(), getClass().getSimpleName()+"-groovy-proxy-target-class-context.xml");
    TestService bean = context.getBean("groovyBean", TestService.class);
    LogUserAdvice logAdvice = context.getBean(LogUserAdvice.class);

    assertEquals(0, logAdvice.getCountThrows());
    try {
        bean.sayHello();
        fail("Expected exception");
    }
    catch (TestException ex) {
        assertEquals("GroovyServiceImpl", ex.getMessage());
    }
    assertEquals(1, logAdvice.getCountBefore());
    assertEquals(1, logAdvice.getCountThrows());
}
项目:class-guard    文件:DestroyMethodInferenceTests.java   
@Test
public void xml() {
    ConfigurableApplicationContext ctx = new GenericXmlApplicationContext(
            getClass(), "DestroyMethodInferenceTests-context.xml");
    WithLocalCloseMethod x1 = ctx.getBean("x1", WithLocalCloseMethod.class);
    WithLocalCloseMethod x2 = ctx.getBean("x2", WithLocalCloseMethod.class);
    WithLocalCloseMethod x3 = ctx.getBean("x3", WithLocalCloseMethod.class);
    WithNoCloseMethod x4 = ctx.getBean("x4", WithNoCloseMethod.class);
    assertThat(x1.closed, is(false));
    assertThat(x2.closed, is(false));
    assertThat(x3.closed, is(false));
    assertThat(x4.closed, is(false));
    ctx.close();
    assertThat(x1.closed, is(false));
    assertThat(x2.closed, is(true));
    assertThat(x3.closed, is(true));
    assertThat(x4.closed, is(false));
}
项目:class-guard    文件:EnvironmentIntegrationTests.java   
@Test
public void genericXmlApplicationContext() {
    GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();

    assertHasStandardEnvironment(ctx);

    ctx.setEnvironment(prodEnv);

    ctx.load(XML_PATH);
    ctx.refresh();

    assertHasEnvironment(ctx, prodEnv);
    assertEnvironmentBeanRegistered(ctx);
    assertEnvironmentAwareInvoked(ctx, prodEnv);
    assertThat(ctx.containsBean(DEV_BEAN_NAME), is(false));
    assertThat(ctx.containsBean(PROD_BEAN_NAME), is(true));
}
项目:netTransformer    文件:SpringBasedNetworkDiscovererFactory.java   
private NetworkDiscoverer createNetworkDiscoverer(String projectPath, String version, int initialNumberOfThreads, int maxNumberOfThreads) {

        GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();
        ctx.load("classpath:netDiscoverer/netDiscoverer.xml");
        ctx.load("classpath:csvConnectionDetails/csvConnectionDetailsFactory.xml");

        AbstractBeanDefinition projectPathBeanDefinition = BeanDefinitionBuilder.rootBeanDefinition(String.class)
                .addConstructorArgValue(projectPath).getBeanDefinition();

        BeanDefinition labelDirNameBeanDefinition = BeanDefinitionBuilder.
                rootBeanDefinition(String.class)
                .addConstructorArgValue(version).getBeanDefinition();

        BeanDefinition versionBeanDefinition = BeanDefinitionBuilder.
                rootBeanDefinition(String.class)
                .addConstructorArgValue(version).getBeanDefinition();

        ctx.registerBeanDefinition("projectPath", projectPathBeanDefinition);
        ctx.registerBeanDefinition("labelDirName", labelDirNameBeanDefinition);
        ctx.registerBeanDefinition("version", versionBeanDefinition);
        ctx.refresh();
        NetworkDiscoverer discoverer = ctx.getBean("parallelSnmpDiscovery", NetworkDiscoverer.class);

        return  discoverer;

    }
项目:netTransformer    文件:FileBasedProjectManagerTest.java   
@Before
public void setup() {
    String baseDir = System.getProperty("base.dir");
    if (baseDir==null){
        baseDir=".";
    }
    System.out.println("BaseDir:"+new File(baseDir).getAbsolutePath());

    Map<String,String> properties = new HashMap<>();
    String projectDir = new File(baseDir,"projectManager/fileBasedProjectManager/src/test/resources").getAbsolutePath();

    properties.put("baseDir", baseDir);
    GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();
    ctx.refresh();

    ctx.load("classpath:fileBasedProjectManager/fileBasedProjectManager.xml");
    FileBasedProjectManagerFactory fileBasedProjectManagerFactory = ctx.getBean("projectManagerFactory", FileBasedProjectManagerFactory.class);
    fileBasedProjectManager = fileBasedProjectManagerFactory.createProjectManager(properties);
    projectName = fileBasedProjectManager.randomProjectNameGenerator(projectDir);
}
项目:netTransformer    文件:DiscoveryResultTopologyViewerFactory.java   
private TopologyViewer createTopologyViewer(String projectPath, String projectType) {
    GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();
    ctx.load("classpath:discoveryResultTopologyViewer/discoveryResultTopologyViewer.xml");
    ctx.load("classpath:xmlTopologyViewerConfig/xmlTopologyViewerConfig.xml");
    ctx.load("classpath:xmlNodeDataProvider/xmlNodeDataProvider.xml");
    AbstractBeanDefinition projectPathBeanDefinition = BeanDefinitionBuilder.rootBeanDefinition(String.class)
            .addConstructorArgValue(projectPath).getBeanDefinition();

    AbstractBeanDefinition projectTypeBeanDefinition = BeanDefinitionBuilder.rootBeanDefinition(String.class)
            .addConstructorArgValue(projectType).getBeanDefinition();

    ctx.registerBeanDefinition("projectPath", projectPathBeanDefinition);
    ctx.registerBeanDefinition("projectType", projectTypeBeanDefinition);

    ctx.refresh();

    TopologyViewer topologyViewer = ctx.getBean("discoveryResultTopologyViewer", TopologyViewer.class);

    return  topologyViewer;

}
项目:spring-cloud-aws    文件:StackConfigurationBeanDefinitionParserTest.java   
@Test
public void resourceIdResolver_stackConfiguration_resourceIdResolverBeanExposed() {
    // Arrange
    GenericXmlApplicationContext applicationContext = new GenericXmlApplicationContext();
    AmazonCloudFormation amazonCloudFormation = Mockito.mock(AmazonCloudFormation.class);

    when(amazonCloudFormation.listStackResources(new ListStackResourcesRequest().withStackName("IntegrationTestStack"))).
            thenReturn(new ListStackResourcesResult().withStackResourceSummaries(new StackResourceSummary()));

    applicationContext.load(new ClassPathResource(getClass().getSimpleName() + "-staticStackName.xml", getClass()));
    applicationContext.getBeanFactory().registerSingleton(getBeanName(AmazonCloudFormation.class.getName()), amazonCloudFormation);

    applicationContext.refresh();

    // Act
    ResourceIdResolver resourceIdResolver = applicationContext.getBean(ResourceIdResolver.class);

    // Assert
    assertThat(resourceIdResolver, is(not(nullValue())));
}
项目:spring-cloud-aws    文件:StackConfigurationBeanDefinitionParserTest.java   
@Test
public void stackResourceRegistry_stackConfigurationWithStaticName_stackResourceRegistryBeanExposedUnderStaticStackName() throws Exception {
    // Arrange
    GenericXmlApplicationContext applicationContext = new GenericXmlApplicationContext();
    AmazonCloudFormation amazonCloudFormation = Mockito.mock(AmazonCloudFormation.class);

    when(amazonCloudFormation.listStackResources(new ListStackResourcesRequest().withStackName("IntegrationTestStack"))).
            thenReturn(new ListStackResourcesResult().withStackResourceSummaries(new StackResourceSummary()));

    applicationContext.load(new ClassPathResource(getClass().getSimpleName() + "-staticStackName.xml", getClass()));
    applicationContext.getBeanFactory().registerSingleton(getBeanName(AmazonCloudFormation.class.getName()), amazonCloudFormation);

    applicationContext.refresh();

    // Act
    StackResourceRegistry staticStackNameProviderBasedStackResourceRegistry = applicationContext.getBean("IntegrationTestStack", StackResourceRegistry.class);

    // Assert
    assertThat(staticStackNameProviderBasedStackResourceRegistry, is(not(nullValue())));
}
项目:spring-cloud-aws    文件:StackConfigurationBeanDefinitionParserTest.java   
@Test
public void resourceIdResolverResolveToPhysicalResourceId_stackConfigurationWithStaticNameAndLogicalResourceIdOfExistingResourceProvided_returnsPhysicalResourceId() {
    // Arrange
    GenericXmlApplicationContext applicationContext = new GenericXmlApplicationContext();
    AmazonCloudFormation amazonCloudFormation = Mockito.mock(AmazonCloudFormation.class);

    when(amazonCloudFormation.listStackResources(new ListStackResourcesRequest().withStackName("IntegrationTestStack"))).
            thenReturn(new ListStackResourcesResult().withStackResourceSummaries(
                    new StackResourceSummary().withLogicalResourceId("EmptyBucket").withPhysicalResourceId("integrationteststack-emptybucket-foo")));

    applicationContext.load(new ClassPathResource(getClass().getSimpleName() + "-staticStackName.xml", getClass()));
    applicationContext.getBeanFactory().registerSingleton(getBeanName(AmazonCloudFormation.class.getName()), amazonCloudFormation);

    applicationContext.refresh();

    ResourceIdResolver resourceIdResolver = applicationContext.getBean(ResourceIdResolver.class);

    // Act
    String physicalResourceId = resourceIdResolver.resolveToPhysicalResourceId("EmptyBucket");

    // Assert
    assertThat(physicalResourceId, startsWith("integrationteststack-emptybucket-"));
}
项目:spring-cloud-aws    文件:StackConfigurationBeanDefinitionParserTest.java   
@Test
public void resourceIdResolverResolveToPhysicalResourceId_logicalResourceIdOfNonExistingResourceProvided_returnsLogicalResourceIdAsPhysicalResourceId() {
    // Arrange
    GenericXmlApplicationContext applicationContext = new GenericXmlApplicationContext();
    AmazonCloudFormation amazonCloudFormation = Mockito.mock(AmazonCloudFormation.class);

    when(amazonCloudFormation.listStackResources(new ListStackResourcesRequest().withStackName("IntegrationTestStack"))).
            thenReturn(new ListStackResourcesResult().withStackResourceSummaries(new StackResourceSummary()));

    applicationContext.load(new ClassPathResource(getClass().getSimpleName() + "-staticStackName.xml", getClass()));
    applicationContext.getBeanFactory().registerSingleton(getBeanName(AmazonCloudFormation.class.getName()), amazonCloudFormation);

    applicationContext.refresh();
    ResourceIdResolver resourceIdResolver = applicationContext.getBean(ResourceIdResolver.class);

    // Act
    String physicalResourceId = resourceIdResolver.resolveToPhysicalResourceId("nonExistingLogicalResourceId");

    // Assert
    assertThat(physicalResourceId, is("nonExistingLogicalResourceId"));
}
项目:Reconciliation-and-Matching-Framework    文件:MatchConfigurationTestingStepdefs.java   
private LuceneMatcher getConfiguration(String config) throws Throwable {
    logger.debug("Considering initialising match controller with configuration {}", config);

    // Load up the matchers from the specified files
    if (!matchers.containsKey(config)){
        String configurationFile = "/META-INF/spring/reconciliation-service/" + config + ".xml";
        logger.debug("Loading configuration {} from {}", config, configurationFile);
        ConfigurableApplicationContext context = new GenericXmlApplicationContext(configurationFile);
        LuceneMatcher matcher = context.getBean("engine", LuceneMatcher.class);
        matcher.loadData();
        logger.debug("Loaded data for configuration {}", config);
        matchers.put(config, matcher);
        logger.debug("Stored matcher with name {} from configuration {}", matcher.getConfig().getName(), config);
    }

    return matchers.get(config);
}
项目:Reconciliation-and-Matching-Framework    文件:CoreApp.java   
public static void main(String[] args) throws Exception {

        // Some arguments possibly want to be picked up from the command-line
        CommandLine line = getParsedCommandLine(args);

        // where is the work directory that contains the design configuration as well
        // as the data files?
        String workDir = ".";
        if (line.hasOption("d")) workDir = line.getOptionValue("d").trim();
        // the name of the core configuration file that contains the dedup/match design
        // NOTE this is relative to the working directory
        String configFileName = "config.xml";
        if (line.hasOption("c")) configFileName = line.getOptionValue("c").trim();
        String dedupDesign = "file:" + new File(new File(workDir), configFileName).toPath();

        runEngineAndCache(new GenericXmlApplicationContext(dedupDesign));

    }
项目:Reconciliation-and-Matching-Framework    文件:MatchConfigurationTestingStepdefs.java   
private LuceneMatcher getConfiguration(String config) throws Throwable {
    logger.debug("Considering initialising match controller with configuration {}", config);

    // Load up the matchers from the specified files
    if (!matchers.containsKey(config)){
        String configurationFile = "/META-INF/spring/reconciliation-service/" + config + ".xml";
        logger.debug("Loading configuration {} from {}", config, configurationFile);
        ConfigurableApplicationContext context = new GenericXmlApplicationContext(configurationFile);
        LuceneMatcher matcher = context.getBean("engine", LuceneMatcher.class);
        matcher.loadData();
        logger.debug("Loaded data for configuration {}", config);
        matchers.put(config, matcher);
        logger.debug("Stored matcher with name {} from configuration {}", matcher.getConfig().getName(), config);
    }

    return matchers.get(config);
}
项目:FiWare-Template-Handler    文件:SpringConfigurationHelper.java   
public static ProcessEngine buildProcessEngine(URL resource) {
  log.fine("==== BUILDING SPRING APPLICATION CONTEXT AND PROCESS ENGINE =========================================");

  ApplicationContext applicationContext = new GenericXmlApplicationContext(new UrlResource(resource));
  Map<String, ProcessEngine> beansOfType = applicationContext.getBeansOfType(ProcessEngine.class);
  if ( (beansOfType==null)
       || (beansOfType.isEmpty())
     ) {
    throw new ActivitiException("no "+ProcessEngine.class.getName()+" defined in the application context "+resource.toString());
  }

  ProcessEngine processEngine = beansOfType.values().iterator().next();

  log.fine("==== SPRING PROCESS ENGINE CREATED ==================================================================");
  return processEngine;
}
项目:Easy-Cassandra-samples    文件:App.java   
public static void main(String[] args) throws IOException, ParseException {
    @SuppressWarnings("resource")
    ApplicationContext ctx = new GenericXmlApplicationContext("SpringConfig.xml");
    Musics musicas = ctx.getBean(Musics.class);
    MusicService service = ctx.getBean(MusicService.class);
    for (Music musica: musicas.getMusics()) {
        service.save(musica);   
    }
    LuceneUtil.INSTANCE.backupToHD();
    System.out.println(service.findMusicByLyric("lepo lepo"));
    System.out.println(service.findMusicByLyric("aMoR"));

    System.out.println(service.findMusicByAuthor("Luan Santana"));
    System.out.println(service.findMusicByAuthor("Santana"));
    System.out.println(service.findMusicByAuthor("Psirico"));
}
项目:javaconfig-ftw    文件:SpringConfigurationHelper.java   
public static ProcessEngine buildProcessEngine(URL resource) {
  log.debug("==== BUILDING SPRING APPLICATION CONTEXT AND PROCESS ENGINE =========================================");

  ApplicationContext applicationContext = new GenericXmlApplicationContext(new UrlResource(resource));
  Map<String, ProcessEngine> beansOfType = applicationContext.getBeansOfType(ProcessEngine.class);
  if ( (beansOfType==null)
       || (beansOfType.isEmpty())
     ) {
    throw new ActivitiException("no "+ProcessEngine.class.getName()+" defined in the application context "+resource.toString());
  }

  ProcessEngine processEngine = beansOfType.values().iterator().next();

  log.debug("==== SPRING PROCESS ENGINE CREATED ==================================================================");
  return processEngine;
}
项目:camunda-bpm-platform    文件:SpringConfigurationHelper.java   
public static ProcessEngine buildProcessEngine(URL resource) {
  log.fine("==== BUILDING SPRING APPLICATION CONTEXT AND PROCESS ENGINE =========================================");

  ApplicationContext applicationContext = new GenericXmlApplicationContext(new UrlResource(resource));
  Map<String, ProcessEngine> beansOfType = applicationContext.getBeansOfType(ProcessEngine.class);
  if ( (beansOfType==null)
       || (beansOfType.isEmpty())
     ) {
    throw new ProcessEngineException("no "+ProcessEngine.class.getName()+" defined in the application context "+resource.toString());
  }

  ProcessEngine processEngine = beansOfType.values().iterator().next();

  log.fine("==== SPRING PROCESS ENGINE CREATED ==================================================================");
  return processEngine;
}
项目:Lagerta    文件:DifferentJVMClusterManager.java   
@Override
public Ignite startCluster(int clusterSize) {
    this.clusterSize = clusterSize;
    clientNode = new GenericXmlApplicationContext(CONFIG_XML).getBean(Ignite.class);
    processes = new ArrayList<>(clusterSize);
    startServerNodes(clusterSize);
    igniteStopper = new IgniteStopper(clientNode);
    cacheConfigs = getNonSystemCacheConfigs();
    serviceConfigs = clientNode.configuration().getServiceConfiguration();
    return clientNode;
}
项目:Lagerta    文件:TestsHelper.java   
private static IgniteConfiguration getIgniteConfigFromCommandLineArgs(String[] args) {
    if (args.length < 1) {
        throw new RuntimeException("Xml config path not passed");
    }
    ApplicationContext appContext = new GenericXmlApplicationContext(args[0]);
    return appContext.getBean(IgniteConfiguration.class);
}