Java Code Examples for org.springframework.context.support.ClassPathXmlApplicationContext

/** 
 * <p>Sets up the test environment.</p>
 */
@Before public void setUp(){
  ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("testApplicationContext.xml");
  TestScopeApplicationContext testScopeApplicationContext=new TestScopeApplicationContext(applicationContext,true);
  instance=new MockAbstractSpringInjectionEnricher();
  ((MockAbstractSpringInjectionEnricher)instance).setTestScopeApplicationContext(testScopeApplicationContext);
}
 

public TicketRegistry getNewTicketRegistry() throws Exception {
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(APPLICATION_CONTEXT_FILE_NAME);
  this.registry=(JBossCacheTicketRegistry)context.getBean(APPLICATION_CONTEXT_CACHE_BEAN_NAME);
  this.treeCache=(Cache<String,Ticket>)context.getBean("cache");
  this.treeCache.removeNode("/ticket");
  return this.registry;
}
 

private <T,N>void runAllCombinations(Checker checker) throws Throwable {
  for (  String clusterManager : clusterManagers) {
    ClassPathXmlApplicationContext actx=new ClassPathXmlApplicationContext(clusterManager);
    actx.registerShutdownHook();
    ClusterInfoSessionFactory factory=(ClusterInfoSessionFactory)actx.getBean("clusterSessionFactory");
    if (checker != null)     checker.check("pass for:" + clusterManager,factory);
    actx.stop();
    actx.destroy();
  }
}
 

public String send(String msg){
  ClassPathXmlApplicationContext springContext=new ClassPathXmlApplicationContext("classpath:/camel-client.xml");
  String batch="";
  batch+="<batch-execution lookup=\"ksession1\">\n";
  batch+="  <insert out-identifier=\"message\">\n";
  batch+="      <org.test.Message>\n";
  batch+="         <text>" + msg + "</text>\n";
  batch+="      </org.test.Message>\n";
  batch+="   </insert>\n";
  batch+="</batch-execution>\n";
  CamelServerApp test=new CamelServerApp();
  String response=test.execute(batch,(CamelContext)springContext.getBean("camel"));
  return response;
}
 

public static void main(String args[]) throws Exception {
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"classpath:client-applicationContext.xml"});
  CustomerServiceTester client=(CustomerServiceTester)context.getBean("tester");
  client.testCustomerService();
  System.exit(0);
}
 

public static void main(String[] args) throws Exception {
  String resource[]={"spring-cache-client-core.xml","spring-cache-client-region-only.xml","spring-cache-templates.xml","spring-command-processor.xml","spring-datasync.xml"};
  ClassPathXmlApplicationContext mainContext=new ClassPathXmlApplicationContext(resource,false);
  mainContext.setValidating(true);
  mainContext.refresh();
  ICommandProcessor cp=mainContext.getBean(ICommandProcessor.DEFAULT_PROCESSOR_NAME,ICommandProcessor.class);
  cp.run(mainContext);
}
 

@Test public void testConstructionFromSpringBean() throws TicketValidationException, UnsupportedEncodingException {
  final ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("classpath:cas20ProxyTicketValidator.xml");
  final Cas20ProxyTicketValidator v=(Cas20ProxyTicketValidator)context.getBean("proxyTicketValidator");
  final String USERNAME="username";
  final String RESPONSE="<cas:serviceResponse xmlns:cas='http://www.yale.edu/tp/cas'><cas:authenticationSuccess><cas:user>username</cas:user><cas:proxyGrantingTicket>PGTIOU-84678-8a9d...</cas:proxyGrantingTicket><cas:proxies><cas:proxy>proxy1</cas:proxy><cas:proxy>proxy2</cas:proxy><cas:proxy>proxy3</cas:proxy></cas:proxies></cas:authenticationSuccess></cas:serviceResponse>";
  server.content=RESPONSE.getBytes(server.encoding);
  final Assertion assertion=v.validate("test","test");
  assertEquals(USERNAME,assertion.getPrincipal().getName());
}
 

@Test public void testWithSpring() throws ClassNotFoundException, IllegalArgumentException, SecurityException, IllegalAccessException, InvocationTargetException, NoSuchMethodException {
  ClassPathXmlApplicationContext appContext=new ClassPathXmlApplicationContext("classpath:spring-test.xml");
  Object test1=appContext.getBean("test1");
  Object test2=appContext.getBean("test2");
  assertEquals("org.xeustechnologies.jcl.JarClassLoader",test1.getClass().getClassLoader().getClass().getName());
  assertEquals("sun.misc.Launcher$AppClassLoader",test2.getClass().getClassLoader().getClass().getName());
}
 

