org.seedstack.seed.core.api.Application类的使用及代码示例

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

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

Application介绍

暂无

代码示例

代码示例来源:origin: org.seedstack.seed/seed-ws-support-jms

@Inject
JmsClientTransport(Application application, LoadingCache<SoapJmsUri, Connection> connectionCache, @Assisted Packet packet, @Assisted Map<String, String> requestHeaders) {
  this.packet = packet;
  this.requestHeaders = requestHeaders;
  this.responseTimeout = application.getConfiguration().getInt("org.seedstack.seed.ws.jms.client-timeout", DEFAULT_TIMEOUT_INTERVAL);
  this.connectionCache = connectionCache;
}

代码示例来源:origin: org.seedstack.business/business-audit

void initHost() {
  host = new Host(application.getId(), application.getName());
}

代码示例来源:origin: org.seedstack.seed/seed-jms-support-core

@Override
public InitState init(InitContext initContext) {
  String applicationId = null;
  transactionPlugin = null;
  for (Plugin plugin : initContext.pluginsRequired()) {
    if (plugin instanceof ApplicationPlugin) {
      application = ((ApplicationPlugin) plugin).getApplication();
      jmsConfiguration = application.getConfiguration().subset(JmsPlugin.JMS_PLUGIN_CONFIGURATION_PREFIX);
      applicationId = ((ApplicationPlugin) plugin).getApplication().getId();
    } else if (plugin instanceof TransactionPlugin) {
      transactionPlugin = ((TransactionPlugin) plugin);
    } else if (plugin instanceof JndiPlugin) {
      jndiContexts = ((JndiPlugin) plugin).getJndiContexts();
    }
  }
  if (jmsConfiguration == null || applicationId == null) {
    throw SeedException.createNew(JmsErrorCodes.PLUGIN_NOT_FOUND).put("plugin", "application");
  }
  if (transactionPlugin == null) {
    throw SeedException.createNew(JmsErrorCodes.PLUGIN_NOT_FOUND).put("plugin", "transaction");
  }
  jmsFactory = new JmsFactoryImpl(applicationId, jmsConfiguration, jndiContexts);
  configureConnections(jmsConfiguration.getStringArray("connections"));
  configureMessageListeners(initContext.scannedTypesBySpecification().get(messageListenerSpec));
  return InitState.INITIALIZED;
}

代码示例来源:origin: org.seedstack.seed/seed-persistence-support-elasticsearch

