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

Attribute.resolveModelAttribute介绍

[英]Resolves the value of this attribute from the specified model applying any default value.
[中]

代码示例

代码示例来源：origin: wildfly/wildfly

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  this.identifier = this.attribute.resolveModelAttribute(context, model).asString();
  return this;
}

代码示例来源：origin: wildfly/wildfly

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  for (ColumnAttribute column : EnumSet.allOf(ColumnAttribute.class)) {
    ModelNode columnModel = column.resolveModelAttribute(context, model);
    String name = column.getColumnName().resolveModelAttribute(context, columnModel).asString();
    String type = column.getColumnType().resolveModelAttribute(context, columnModel).asString();
    this.columns.put(column, new AbstractMap.SimpleImmutableEntry<>(name, type));
  }
  this.fetchSize = FETCH_SIZE.resolveModelAttribute(context, model).asInt();
  this.prefix = this.prefixAttribute.resolveModelAttribute(context, model).asString();
  return this;
}

代码示例来源：origin: wildfly/wildfly

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  int maxThreads = this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt();
  int minThreads = this.definition.getMinThreads().resolveModelAttribute(context, model).asInt();
  int queueLength = this.definition.getQueueLength().resolveModelAttribute(context, model).asInt();
  long keepAliveTime = this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong();
  this.factory = new ExecutorFactory() {
    @Override
    public ExecutorService getExecutor(Properties property) {
      ThreadFactory clThreadFactory = new ClassLoaderThreadFactory(ClientThreadPoolServiceConfigurator.this, AccessController.doPrivileged((PrivilegedAction<ClassLoader>) ClassLoaderThreadFactory.class::getClassLoader));
      return new ThreadPoolExecutor(minThreads, maxThreads, keepAliveTime, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(queueLength), clThreadFactory);
    }
  };
  return this;
}

代码示例来源：origin: wildfly/wildfly

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  ThreadPoolExecutorFactory<?> factory = new BlockingThreadPoolExecutorFactory(
      this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt(),
      this.definition.getMinThreads().resolveModelAttribute(context, model).asInt(),
      this.definition.getQueueLength().resolveModelAttribute(context, model).asInt(),
      this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong()
  ) {
    @Override
    public ExecutorService createExecutor(ThreadFactory factory) {
      return super.createExecutor(new ClassLoaderThreadFactory(factory, WildFlySecurityManager.doUnchecked(GET_CLASS_LOADER_ACTION)));
    }
  };
  this.builder.threadPoolFactory(factory);
  return this;
}

代码示例来源：origin: wildfly/wildfly

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  this.setMinThreads(this.definition.getMinThreads().resolveModelAttribute(context, model).asInt());
  this.setMaxThreads(this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt());
  this.setKeepAliveTime(this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong());
  return this;
}

代码示例来源：origin: wildfly/wildfly

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  int maxThreads = this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt();
  long keepAliveTime = this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong();
  ThreadPoolExecutorFactory<?> factory = new ThreadPoolExecutorFactory<ScheduledExecutorService>() {
    @Override
    public ScheduledExecutorService createExecutor(ThreadFactory factory) {
      // Use fixed size, based on maxThreads
      ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(maxThreads, new ClassLoaderThreadFactory(factory, WildFlySecurityManager.doUnchecked(GET_CLASS_LOADER_ACTION)));
      executor.setKeepAliveTime(keepAliveTime, TimeUnit.MILLISECONDS);
      executor.setRemoveOnCancelPolicy(true);
      executor.setExecuteExistingDelayedTasksAfterShutdownPolicy(false);
      return executor;
    }
    @Override
    public void validate() {
      // Do nothing
    }
  };
  this.builder.threadPoolFactory(factory);
  return this;
}

代码示例来源：origin: org.jboss.eap/wildfly-clustering-common

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  this.identifier = this.attribute.resolveModelAttribute(context, model).asString();
  return this;
}