public static void main(String args[]) throws Exception {
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"client-beans.xml"});
  HelloWorld client=(HelloWorld)context.getBean("client");
  String response=client.sayHi("Joe");
  System.out.println("Response: " + response);
  System.exit(0);
}
 

public static void main(String[] args){
  log.info("Starting Analysis Server...");
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("/analysis-server.xml");
  AnalysisRequestManager manager=(AnalysisRequestManager)context.getBean("analysisManager");
  log.info("READY: " + manager.getConanTaskService().getTasks().toString());
}
 

@Test public void setLocation(){
  System.setProperty("portal.override.properties","classpath:portal-test.properties");
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("applicationContext-test.xml");
  final StringBuffer testBean=(StringBuffer)context.getBean("testBean");
  assertEquals("Dummy value",testBean.toString());
}
 

/** 
 * @param args
 */
public static void main(String[] args) throws Exception {
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("aggregator-config.xml",TimeBasedAggregationDemo.class);
  MessageChannel inChannel=context.getBean("inChannel",MessageChannel.class);
  Random random=new Random();
  while (true) {
    inChannel.send(MessageBuilder.withPayload("VMW").setHeader("price",95 + random.nextDouble()).build());
    Thread.sleep(random.nextInt(687));
  }
}
 

public static void main(String[] args){
  ClassPathXmlApplicationContext ctx=new ClassPathXmlApplicationContext("applicationContext.xml");
  IMyEntityService service=(IMyEntityService)ctx.getBean("entityService");
  MyEntity entity=new MyEntity();
  entity.setName("Pavel");
  service.saveEntity(entity);
}
 

@Test public void testFilterDefinition(){
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("org/apache/shiro/spring/web/ShiroFilterFactoryBeanTest.xml");
  AbstractShiroFilter shiroFilter=(AbstractShiroFilter)context.getBean("shiroFilter");
  PathMatchingFilterChainResolver resolver=(PathMatchingFilterChainResolver)shiroFilter.getFilterChainResolver();
  DefaultFilterChainManager fcManager=(DefaultFilterChainManager)resolver.getFilterChainManager();
  NamedFilterList chain=fcManager.getChain("/test");
  assertNotNull(chain);
  assertEquals(chain.size(),2);
  Filter[] filters=new Filter[chain.size()];
  filters=chain.toArray(filters);
  assertTrue(filters[0] instanceof DummyFilter);
  assertTrue(filters[1] instanceof FormAuthenticationFilter);
}
 

@Test public void testContext() throws Exception {
  ClassPathXmlApplicationContext parent=new ClassPathXmlApplicationContext("classpath:/server-bootstrap-config.xml");
  try {
    ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"classpath:/servlet-config.xml"},parent);
    context.close();
  }
  finally {
    parent.close();
  }
}
 

private Config assertInjected(String testCase){
  ClassPathXmlApplicationContext ctx=new ClassPathXmlApplicationContext("classpath:org/springframework/data/neo4j/config/DataGraphNamespaceHandlerTest" + testCase + "-context.xml");
  Config config=ctx.getBean("config",Config.class);
  GraphDatabaseContext graphDatabaseContext=config.graphDatabaseContext;
  Assert.assertNotNull("graphDatabaseContext",graphDatabaseContext);
  EmbeddedGraphDatabase graphDatabaseService=(EmbeddedGraphDatabase)graphDatabaseContext.getGraphDatabaseService();
  Assert.assertEquals("store-dir","target/config-test",graphDatabaseService.getStoreDir());
  Assert.assertNotNull("graphRepositoryFactory",config.graphRepositoryFactory);
  Assert.assertNotNull("graphDatabaseService",config.graphDatabaseService);
  Assert.assertNotNull("transactionManager",config.transactionManager);
  config.graphDatabaseService.shutdown();
  return config;
}
 

@Test public void dropsEventIfNotForCorrectDomainType(){
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext();
  context.refresh();
  SamplePersonEventListener listener=new SamplePersonEventListener();
  context.addApplicationListener(listener);
  context.publishEvent(new BeforeConvertEvent<Person>(new Person("Dave","Matthews")));
  assertThat(listener.invokedOnBeforeConvert,is(true));
  listener.invokedOnBeforeConvert=false;
  context.publishEvent(new BeforeConvertEvent<String>("Test"));
  assertThat(listener.invokedOnBeforeConvert,is(false));
}
 

@Override public List<PotentialAssignment> getValueSources(ParameterSignature signature){
  SpringSyntaxTreeExamples annotation=signature.getAnnotation(SpringSyntaxTreeExamples.class);
  ApplicationContext ctx=new ClassPathXmlApplicationContext(annotation.contextLocation());
  @SuppressWarnings("unchecked") Map<String,String> exampleMap=(Map<String,String>)ctx.getBean(annotation.exampleMap());
  List<PotentialAssignment> examples=new ArrayList<PotentialAssignment>();
  for (  Entry<String,String> exampleEntry : exampleMap.entrySet()) {
    SyntaxTreeExample example=new SyntaxTreeExample();
    example.setQuery(exampleEntry.getKey());
    example.setSyntaxTree(exampleEntry.getValue().trim());
    examples.add(example);
  }
  return examples;
}
 

