org.apache.polygene.api.structure.Application类的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(139)

本文整理了Java中org.apache.polygene.api.structure.Application类的一些代码示例，展示了Application类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Application类的具体详情如下：
包路径：org.apache.polygene.api.structure.Application
类名称：Application

Application介绍

[英]The Application represents a whole Polygene application.
[中]该应用程序代表一个完整的多基因应用程序。

代码示例

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.api

private ApplicationPassivationThread( Application application, PrintStream output, Logger logger )
{
  super( new ApplicationPassivation( application, output, logger ),
      application.name() + " Passivation Thread" );
}

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.testsupport

protected Module metricsModule()
{
  return application.findModule( "infra", "metrics" );
}

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.bootstrap

public void start()
  throws ActivationException
{
  application.activate();
}

代码示例来源：origin: apache/attic-polygene-java

@Override
public void activateService()
  throws IOException
{
  File tmp;
  if( fileConfig == null )
  {
    tmp = new File( "polygene", app.name() + "-" + app.version() );
  }
  else
  {
    tmp = fileConfig.temporaryDirectory();
  }
  workDir = new File( tmp, "uowfile-" + me.identity().get() );
  if( !workDir.exists() && !workDir.mkdirs() )
  {
    throw new IOException( "Unable to create temporary directory: " + workDir );
  }
}

代码示例来源：origin: apache/attic-polygene-java

@Override
public void run()
{
  try
  {
    application.passivate();
  }
  catch( PassivationException ex )
  {
    String message = application.name() + " " + ex.getMessage();
    if( logger != null )
    {
      logger.log( Level.SEVERE, message, ex );
    }
    else if( output != null )
    {
      output.println( message );
      ex.printStackTrace( output );
    }
    else
    {
      ex.printStackTrace();
    }
  }
}

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.testsupport

protected final void assertUowTimer( MetricValuesProvider metrics ) throws PassivationException, ActivationException
{
  Long initialUowCount = metrics.timerCount( UOW_TIMER_NAME );
  runScenario1();
  assertThat( UOW_TIMER_NAME + " count incremented by 3", metrics.timerCount( UOW_TIMER_NAME ), is( initialUowCount + 3L ) );
  application.passivate();
  application.activate();
  assertThat( UOW_TIMER_NAME + " count reset on passivation", metrics.timerCount( UOW_TIMER_NAME ), equalTo( initialUowCount ) );
}

代码示例来源：origin: apache/attic-polygene-java

@Test
public void canCreateAndQueryWithAllInMemory()
  throws Exception
{
  Application application = createApplication( inMemoryRdf, inMemoryStore, domain );
  try
  {
    application.activate();
    Module domain = application.findModule( "Domain", "Domain" );
    UnitOfWorkFactory unitOfWorkFactory = domain.unitOfWorkFactory();
    createABunchOfStuffAndDoQueries( unitOfWorkFactory, domain );
  }
  finally
  {
    application.passivate();
  }
}

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.bootstrap

public void stop()
  throws PassivationException
{
  application.passivate();
}

代码示例来源：origin: apache/attic-polygene-java

public static void main( String[] args )
    throws Exception
  {
    Energy4Java polygene = new Energy4Java(  );

    Server server = new Server( Protocol.HTTP, 8888 );

    Application app = polygene.newApplication( new ForumAssembler(), new MetadataService() );

    app.activate();

    ContextRestlet restlet = app.findModule( "REST", "Restlet" ).newObject( ContextRestlet.class, new org.restlet.Context() );

    ChallengeAuthenticator guard = new ChallengeAuthenticator(null, ChallengeScheme.HTTP_BASIC, "testRealm");
    MapVerifier mapVerifier = new MapVerifier();
    mapVerifier.getLocalSecrets().put("rickard", "secret".toCharArray());
    guard.setVerifier(mapVerifier);

    guard.setNext(restlet);

    server.setNext( restlet );
    server.start();
  }
}

代码示例来源：origin: org.apache.polygene.libraries/org.apache.polygene.library.fileconfig

