本文整理了Java中org.seedstack.seed.core.api.Application
类的一些代码示例,展示了Application
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Application
类的具体详情如下:
包路径:org.seedstack.seed.core.api.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;
}
内容来源于网络,如有侵权,请联系作者删除!