public BasePaymentsTest(){
  super(new WebAppDescriptor.Builder("org.fracturedatlas.athena.web.resource").contextPath("payments").contextParam("contextConfigLocation","classpath:testApplicationContext.xml").servletClass(SpringServlet.class).contextListenerClass(ContextLoaderListener.class).contextParam("javax.ws.rs.Application","org.fracturedatlas.athena.payments.web.config.PaymentsConfig").build());
  ClientConfig cc=new DefaultClientConfig();
  Client c=Client.create(cc);
  webResource=c.resource(BASE_URI);
  webResource.addFilter(new LoggingFilter());
  payments=new AthenaPayments(webResource);
  ApplicationContext context=new ClassPathXmlApplicationContext("testApplicationContext.xml");
}
 

/** 
 * This test checks whether the exceptions will happen during instantiation of cont
 */
@Test public void testNested(){
  ApplicationContext context=new ClassPathXmlApplicationContext("com/griddynamics/banshun/analyzer/root-context.xml");
  Registry registry=(Registry)context.getBean("root");
  SuperInterface first=registry.lookup("firstObject",SuperInterface.class);
  SubInterface second=registry.lookup("secondObject",SubInterface.class);
  assertNotNull(first);
  assertNotNull(second);
}
 

public static void main(String[] args){
  ApplicationContext applicationContext=new ClassPathXmlApplicationContext("classpath:applicationContext-client.xml");
  ProductClient client=applicationContext.getBean("productClient",ProductClient.class);
  credentialFactory=applicationContext.getBean("credentialFactory",CredentialFactory.class);
  apiKey=credentialFactory.getPublisherApiKey();
  publisherId=credentialFactory.getPublisherId();
  client.doProductSearch(apiKey,publisherId,keyword,10);
}
 

@Test public void testSpringWiringOfCometDServices() throws Exception {
  ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext();
  applicationContext.setConfigLocation("classpath:applicationContext.xml");
  applicationContext.refresh();
  String beanName=Introspector.decapitalize(SpringBayeuxService.class.getSimpleName());
  String[] beanNames=applicationContext.getBeanDefinitionNames();
  assertTrue(Arrays.asList(beanNames).contains(beanName));
  SpringBayeuxService service=(SpringBayeuxService)applicationContext.getBean(beanName);
  assertNotNull(service);
  assertNotNull(service.dependency);
  assertNotNull(service.bayeuxServer);
  assertNotNull(service.serverSession);
  assertTrue(service.active);
  assertEquals(1,service.bayeuxServer.getChannel(SpringBayeuxService.CHANNEL).getSubscribers().size());
  applicationContext.close();
  assertFalse(service.active);
}
 

@Test public void givenDevelopmentEnvironmentTheCorrectImportsAreProcessed(){
  ApplicationContext ctx=new ClassPathXmlApplicationContext("org/constretto/spring/namespacehandler/ImportWithSpecifiedResolverTest-context.xml");
  Assert.assertTrue(ctx.containsBean("inMainConfig"));
  Assert.assertFalse(ctx.containsBean("inJunitConfig"));
  Assert.assertTrue(ctx.containsBean("inDevelopmentConfig"));
}
 

@Test public void compilationTest(){
  ApplicationContext context=new ClassPathXmlApplicationContext("META-INF/applicationContext.xml");
  DroolsAgent agent=(DroolsAgent)context.getBean("agent");
  assertNotNull(agent);
  agent.dispose();
}
 

@BeforeClass(dependsOnGroups={"dspaceActionTests"},dependsOnMethods={"init"}) private void initContext(){
  context=new ClassPathXmlApplicationContext("classpath:META-INF/00_system.xml");
  final Properties map=new Properties();
  map.put("openjpa.Id",getDbName());
  map.put("openjpa.ConnectionURL","jdbc:derby:" + getDbPath() + ";create=true");
  final EntityManagerFactory emf=Persistence.createEntityManagerFactory(getDbName(),map);
  setEntityManagerFactory(emf);
}
 

public void testSchema(){
  ApplicationContext context=new ClassPathXmlApplicationContext("org/hdiv/config/xml/hdiv-config-test-schema.xml");
  Validation validation=(Validation)context.getBean("id1");
  assertNotNull(validation);
  System.out.println(validation.toString());
  System.out.println("-----------------------");
  HDIVConfig hdivConfig=(HDIVConfig)context.getBean("config");
  assertNotNull(hdivConfig);
  System.out.println(hdivConfig.toString());
  System.out.println("-----------------------");
  HDIVValidations validations=(HDIVValidations)context.getBean("editableParametersValidations");
  assertNotNull(validations);
  System.out.println(validations.toString());
}
 