代码示例来源：origin: org.wildfly/wildfly-clustering-infinispan-extension

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  for (ColumnAttribute column : EnumSet.allOf(ColumnAttribute.class)) {
    ModelNode columnModel = column.resolveModelAttribute(context, model);
    String name = column.getColumnName().resolveModelAttribute(context, columnModel).asString();
    String type = column.getColumnType().resolveModelAttribute(context, columnModel).asString();
    this.columns.put(column, new AbstractMap.SimpleImmutableEntry<>(name, type));
  }
  this.fetchSize = FETCH_SIZE.resolveModelAttribute(context, model).asInt();
  this.prefix = this.prefixAttribute.resolveModelAttribute(context, model).asString();
  return this;
}

代码示例来源：origin: org.wildfly/wildfly-clustering-infinispan-extension

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  int maxThreads = this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt();
  int minThreads = this.definition.getMinThreads().resolveModelAttribute(context, model).asInt();
  int queueLength = this.definition.getQueueLength().resolveModelAttribute(context, model).asInt();
  long keepAliveTime = this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong();
  this.factory = new ExecutorFactory() {
    @Override
    public ExecutorService getExecutor(Properties property) {
      ThreadFactory clThreadFactory = new ClassLoaderThreadFactory(ClientThreadPoolServiceConfigurator.this, AccessController.doPrivileged((PrivilegedAction<ClassLoader>) ClassLoaderThreadFactory.class::getClassLoader));
      return new ThreadPoolExecutor(minThreads, maxThreads, keepAliveTime, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(queueLength), clThreadFactory);
    }
  };
  return this;
}

代码示例来源：origin: org.wildfly/wildfly-clustering-infinispan-extension

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  ThreadPoolExecutorFactory<?> factory = new BlockingThreadPoolExecutorFactory(
      this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt(),
      this.definition.getMinThreads().resolveModelAttribute(context, model).asInt(),
      this.definition.getQueueLength().resolveModelAttribute(context, model).asInt(),
      this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong()
  ) {
    @Override
    public ExecutorService createExecutor(ThreadFactory factory) {
      return super.createExecutor(new ClassLoaderThreadFactory(factory, WildFlySecurityManager.doUnchecked(GET_CLASS_LOADER_ACTION)));
    }
  };
  this.builder.threadPoolFactory(factory);
  return this;
}

代码示例来源：origin: org.jboss.eap/wildfly-clustering-jgroups-extension

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  this.setMinThreads(this.definition.getMinThreads().resolveModelAttribute(context, model).asInt());
  this.setMaxThreads(this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt());
  this.setKeepAliveTime(this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong());
  return this;
}

代码示例来源：origin: org.wildfly/wildfly-clustering-infinispan-extension

@Override
public ServiceConfigurator configure(OperationContext context, ModelNode model) throws OperationFailedException {
  int maxThreads = this.definition.getMaxThreads().resolveModelAttribute(context, model).asInt();
  long keepAliveTime = this.definition.getKeepAliveTime().resolveModelAttribute(context, model).asLong();
  ThreadPoolExecutorFactory<?> factory = new ThreadPoolExecutorFactory<ScheduledExecutorService>() {
    @Override
    public ScheduledExecutorService createExecutor(ThreadFactory factory) {
      // Use fixed size, based on maxThreads
      ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(maxThreads, new ClassLoaderThreadFactory(factory, WildFlySecurityManager.doUnchecked(GET_CLASS_LOADER_ACTION)));
      executor.setKeepAliveTime(keepAliveTime, TimeUnit.MILLISECONDS);
      executor.setRemoveOnCancelPolicy(true);
      executor.setExecuteExistingDelayedTasksAfterShutdownPolicy(false);
      return executor;
    }
    @Override
    public void validate() {
      // Do nothing
    }
  };
  this.builder.threadPoolFactory(factory);
  return this;
}