@Override
public InitState init(InitContext initContext) {
  ApplicationPlugin applicationPlugin = (ApplicationPlugin) initContext.pluginsRequired().iterator().next();
  Configuration elasticSearchConfiguration = applicationPlugin.getApplication().getConfiguration().subset(ELASTIC_SEARCH_PLUGIN_CONFIGURATION_PREFIX);
          propertiesMap.put("path.home", applicationPlugin.getApplication().getStorageLocation(ElasticSearchPlugin.ELASTIC_SEARCH_STORAGE_ROOT + elasticSearchClientName).getAbsolutePath());
        } catch (IOException e) {
          throw new PluginException("Unable to create ElasticSearch home directory", e);

代码示例来源:origin: org.seedstack.functions.w20/w20-function-rest

@Override
public void overrideConfiguration(String fragmentName, String moduleName, Map<String, Object> sourceConfiguration) {
  if ("w20-core".equals(fragmentName)) {
    if ("application".equals(moduleName)) {
      sourceConfiguration.put("id", application.getId());
    }
    if ("env".equals(moduleName)) {
      if (!sourceConfiguration.containsKey("type") && environment != null) {
        sourceConfiguration.put("type", environment);
      }
    }
  }
}

代码示例来源:origin: org.seedstack.functions.w20/w20-function-rest

variables.put("applicationTitle", StringUtils.isBlank(applicationTitle) ? application.getName() : applicationTitle);
variables.put("applicationSubtitle", applicationSubtitle);
variables.put("applicationVersion", StringUtils.isBlank(applicationVersion) ? application.getVersion() : applicationVersion);
variables.put("timeout", timeout);
variables.put("corsWithCredentials", corsWithCredentials);

代码示例来源:origin: org.seedstack.seed/seed-shell-support

@Override
public InitState init(InitContext initContext) {
  ApplicationPlugin applicationPlugin = (ApplicationPlugin) initContext.pluginsRequired().iterator().next();
  org.apache.commons.configuration.Configuration shellConfiguration = applicationPlugin.getApplication().getConfiguration().subset(ShellPlugin.SHELL_PLUGIN_CONFIGURATION_PREFIX);
    File storage;
    try {
      storage = applicationPlugin.getApplication().getStorageLocation("shell");
    } catch (IOException e) {
      throw new PluginException("Unable to acces storage location for context shell", e);

代码示例来源:origin: org.seedstack.seed/seed-web-support-security

@SuppressWarnings("unchecked")
@Override
public void init(InitContext initContext) {
  ApplicationPlugin applicationPlugin = null;
  for (Plugin plugin : initContext.pluginsRequired()) {
    if (plugin instanceof ApplicationPlugin) {
      applicationPlugin = ((ApplicationPlugin) plugin);
    }
  }
  if (applicationPlugin == null) {
    throw SeedException.createNew(WebErrorCode.PLUGIN_NOT_FOUND).put("plugin", "application");
  }
  props = applicationPlugin.getProps();
  applicationId = applicationPlugin.getApplication().getId();
  for (Class<?> filterClass : initContext.scannedClassesByAnnotationClass().get(SecurityFilter.class)) {
    if (Filter.class.isAssignableFrom(filterClass)) {
      scannedFilters.add((Class<? extends Filter>) filterClass);
    } else {
      throw new PluginException("Annotated class " + filterClass.getName() + " must implement Filter to be used in a filter chain");
    }
  }
}

代码示例来源:origin: org.seedstack.functions.w20/w20-function-rest

@Inject
GlobalConfigurationHandler(ServletContext servletContext, Application application, @Named("SeedRestPath") String restPath, @Named("SeedWebResourcesPath") String webResourcesPath) {
  this.contextPath = servletContext.getContextPath();
  this.componentsPath = application.getConfiguration().getString(W20Plugin.W20_PLUGIN_CONFIGURATION_PREFIX + ".components-path");
  this.restPath = restPath;
  this.webResourcesPath = webResourcesPath;
}

代码示例来源:origin: org.seedstack.functions.audit/audit-function-core

void initHost() {
  host = new Host(application.getId(), application.getName());
}

代码示例来源:origin: org.seedstack.seed/seed-shell-support

@Override
public void start(Environment environment) throws IOException {
  errorPrintStream = new PrintStream(errorStream, true);
  String user = environment.getEnv().get(Environment.ENV_USER);
  if (Strings.isNullOrEmpty(user)) {
    user = "unknown";
  }
  try {
    // Use our RemoteTerminal which does not depends on the platform.
    terminal = new RemoteTerminal(true);
    terminal.init();
  } catch (Exception e) {
    LOGGER.warn("Error during terminal detection, falling back to unsupported terminal");
    LOGGER.debug(DETAILS_MESSAGE, e);
    terminal = new UnsupportedTerminal();
  }
  consoleReader = new ConsoleReader(inputStream, outputStream, terminal);
  // Disable jline shutdownhook to avoid exception at application shutdown
  jline.internal.Configuration.getString("jline.shutdownhook", "false");
  consoleReader.addCompleter(new StringsCompleter(commandRegistry.getCommandList()));
  consoleReader.setCompletionHandler(new CandidateListCompletionHandler());
  consoleReader.setPrompt(user + "@" + application.getId() + "$ ");
  consoleReader.setHandleUserInterrupt(false);
  consoleReader.setHistoryEnabled(true);
  ses = new SubjectAwareExecutorService(Executors.newSingleThreadExecutor());
  ses.submit(this);
}

代码示例来源:origin: org.seedstack.seed/seed-core-support-core

@Override
  public Object execute(Object object) throws Exception {
    return ConfigurationConverter.getMap(application.getConfiguration());
  }
}

代码示例来源:origin: org.seedstack.functions.i18n/i18n-function-core

@Singleton
  @Override
  public LoadingCache<String, Map<String, String>> get() {
    Configuration configuration = application.getConfiguration();
    int cacheSize = configuration.getInt("org.seedstack.i18n.cache.max-size", DEFAULT_CACHE_SIZE);
    return CacheBuilder.newBuilder().maximumSize(cacheSize)
        .concurrencyLevel(configuration.getInt("org.seedstack.i18n.cache.concurrency", DEFAULT_CACHE_CONCURRENCY))
        .initialCapacity(configuration.getInt("org.seedstack.i18n.cache.initial-size", cacheSize / 4))
        .build(i18nCacheLoader);
  }
}

代码示例来源:origin: org.seedstack.seed/seed-web-support-core

@Inject
WebResourceResolverImpl(final Application application, final Injector injector, @Named("SeedWebResourcesPath") final String resourcePath) {
  Configuration configuration = application.getConfiguration();
  this.injector = injector;
  this.resourcePath = resourcePath;
  this.classpathLocation = "META-INF/resources" + resourcePath;
  this.classLoader = SeedReflectionUtils.findMostCompleteClassLoader(WebResourceResolverImpl.class);
  this.docrootLocation = resourcePath;
  this.mimetypesFileTypeMap = new MimetypesFileTypeMap();
  this.serveMinifiedResources = configuration.getBoolean(WebPlugin.WEB_PLUGIN_PREFIX + ".resources.minification-support", true);
  this.serveGzippedResources = configuration.getBoolean(WebPlugin.WEB_PLUGIN_PREFIX + ".resources.gzip-support", true);
  this.onTheFlyGzipping = configuration.getBoolean(WebPlugin.WEB_PLUGIN_PREFIX + ".resources.gzip-on-the-fly", true);
}

代码示例来源:origin: org.seedstack.seed/seed-web-support-core

@Inject
WebResourceServlet(final Application application, final WebResourceResolver webResourceResolver) {
  Configuration configuration = application.getConfiguration();
  this.servletInitTime = System.currentTimeMillis();
  this.webResourceResolver = webResourceResolver;
  int cacheSize = configuration.getInt(WebPlugin.WEB_PLUGIN_PREFIX + ".resources.cache.max-size", DEFAULT_CACHE_SIZE);
  this.resourceInfoCache = CacheBuilder.newBuilder().maximumSize(cacheSize).concurrencyLevel(configuration.getInt(WebPlugin.WEB_PLUGIN_PREFIX + ".resources.cache.concurrency", DEFAULT_CACHE_CONCURRENCY)).initialCapacity(configuration.getInt(WebPlugin.WEB_PLUGIN_PREFIX + ".resources.cache.initial-size", cacheSize / 4)).build(new CacheLoader<ResourceRequest, Optional<ResourceInfo>>() {
    @Override
    public Optional<ResourceInfo> load(ResourceRequest key) {
      ResourceInfo resourceInfo = webResourceResolver.resolveResourceInfo(key);
      if (resourceInfo == null) {
        return Optional.absent();
      } else {
        return Optional.of(resourceInfo);
      }
    }
  });
}

代码示例来源:origin: org.seedstack.seed/seed-core-support-core

@Override
protected void configure() {
  bind(Application.class).toInstance(this.application);
  bindListener(Matchers.any(), new ConfigurationTypeListener(this.application.getConfiguration()));
}

代码示例来源:origin: org.seedstack.seed/seed-mail-support-core

Configuration getPluginConfiguration(Plugin deployedPlugin) {
  Configuration mailSessionsConfiguration = null;
  if (deployedPlugin instanceof ApplicationPlugin) {
    ApplicationPlugin applicationPlugin = (ApplicationPlugin) deployedPlugin;
    mailSessionsConfiguration = applicationPlugin.getApplication().getConfiguration().subset(JavaMailPlugin.CONFIGURATION_PREFIX);
  }
  return mailSessionsConfiguration;
}

代码示例来源:origin: org.seedstack.seed/seed-web-support-core

@Override
public InitState init(InitContext initContext) {
  if (this.servletContext == null) {
    LOGGER.info("No servlet context detected, web support disabled");
    return InitState.INITIALIZED;
  }
  ApplicationPlugin applicationPlugin = (ApplicationPlugin) initContext.pluginsRequired().iterator().next();
  Configuration webConfiguration = applicationPlugin.getApplication().getConfiguration().subset(WebPlugin.WEB_PLUGIN_PREFIX);
  boolean corsEnabled = webConfiguration.getBoolean("cors.enabled", false);
  Map<String, String> corsParameters = new HashMap<String, String>();
  String corsMapping;
  if (corsEnabled) {
    corsMapping = webConfiguration.getString("cors.url-mapping", "/*");
    Properties corsProperties = SeedConfigurationUtils.buildPropertiesFromConfiguration(webConfiguration, "cors.property");
    for (Object key : corsProperties.keySet()) {
      corsParameters.put("cors." + key.toString(), corsProperties.getProperty(key.toString()));
    }
    webCorsModule = new WebCorsModule(corsMapping, corsParameters);
    LOGGER.info("CORS support enabled on {}", corsMapping);
  }
  return InitState.INITIALIZED;
}

代码示例来源:origin: org.seedstack.seed/seed-spring-support-core

@Override
public InitState init(InitContext initContext) {
  ApplicationPlugin applicationPlugin = (ApplicationPlugin) initContext.pluginsRequired().iterator().next();
  Configuration springConfiguration = applicationPlugin.getApplication().getConfiguration().subset(SPRING_PLUGIN_CONFIGURATION_PREFIX);
  Map<String, Collection<String>> scannedApplicationContexts = initContext.mapResourcesByRegex();
  SeedConfigurationFactoryBean.configuration = applicationPlugin.getApplication().getConfiguration();
  boolean autodetect = springConfiguration.getBoolean("autodetect", true);
  for (String applicationContextPath : scannedApplicationContexts.get(APPLICATION_CONTEXT_REGEX)) {
    if (autodetect && applicationContextPath.startsWith("META-INF/spring")) {
      applicationContextsPaths.add(applicationContextPath);
      LOGGER.info("Autodetected spring context at " + applicationContextPath);
    }
  }
  if (springConfiguration.containsKey("contexts")) {
    String[] explicitContexts = springConfiguration.getStringArray("contexts");
    for (String explicitContext : explicitContexts) {
      applicationContextsPaths.add(explicitContext);
      LOGGER.info("Configured spring context at " + explicitContext);
    }
  } else if (springConfiguration.containsKey("context")) {
    String explicitContext = springConfiguration.getString("context");
    applicationContextsPaths.add(explicitContext);
    LOGGER.info("Configured spring context at " + explicitContext);
  }
  LOGGER.info("Initializing spring contexts " + applicationContextsPaths);
  globalApplicationContext = new ClassPathXmlApplicationContext(this.applicationContextsPaths.toArray(new String[this.applicationContextsPaths.size()]));
  return InitState.INITIALIZED;
}

代码示例来源:origin: org.seedstack.business/business-audit

@Override
public InitState init(InitContext initContext) {
  scannedClasses = initContext.scannedSubTypesByAncestorClass();
  ApplicationPlugin applicationPlugin = (ApplicationPlugin) initContext.pluginsRequired().iterator().next();
  auditConfigurer = new AuditConfigurer(applicationPlugin.getApplication().getConfiguration().subset(PROPERTIES_PREFIX), scannedClasses);
  return InitState.INITIALIZED;
}

相关文章

微信公众号

最新文章

更多