public static void main(String[] args) throws Exception {
  try {
    initConnectionProperties(args);
  }
 catch (  Exception e) {
    System.err.println("Error parsing command line connection properties.  Cause: " + e.getMessage());
    e.printStackTrace(System.err);
    System.exit(1);
  }
  final ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext(new String[]{"classpath:/META-INF/spring/hqapi-context.xml","classpath*:/META-INF/**/*commands-context.xml"});
  try {
    final int exitCode=((Shell)applicationContext.getBean("commandDispatcher")).dispatchCommand(args);
    System.exit(exitCode);
  }
 catch (  Exception e) {
    System.err.println("Error running command: " + e.getMessage());
    e.printStackTrace(System.err);
    System.exit(1);
  }
}
 

@Test public void testPropertiesResolver() throws MalformedURLException {
  ApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"spring/test-properties-resolver.xml"});
  Assert.assertEquals(context.getBean("stringA"),"x-override");
  Assert.assertEquals(context.getBean("stringB"),"x-override/ex");
  Assert.assertEquals(context.getBean("stringC"),"x-override/y-default/ex");
  Assert.assertEquals(context.getBean("stringD"),"x-override+y-default");
}
 

public static void main(String[] args){
  final AbstractApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"application-context.xml"});
  println("Context created.");
  final Person person1=(Person)context.getBean("person");
  final BlogPost post1=(BlogPost)context.getBean("blogPost");
  person1.setAge(19);
  post1.setContent("Sample content");
  context.close();
  println("End.");
}
 

@Test public void defaultTracing(){
  ApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"defaultTracing.xml"});
  TracingAspect tracingAspect=(TracingAspect)context.getBean("tracingAspect");
  if (logger.isInfoEnabled())   logger.info("Using tracingAspect {}",tracingAspect);
  ExampleServiceIfc exampleService=(ExampleServiceIfc)context.getBean("exampleService");
  callExampleService(exampleService);
}
 

public ShellMapPrinter(String[] args) throws IOException {
  try {
    GetOptions.parse(args,this);
  }
 catch (  InvalidOption invalidOption) {
    help(invalidOption.getMessage());
  }
  configureLogs();
  this.context=new ClassPathXmlApplicationContext(DEFAULT_SPRING_CONTEXT);
  if (springConfig != null) {
    this.context=new FileSystemXmlApplicationContext(new String[]{"classpath:/" + DEFAULT_SPRING_CONTEXT,springConfig});
  }
}
 

@Override public void init(ServletConfig config) throws ServletException {
  try {
    this.config=config;
    servletContext=config.getServletContext();
    context=new ClassPathXmlApplicationContext(new String[]{"applicationContext.xml"});
    httpManager=(HttpManager)context.getBean("milton.http.manager");
  }
 catch (  Throwable ex) {
    log.error("Exception starting milton servlet",ex);
    throw new RuntimeException(ex);
  }
}
 

@Override public void init(ServletConfig config) throws ServletException {
  try {
    this.config=config;
    servletContext=config.getServletContext();
    context=new ClassPathXmlApplicationContext(new String[]{"applicationContext.xml"});
    httpManager=(HttpManager)context.getBean("milton.http.manager");
  }
 catch (  Throwable ex) {
    log.error("Exception starting milton servlet",ex);
    throw new RuntimeException(ex);
  }
}
 

public ModelManager getModelManager(){
  if (persistenceBeans == null) {
    persistenceBeans=new ClassPathXmlApplicationContext(new String[]{"/META-INF/persistenceContext.xml","/META-INF/test/persistenceContext.xml"});
  }
  return (ModelManager)persistenceBeans.getBean("modelManager");
}
 

@BeforeClass public static void classInit() throws Exception {
  MultiTenantUtil multiTenantUtil=new MultiTenantUtil();
  ReflectionTestUtils.setField(multiTenantUtil,"multiTenantService",new DefaultMultiTenantService());
  multiTenantUtil.init();
  applicationContext=new ClassPathXmlApplicationContext();
  applicationContext.getEnvironment().setActiveProfiles("standalone");
  applicationContext.setConfigLocation("spring.xml");
  applicationContext.refresh();
  dataDefinitionService=applicationContext.getBean(InternalDataDefinitionService.class);
  sessionFactory=applicationContext.getBean("sessionFactory",SessionFactory.class);
  jdbcTemplate=applicationContext.getBean(JdbcTemplate.class);
  verifyHooks=applicationContext.getBean(VerifyHooks.class);
}
 