String application = System.getProperty( "application", app.name() );
if ( !app.mode().equals( Application.Mode.production ) ) {
  application += "-" + app.mode().name();

代码示例来源：origin: apache/attic-polygene-java

@SuppressWarnings( "SameParameterValue" )
protected void addEntityInfoToInsertToEntityTablePS( EntityState state, PreparedStatement ps, int startingIndex )
  throws SQLException
{
  ps.setString( startingIndex, state.entityReference().identity().toString() );
  ps.setTimestamp( startingIndex + 1, Timestamp.from( state.lastModified() ) );
  ps.setString( startingIndex + 2, state.version() );
  ps.setString( startingIndex + 3, this._app.version() );
}

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.bootstrap

for( ActivationEventListener activationListener : activationListeners )
  application.registerActivationEventListener( activationListener );
application.activate();
if( passivationShutdownHook )

代码示例来源：origin: apache/attic-polygene-java

public ServiceFactoryBean( Application anApplication, String aServiceId )
  throws IllegalArgumentException
{
  notNull( anApplication, "Argument [anApplication] must not be [null]." );
  notNull( aServiceId, "Argument [aServiceId] must not be [null]." );
  ServiceLocator serviceLocator = new ServiceLocator( aServiceId );
  anApplication.descriptor().accept( serviceLocator );
  serviceReference = serviceLocator.locateService( anApplication );
  if( serviceReference == null )
  {
    throw new IllegalArgumentException( "Polygene service with id [" + aServiceId + "] is not found." );
  }
}

代码示例来源：origin: apache/attic-polygene-java

@Override
  public void beforeActivation( Application application )
  {
    application.registerActivationEventListener( System.out::println );
  }
};

代码示例来源：origin: apache/attic-polygene-java

@Override
  protected String hostnames()
  {
    switch( application.mode() )
    {
    case development:
      return "localhost:9042";
    case staging:
      return "cassandra.staging:9042";
    case production:
      return "cassandra1.prod:9042,cassandra2.prod:9042,cassandra3.prod:9042";
    case test:
    default:
      return "cassandra.test:9042";
    }
  }
}

代码示例来源：origin: apache/attic-polygene-java

@Test
public void canCreateAndQueryWithNativeRdfWithInMemoryStore()
  throws Exception
{
  Application application = createApplication( nativeRdf, inMemoryStore, domain );
  try
  {
    application.activate();
    Module domain = application.findModule( "Domain", "Domain" );
    UnitOfWorkFactory unitOfWorkFactory = domain.unitOfWorkFactory();
    createABunchOfStuffAndDoQueries( unitOfWorkFactory, domain );
  }
  finally
  {
    application.passivate();
  }
}

代码示例来源：origin: apache/attic-polygene-java

public void stop()
  throws PassivationException
{
  application.passivate();
}

代码示例来源：origin: org.apache.polygene.core/org.apache.polygene.core.api

@Override
public void run()
{
  try
  {
    application.passivate();
  }
  catch( PassivationException ex )
  {
    String message = application.name() + " " + ex.getMessage();
    if( logger != null )
    {
      logger.log( Level.SEVERE, message, ex );
    }
    else if( output != null )
    {
      output.println( message );
      ex.printStackTrace( output );
    }
    else
    {
      ex.printStackTrace();
    }
  }
}

代码示例来源：origin: apache/attic-polygene-java

protected final void assertUowTimer( MetricValuesProvider metrics ) throws PassivationException, ActivationException
{
  Long initialUowCount = metrics.timerCount( UOW_TIMER_NAME );
  runScenario1();
  assertThat( UOW_TIMER_NAME + " count incremented by 3", metrics.timerCount( UOW_TIMER_NAME ), is( initialUowCount + 3L ) );
  application.passivate();
  application.activate();
  assertThat( UOW_TIMER_NAME + " count reset on passivation", metrics.timerCount( UOW_TIMER_NAME ), equalTo( initialUowCount ) );
}

代码示例来源：origin: apache/attic-polygene-java

@Test
  public void validateThatAssemblerCreatesApplication()
    throws AssemblyException, ActivationException
  {
    TestApplication assembler = new TestApplication( "Test Application", "1.0.1", Application.Mode.test );
    assembler.initialize();
    assembler.start();

    assertThat( assembler.application().name(), equalTo("Test Application") );
    assertThat( assembler.application().version(), equalTo("1.0.1") );
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Application

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com