public Bootstrap() throws ServiceException {
  ClassPathXmlApplicationContext ctx=new ClassPathXmlApplicationContext("classpath:/META-INF/spring-bootstrap.xml");
  rolesAndRights=(RolesAndRights)ctx.getBean("rolesAndRights");
  entityManager=(((EntityManagerFactory)ctx.getBean("entityManagerFactory")).createEntityManager());
  passwordEncoder=(PasswordEncoder)ctx.getBean("passwordEncoder");
  saltSourceUser=(ReflectionSaltSource)ctx.getBean("saltSourceUser");
  saltSourceTrialSite=(SystemWideSaltSource)ctx.getBean("saltSourceTrialSite");
  trialService=(TrialService)ctx.getBean("trialService");
  trialSiteService=(TrialSiteService)ctx.getBean("trialSiteService");
  userService=(UserService)ctx.getBean("userService");
  dataSource=(DataSource)ctx.getBean("dataSource");
  init();
  try {
    IDatabaseConnection conn=new DatabaseConnection(dataSource.getConnection());
    ITableFilter filter=new DatabaseSequenceFilter(conn);
    IDataSet dataset=new FilteredDataSet(filter,conn.createDataSet());
    FlatXmlDataSet.write(dataset,new FileWriter(new File("testDBUNIT.xml")));
  }
 catch (  Exception e) {
    e.printStackTrace();
  }
}
 

@Before public void loadSpringContext() throws IOException {
  context=new ClassPathXmlApplicationContext("/org/red5/spring/placeholder_context.xml");
  testProperties=new Properties();
  testProperties.load(this.getClass().getResourceAsStream("/org/red5/spring/test.properties"));
  testAProperties=new Properties();
  testAProperties.load(this.getClass().getResourceAsStream("/org/red5/spring/test_a.properties"));
  testBProperties=new Properties();
  testBProperties.load(this.getClass().getResourceAsStream("/org/red5/spring/test_b.properties"));
}
 

@Before public void buildContextLoader(){
  loader=new ContextLoader();
  loader.setApplicationContext(new ClassPathXmlApplicationContext("/org/red5/server/parent_context_loader_test.xml"));
  loader.setParentContext(new ClassPathXmlApplicationContext("/org/red5/server/parent_context_loader_test.xml"));
  loader.setContextsConfig("classpath:/org/red5/server/classpath_context_loader_test.properties");
}
 

@Before public void loadSpringContext() throws IOException {
  context=new ClassPathXmlApplicationContext("/org/red5/spring/placeholder_context.xml");
  testProperties=new Properties();
  testProperties.load(this.getClass().getResourceAsStream("/org/red5/spring/test.properties"));
  testAProperties=new Properties();
  testAProperties.load(this.getClass().getResourceAsStream("/org/red5/spring/test_a.properties"));
  testBProperties=new Properties();
  testBProperties.load(this.getClass().getResourceAsStream("/org/red5/spring/test_b.properties"));
}
 

public void initialize(){
  logger.info("Initializing service " + getDescription());
  applicationContext=new ClassPathXmlApplicationContext(new String[]{DefaultConfig.SPRING_CONTEXT_FILE});
  applicationContext.registerShutdownHook();
  initialized=true;
  logger.info(getDescription() + " initialized successfully");
}
 

public void initialize(){
  logger.info("Initializing service " + getDescription());
  applicationContext=new ClassPathXmlApplicationContext(new String[]{DefaultConfig.SPRING_CONTEXT_FILE});
  applicationContext.registerShutdownHook();
  initialized=true;
  logger.info(getDescription() + " initialized successfully");
}
 

private void readyStuff(){
  ApplicationContext appcxt=new ClassPathXmlApplicationContext("AllInOneRepositoryContext.xml");
  generalRepository=(GeneralRepository)appcxt.getBean("generalRepository");
  AnnotApplicationContextMock appctx=new AnnotApplicationContextMock();
  appctx.putBean("generalRepository",generalRepository);
  WicketApplication wicketPersistanceApplication=new WicketApplication();
  wicketPersistanceApplication.setSpringComponentInjector(new SpringComponentInjector(wicketPersistanceApplication,appctx));
  wicketTester=new WicketTester(wicketPersistanceApplication);
}
 

/** 
 * Depends on the presence of a Spring  {@link ApplicationContext} at the locationon the classpath defined by the  {@link #CONFIG_SYSTEM_PROPERTY} System property.
 * @param args
 */
public static void main(String[] args){
  ApplicationContext context=new ClassPathXmlApplicationContext(CONFIG);
  ScheduleOwnerAuditor auditor=(ScheduleOwnerAuditor)context.getBean("scheduleOwnerAuditor");
  List<PersistenceScheduleOwner> allOwnerRecords=auditor.gatherAllScheduleOwnerRecords();
  for (  PersistenceScheduleOwner owner : allOwnerRecords) {
    auditor.auditRecord(owner);
  }
}
 

@Override protected void setUp() throws Exception {
  SingleNodeStarter.start("conf",15000);
  brokerContext=new ClassPathXmlApplicationContext("federatedBroker-context.xml");
  federatedBroker=(FederatedBroker)brokerContext.getBean("federatedBroker",FederatedBroker.class);
  storeClient=(StoreClient<String,String>)brokerContext.getBean("storeClient");
  senseiProxy=(BrokerProxy)brokerContext.getBean("senseiProxy");
  JSONArray arr=readCarDocs();
  storeClient.put("test",arr.toString());
}
 

/** 
 * Sets up the container, sets up logging, and starts the CompetitionControl service. <p> A simple script file can be used in lieu of a web interface to configure and run games. Each line in the file must be in one of two forms:<br/> <code>&nbsp;&nbsp;bootstrap [--config boot-config]</code><br/> <code>&nbsp;&nbsp;sim [--config sim-config] broker1 broker2 ...</code><br/> where  <dl> <dt><code>boot-config</code></dt> <dd>is the optional name of a properties file that specifies the bootstrap setup. If not provided, then the default server.properties will be used.</dd> <dt><code>sim-config</code></dt> <dd>is the optional name of a properties file that specifies the simulation setup. If not provided, then the default server.properties file will be used. It is possible for the sim-config to be different from the boot-config that produced the bootstrap data file used in the sim, but many properties will be carried over from the bootstrap session regardless of the contents of sim-config.</dd> <dt><code>brokern</code></dt> <dd>are the broker usernames of the brokers that will be logged in before the simulation starts. They must attempt to log in after the server starts.</dd> </dl> To use a configuration file, simply give the filename as a command-line argument.
 */
public static void main(String[] args){
  AbstractApplicationContext context=new ClassPathXmlApplicationContext("powertac.xml");
  context.registerShutdownHook();
  css=(CompetitionSetupService)context.getBeansOfType(CompetitionSetupService.class).values().toArray()[0];
  css.processCmdLine(args);
  System.exit(0);
}
 

protected ClassPathXmlApplicationContext createApplicationContext(){
  return new ClassPathXmlApplicationContext("org/apache/servicemix/camel/spring/DummyBean.xml"){
    @Override public <T>T getBean(    String name,    Class<T> requiredType) throws BeansException {
      if (BUS_BEAN_NAME.equals(name)) {
        return requiredType.cast(bus);
      }
      return super.getBean(name,requiredType);
    }
  }
;
}
 

public void testNoRedeploymentForSpringContainerRestart() throws Exception {
  createAppContext(CTX_PATH);
  DeploymentQuery deploymentQuery=repositoryService.createDeploymentQuery();
  assertEquals(1,deploymentQuery.count());
  ProcessDefinitionQuery processDefinitionQuery=repositoryService.createProcessDefinitionQuery();
  assertEquals(3,processDefinitionQuery.count());
  new ClassPathXmlApplicationContext(CTX_NO_DROP_PATH);
  assertEquals(1,deploymentQuery.count());
  assertEquals(3,processDefinitionQuery.count());
}
 

@Test public void testIncompatibleTxAtts(){
  try {
    new ClassPathXmlApplicationContext(getClass().getSimpleName() + "-fail-context.xml",getClass());
    fail("Parse exception exptected");
  }
 catch (  BeanDefinitionParsingException e) {
    assertTrue(e.getMessage().startsWith("Configuration problem: Listener Container - cannot set channel-transacted with acknowledge='NONE'"));
  }
}
 

@Test public void testServletConfiguration() throws Exception {
  ClassPathXmlApplicationContext parent=new ClassPathXmlApplicationContext("classpath:/org/springframework/batch/admin/web/resources/webapp-config.xml");
  ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"classpath:/org/springframework/batch/admin/web/resources/servlet-config.xml"},parent);
  assertTrue(context.containsBean("jobRepository"));
  String[] beanNames=BeanFactoryUtils.beanNamesForTypeIncludingAncestors(context.getBeanFactory(),JobController.class);
  assertEquals(1,beanNames.length);
  Job job=context.getBean(JobRegistry.class).getJob("job1");
  final JobExecution jobExecution=parent.getBean(JobLauncher.class).run(job,new JobParametersBuilder().addString("fail","false").toJobParameters());
  new DirectPoller<BatchStatus>(100).poll(new Callable<BatchStatus>(){
    public BatchStatus call() throws Exception {
      BatchStatus status=jobExecution.getStatus();
      if (status.isLessThan(BatchStatus.STOPPED) && status != BatchStatus.COMPLETED) {
        return null;
      }
      return status;
    }
  }
).get(2000,TimeUnit.MILLISECONDS);
  context.close();
  parent.close();
  assertEquals(BatchStatus.COMPLETED,jobExecution.getStatus());
}
 

/** 
 * Launch Test. 
 */
@Test public void launchJob() throws Exception {
  ConfigurableApplicationContext context=new ClassPathXmlApplicationContext("spring/batch/job/in-memory-job.xml","spring/batch/setup/job-context.xml","spring/batch/setup/job-database.xml");
  Job job=(Job)context.getBean("inMemoryJob");
  JobLauncher launcher=(JobLauncher)context.getBean("jobLauncher");
  Map<String,JobParameter> jobParametersMap=new HashMap<String,JobParameter>();
  jobParametersMap.put("time",new JobParameter(System.currentTimeMillis()));
  jobParametersMap.put("input.file",new JobParameter("file:src/test/resources/input/input.txt"));
  jobParametersMap.put("output.file",new JobParameter("file:target/test-outputs/simple/output.txt"));
  JobExecution jobExecution=launcher.run(job,new JobParameters(jobParametersMap));
  assertEquals(BatchStatus.COMPLETED,jobExecution.getStatus());
}
 

/** 
 * @param args
 */
public static void main(String[] args) throws Exception {
  ApplicationContext ctx=new ClassPathXmlApplicationContext("classpath*:/META-INF/spring/*.xml");
  JobLauncher jobLauncher=ctx.getBean(JobLauncher.class);
  Job job=ctx.getBean(Job.class);
  jobLauncher.run(job,new JobParametersBuilder().addString("hdfsSourceDirectory","/data/analysis/results/part-*").addDate("date",new Date()).toJobParameters());
}
 

public static void main(String[] args){
  System.out.println("Bootstrapping HelloMongo");
  ConfigurableApplicationContext context=null;
  context=new ClassPathXmlApplicationContext("META-INF/spring/bootstrap.xml");
  HelloMongo hello=context.getBean(HelloMongo.class);
  hello.run();
  System.out.println("DONE!");
}
 

/** 
 * Starts the server using Spring configuration.
 */
public void start(){
  try {
    if (isStandAlone()) {
      Runtime.getRuntime().addShutdownHook(new ShutdownHookThread());
    }
    serverName=Config.getString("xmpp.domain","127.0.0.1").toLowerCase();
    context=new ClassPathXmlApplicationContext("spring-config.xml");
    log.info("Spring Configuration loaded.");
    log.info("XmppServer started: " + serverName);
    log.info("Androidpn Server v" + version);
  }
 catch (  Exception e) {
    e.printStackTrace();
    shutdownServer();
  }
}
 

@Ignore public static void main(final String[] args){
  final ApplicationContext applicationContext=new ClassPathXmlApplicationContext("classpath:/spring-trickle.xml");
  final BetDao betDao=(BetDao)applicationContext.getBean("betDao");
  final RaceDao raceDao=(RaceDao)applicationContext.getBean("raceDao");
  final Race race=new Race(867,"Race",new LocalDateTime(2012,2,22,19,19,0),"meeting");
  final Horse horse=new Horse();
  horse.setRunnerId(441);
  horse.setRaceId(867);
  horse.setRace(race);
  race.addHorse(horse);
  final Strategy strategy1=new Strategy();
  strategy1.setBetSecondsBeforeStartTime(Lists.newArrayList(120,270,600));
  final Strategy strategy2=new Strategy();
  strategy2.setBetSecondsBeforeStartTime(Lists.newArrayList(120,270,700));
  raceDao.saveOrUpdate(race);
  final Bet bet1=new Bet(horse,strategy1);
  betDao.saveOrUpdate(bet1);
  final Bet bet2=new Bet(horse,strategy2);
  betDao.saveOrUpdate(bet2);
  System.out.println(betDao.getBetsToPlace());
}
 

/** 
 * Initializes the transformer by retrieving the XSLT document to use and building a transformer from it. 
 * @throws Exception
 */
public void init() throws Exception {
  ApplicationContext ctx=new ClassPathXmlApplicationContext();
  Resource res=ctx.getResource("classpath:/transform/" + xslName);
  Source transformSource=new StreamSource(res.getInputStream());
  TransformerFactory factory=TransformerFactory.newInstance();
  factory.setURIResolver(new URIResolver(){
    public Source resolve(    String href,    String base) throws TransformerException {
      Source result=null;
      if (href.startsWith("/"))       result=new StreamSource(UpdateDocTransformer.class.getResourceAsStream(href));
 else       result=new StreamSource(UpdateDocTransformer.class.getResourceAsStream("/transform/" + href));
      return result;
    }
  }
);
  Templates transformTemplate=factory.newTemplates(transformSource);
  transformer=transformTemplate.newTransformer();
}
 

private HCTConnManager(final String componentName){
  if (!HstServices.isAvailable()) {
    throw new SetupException("HstServices not available");
  }
  final Credentials credentials=HstServices.getComponentManager().getComponent(componentName);
  repository=HstServices.getComponentManager().getComponent(Repository.class.getName());
  try {
    session=repository.login(credentials);
  }
 catch (  RepositoryException e) {
    throw new SetupException("While log in to the Hippo repository",e);
  }
  final MetadataReaderClasspathResourceScanner scanner=new MetadataReaderClasspathResourceScanner();
  scanner.setResourceLoader(new ClassPathXmlApplicationContext());
  try {
    final String[] fallbackNodeTypes=(String[])ArrayUtils.add(ObjectConverterUtils.getDefaultFallbackNodeTypes(),"hippo:compound");
    objConv=ObjectConverterUtils.createObjectConverter(ObjectConverterUtils.getAnnotatedClasses(scanner,"classpath*:net/tirasa/hct/hstbeans/**/*.class"),(Class<? extends HippoBean>[])Constants.DEFAULT_BUILT_IN_MAPPING_CLASSES,fallbackNodeTypes,false);
    objMan=new ObjectBeanManagerImpl(session,objConv);
  }
 catch (  Exception e) {
    throw new SetupException("While creating HST ObjectManager",e);
  }
}
 

/** 
 * @param war
 * @param port
 */
public void start(String war,int port){
  log.info("huahin-manager start");
  ConfigurableApplicationContext applicationContext=null;
  try {
    applicationContext=new ClassPathXmlApplicationContext("huahinManagerProperties.xml");
    Properties properties=(Properties)applicationContext.getBean("properties");
    QueueManager queueManager=new QueueManager(properties);
    RunnableFuture<Void> queueManagerThread=new FutureTask<Void>(queueManager);
    new Thread(queueManagerThread).start();
    SelectChannelConnector connector=new SelectChannelConnector();
    connector.setPort(port);
    Server server=new Server();
    server.setConnectors(new Connector[]{connector});
    WebAppContext web=new WebAppContext();
    web.setContextPath("/");
    web.setWar(war);
    server.addHandler(web);
    server.start();
    server.join();
    queueManagerThread.get();
  }
 catch (  Exception e) {
    log.error("huahin-manager aborted",e);
    System.exit(-1);
  }
 finally {
    if (applicationContext != null) {
      applicationContext.close();
    }
  }
  log.info("huahin-manager end");
}
 

public static void main(String[] args){
  com.sun.net.ssl.internal.ssl.Provider provider=new com.sun.net.ssl.internal.ssl.Provider();
  java.security.Security.addProvider(provider);
  setAllPermissions();
  if (System.getProperty("os.name").toLowerCase().startsWith("mac os x")) {
    System.setProperty("apple.laf.useScreenMenuBar","true");
  }
  Logger log=LoggerFactory.getLogger(ApplicationLauncher.class);
  if (!UIManager.getLookAndFeel().getName().equals(UIManager.getSystemLookAndFeelClassName())) {
    try {
      UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
    }
 catch (    Exception e) {
      log.warn("Unable to change L&F to System",e);
    }
  }
  long start=System.currentTimeMillis();
  Splash splash=new Splash("/images/splash.png");
  splash.setVisible(true);
  splash.setCursor(new Cursor(Cursor.WAIT_CURSOR));
  if (System.getSecurityManager() == null) {
    System.setSecurityManager(new RMISecurityManager());
  }
  new ClassPathXmlApplicationContext("org/pegadi/client/client-context.xml");
  long timeToLogin=System.currentTimeMillis() - start;
  log.info("Connected OK after {} ms",timeToLogin);
  log.info("Java Version {}",System.getProperty("java.version"));
  splash.dispose();
}
 

public void loadAppContext(String appContextFile,boolean loadDefinitionOnStartup){
  if (appContextFile == null) {
    throw new IllegalArgumentException("Argument 'contextFile' is null");
  }
  _appContextFile=SystemPropertyUtils.resolvePlaceholders(appContextFile);
  if (loadDefinitionOnStartup) {
    _beanFactory=new ClassPathXmlApplicationContext(_appContextFile);
  }
 else {
    if (_appContextFile.startsWith(FILE_PREFIX)) {
      _appContextFile=_appContextFile.substring(FILE_PREFIX.length());
    }
    Resource configResource=new FileSystemResource(_appContextFile);
    _beanFactory=new XmlBeanFactory(configResource);
  }
}