WFLY-19548 Remove redundant capability name String instances for core…

… capabilities

appclient/src/main/java/org/jboss/as/appclient/service/ApplicationClientDeploymentService.java

@@ -16,7 +16,7 @@
 
 import java.io.File;
 import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executor;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
 
@@ -43,18 +43,18 @@ public class ApplicationClientDeploymentService implements Service {
     private final File path;
     private final Consumer<ApplicationClientDeploymentService> consumer;
     private final Supplier<ModelControllerClientFactory> clientFactorySupplier;
-    private final Supplier<ExecutorService> executorServiceSupplier;
+    private final Supplier<Executor> executorSupplier;
     private final CountDownLatch deploymentCompleteLatch = new CountDownLatch(1);
 
 
     public ApplicationClientDeploymentService(final Consumer<ApplicationClientDeploymentService> consumer,
                                               final File path,
                                               final Supplier<ModelControllerClientFactory> clientFactorySupplier,
-                                              final Supplier<ExecutorService> executorServiceSupplier) {
+                                              final Supplier<Executor> executorSupplier) {
         this.consumer = consumer;
         this.path = path;
         this.clientFactorySupplier = clientFactorySupplier;
-        this.executorServiceSupplier = executorServiceSupplier;
+        this.executorSupplier = executorSupplier;
     }
 
     @Override
@@ -111,7 +111,7 @@ private DeploymentTask(final Operation deploymentOp) {
 
         @Override
         public void run() {
-            try (LocalModelControllerClient controllerClient = clientFactorySupplier.get().createSuperUserClient(executorServiceSupplier.get())) {
+            try (LocalModelControllerClient controllerClient = clientFactorySupplier.get().createSuperUserClient(executorSupplier.get())) {
                 ModelNode result = controllerClient.execute(deploymentOp);
                 if (!SUCCESS.equals(result.get(OUTCOME).asString())) {
                     System.exit(1);

appclient/src/main/java/org/jboss/as/appclient/subsystem/AppClientSubsystemAdd.java

@@ -9,7 +9,7 @@
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.util.List;
-import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executor;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
 
@@ -28,6 +28,7 @@
 import org.jboss.as.controller.ModelControllerClientFactory;
 import org.jboss.as.controller.OperationContext;
 import org.jboss.as.controller.OperationFailedException;
+import org.jboss.as.controller.management.Capabilities;
 import org.jboss.as.server.AbstractDeploymentChainStep;
 import org.jboss.as.server.DeploymentProcessorTarget;
 import org.jboss.as.server.deployment.Phase;
@@ -40,8 +41,6 @@
 import org.jboss.msc.service.StopContext;
 
 import static org.jboss.as.appclient.subsystem.AppClientSubsystemResourceDefinition.APPCLIENT_CAPABILITY;
-import static org.jboss.as.appclient.subsystem.AppClientSubsystemResourceDefinition.EXECUTOR_CAPABILITY;
-import static org.jboss.as.appclient.subsystem.AppClientSubsystemResourceDefinition.MCF_CAPABILITY;
 import static org.jboss.as.appclient.subsystem.Constants.CONNECTION_PROPERTIES_URL;
 import static org.jboss.as.appclient.subsystem.Constants.HOST_URL;
 
@@ -97,11 +96,9 @@ protected void execute(DeploymentProcessorTarget processorTarget) {
 
         CapabilityServiceBuilder<?> builder = context.getCapabilityServiceTarget().addCapability(APPCLIENT_CAPABILITY);
         Consumer<ApplicationClientDeploymentService> consumer = builder.provides(APPCLIENT_CAPABILITY);
-        Supplier<ModelControllerClientFactory> mcfSupplier =
-                builder.requiresCapability(MCF_CAPABILITY, ModelControllerClientFactory.class);
-        Supplier<ExecutorService> esSupplier =
-                builder.requiresCapability(EXECUTOR_CAPABILITY, ExecutorService.class);
-        builder.setInstance(new ApplicationClientDeploymentService(consumer, file, mcfSupplier, esSupplier));
+        Supplier<ModelControllerClientFactory> mcfSupplier = builder.requires(ModelControllerClientFactory.SERVICE_DESCRIPTOR);
+        Supplier<Executor> executorSupplier = builder.requires(Capabilities.MANAGEMENT_EXECUTOR);
+        builder.setInstance(new ApplicationClientDeploymentService(consumer, file, mcfSupplier, executorSupplier));
         builder.install();
 
         try {

appclient/src/main/java/org/jboss/as/appclient/subsystem/AppClientSubsystemResourceDefinition.java

@@ -25,11 +25,8 @@
  */
 public class AppClientSubsystemResourceDefinition extends SimpleResourceDefinition {
 
-    static final String MCF_CAPABILITY = "org.wildfly.management.model-controller-client-factory";
-    static final String EXECUTOR_CAPABILITY = "org.wildfly.management.executor";
-
     public static final RuntimeCapability<Void> APPCLIENT_CAPABILITY = RuntimeCapability.Builder.of("org.wildfly.appclient", Void.class)
-            //.addRequirements(MCF_CAPABILITY, EXECUTOR_CAPABILITY) TODO determine why this breaks domain mode provisioning
+            //.addRequirements(ModelControllerClientFactory.SERVICE_DESCRIPTOR, Capabilities.MANAGEMENT_EXECUTOR) TODO determine why this breaks domain mode provisioning
             .build();
 
     public static final SimpleAttributeDefinition FILE =

batch-jberet/src/main/java/org/wildfly/extension/batch/jberet/_private/Capabilities.java

@@ -60,9 +60,4 @@ public class Capabilities {
      * The capability name for the kernel SuspendController
      */
     public static final String SUSPEND_CONTROLLER_CAPABILITY = "org.wildfly.server.suspend-controller";
-
-    /**
-     * The capability name for the kernel ProcessStateNotifier.
-     */
-    public static final String PROCESS_STATE_NOTIFIER_CAPABILITY = "org.wildfly.management.process-state-notifier";
 }

batch-jberet/src/main/java/org/wildfly/extension/batch/jberet/deployment/BatchEnvironmentProcessor.java

@@ -22,6 +22,8 @@
 import org.jberet.spi.JobExecutor;
 import org.jberet.spi.JobOperatorContext;
 import org.jboss.as.controller.ProcessStateNotifier;
+import org.jboss.as.controller.RequirementServiceBuilder;
+import org.jboss.as.controller.RequirementServiceTarget;
 import org.jboss.as.controller.capability.CapabilityServiceSupport;
 import org.jboss.as.ee.component.EEModuleDescription;
 import org.jboss.as.ee.structure.DeploymentType;
@@ -38,7 +40,6 @@
 import org.jboss.modules.Module;
 import org.jboss.msc.service.ServiceBuilder;
 import org.jboss.msc.service.ServiceName;
-import org.jboss.msc.service.ServiceTarget;
 import org.wildfly.extension.batch.jberet.BatchConfiguration;
 import org.wildfly.extension.batch.jberet.BatchServiceNames;
 import org.wildfly.extension.batch.jberet._private.BatchLogger;
@@ -79,7 +80,7 @@ public void deploy(final DeploymentPhaseContext phaseContext) throws DeploymentU
             final Module module = deploymentUnit.getAttachment(Attachments.MODULE);
             final ClassLoader moduleClassLoader = module.getClassLoader();
 
-            final ServiceTarget serviceTarget = phaseContext.getServiceTarget();
+            final RequirementServiceTarget serviceTarget = phaseContext.getRequirementServiceTarget();
 
             // Check for a deployment descriptor
             BatchEnvironmentMetaData metaData = deploymentUnit.getAttachment(BatchAttachments.BATCH_ENVIRONMENT_META_DATA);
@@ -160,12 +161,12 @@ public void deploy(final DeploymentPhaseContext phaseContext) throws DeploymentU
 
             // Install the JobOperatorService
             final ServiceName jobOperatorServiceName = BatchServiceNames.jobOperatorServiceName(deploymentUnit);
-            final ServiceBuilder<?> jobOperatorServiceSB = serviceTarget.addService(jobOperatorServiceName);
+            final RequirementServiceBuilder<?> jobOperatorServiceSB = serviceTarget.addService();
             final Consumer<JobOperator> jobOperatorConsumer = jobOperatorServiceSB.provides(jobOperatorServiceName);
             final Supplier<ExecutorService> executorSupplier = Services.requireServerExecutor(jobOperatorServiceSB);
             final Supplier<BatchConfiguration> batchConfigSupplier = jobOperatorServiceSB.requires(support.getCapabilityServiceName(Capabilities.BATCH_CONFIGURATION_CAPABILITY.getName()));
             final Supplier<SuspendController> suspendControllerSupplier = jobOperatorServiceSB.requires(support.getCapabilityServiceName(Capabilities.SUSPEND_CONTROLLER_CAPABILITY));
-            final Supplier<ProcessStateNotifier> processStateSupplier = jobOperatorServiceSB.requires(support.getCapabilityServiceName(Capabilities.PROCESS_STATE_NOTIFIER_CAPABILITY));
+            final Supplier<ProcessStateNotifier> processStateSupplier = jobOperatorServiceSB.requires(ProcessStateNotifier.SERVICE_DESCRIPTOR);
             final Supplier<SecurityAwareBatchEnvironment> batchEnvironmentSupplier = jobOperatorServiceSB.requires(BatchServiceNames.batchEnvironmentServiceName(deploymentUnit));
             final JobOperatorService jobOperatorService = new JobOperatorService(jobOperatorConsumer, batchConfigSupplier, batchEnvironmentSupplier, executorSupplier, suspendControllerSupplier, processStateSupplier, restartJobsOnResume, deploymentName, jobXmlResolver);
             jobOperatorServiceSB.setInstance(jobOperatorService);

clustering/common/src/main/java/org/jboss/as/clustering/controller/CommonRequirement.java

@@ -12,6 +12,7 @@
 import org.jboss.as.naming.service.NamingService;
 import org.jboss.as.network.SocketBindingManager;
 import org.wildfly.clustering.service.Requirement;
+import org.wildfly.service.descriptor.NullaryServiceDescriptor;
 
 /**
  * Enumerates common requirements for clustering resources.
@@ -22,13 +23,17 @@ public enum CommonRequirement implements Requirement, ServiceNameFactoryProvider
     LOCAL_TRANSACTION_PROVIDER("org.wildfly.transactions.global-default-local-provider", Void.class),
     MBEAN_SERVER("org.wildfly.management.jmx", MBeanServer.class),
     NAMING_STORE(NamingService.CAPABILITY_NAME, NamingStore.class),
-    PATH_MANAGER("org.wildfly.management.path-manager", PathManager.class),
-    SOCKET_BINDING_MANAGER("org.wildfly.management.socket-binding-manager", SocketBindingManager.class),
+    PATH_MANAGER(PathManager.SERVICE_DESCRIPTOR),
+    SOCKET_BINDING_MANAGER(SocketBindingManager.SERVICE_DESCRIPTOR),
     ;
     private final String name;
     private final Class<?> type;
     private final ServiceNameFactory factory = new RequirementServiceNameFactory(this);
 
+    CommonRequirement(NullaryServiceDescriptor<?> descriptor) {
+        this(descriptor.getName(), descriptor.getType());
+    }
+
     CommonRequirement(String name, Class<?> type) {
         this.name = name;
         this.type = type;

clustering/common/src/main/java/org/jboss/as/clustering/controller/CommonUnaryRequirement.java

@@ -10,10 +10,12 @@
 import javax.net.ssl.SSLContext;
 import javax.sql.DataSource;
 
+import org.jboss.as.controller.services.path.PathManager;
 import org.jboss.as.network.OutboundSocketBinding;
 import org.jboss.as.network.SocketBinding;
 import org.wildfly.clustering.service.UnaryRequirement;
 import org.wildfly.security.credential.store.CredentialStore;
+import org.wildfly.service.descriptor.UnaryServiceDescriptor;
 
 /**
  * Enumerates common unary requirements for clustering resources
@@ -23,15 +25,19 @@ public enum CommonUnaryRequirement implements UnaryRequirement, UnaryServiceName
     CREDENTIAL_STORE("org.wildfly.security.credential-store", CredentialStore.class),
     DATA_SOURCE("org.wildfly.data-source", DataSource.class),
     KEY_STORE("org.wildfly.security.key-store", KeyStore.class),
-    OUTBOUND_SOCKET_BINDING("org.wildfly.network.outbound-socket-binding", OutboundSocketBinding.class),
-    PATH("org.wildfly.management.path", String.class),
-    SOCKET_BINDING("org.wildfly.network.socket-binding", SocketBinding.class),
+    OUTBOUND_SOCKET_BINDING(OutboundSocketBinding.SERVICE_DESCRIPTOR),
+    PATH(PathManager.PATH_SERVICE_DESCRIPTOR),
+    SOCKET_BINDING(SocketBinding.SERVICE_DESCRIPTOR),
     SSL_CONTEXT("org.wildfly.security.ssl-context", SSLContext.class),
     ;
     private final String name;
     private final Class<?> type;
     private final UnaryServiceNameFactory factory = new UnaryRequirementServiceNameFactory(this);
 
+    CommonUnaryRequirement(UnaryServiceDescriptor<?> descriptor) {
+        this(descriptor.getName(), descriptor.getType());
+    }
+
     CommonUnaryRequirement(String name, Class<?> type) {
         this.name = name;
         this.type = type;

ee-feature-pack/galleon-shared/src/main/resources/modules/system/layers/base/org/jboss/as/clustering/common/main/module.xml

@@ -32,5 +32,6 @@
         <module name="org.wildfly.clustering.service"/>
         <module name="org.wildfly.common"/>
         <module name="org.wildfly.security.elytron-private"/>
+        <module name="org.wildfly.service"/>
     </dependencies>
 </module>

ee-feature-pack/galleon-shared/src/main/resources/modules/system/layers/base/org/jboss/as/ee/main/module.xml

@@ -43,6 +43,7 @@
         <module name="org.jboss.metadata.ear"/>
         <module name="org.jboss.vfs"/>
         <module name="org.wildfly.common"/>
+        <module name="org.wildfly.service"/>
         <module name="org.wildfly.transaction.client" optional="true" />
     </dependencies>
 </module>

ee-feature-pack/galleon-shared/src/main/resources/modules/system/layers/base/org/wildfly/extension/health/main/module.xml

@@ -25,5 +25,6 @@
         <module name="org.jboss.msc"/>
         <module name="org.jboss.logging"/>
         <module name="org.jboss.vfs"/>
+        <module name="org.wildfly.service"/>
     </dependencies>
 </module>

ee/src/main/java/org/jboss/as/ee/concurrent/resource/definition/ManagedExecutorDefinitionInjectionSource.java

@@ -7,6 +7,7 @@
 import org.glassfish.enterprise.concurrent.AbstractManagedExecutorService;
 import org.glassfish.enterprise.concurrent.ManagedExecutorServiceAdapter;
 import org.jboss.as.controller.ProcessStateNotifier;
+import org.jboss.as.controller.RequirementServiceBuilder;
 import org.jboss.as.controller.capability.CapabilityServiceSupport;
 import org.jboss.as.ee.concurrent.ContextServiceImpl;
 import org.jboss.as.ee.concurrent.deployers.EEConcurrentDefaultBindingProcessor;
@@ -42,7 +43,6 @@ public class ManagedExecutorDefinitionInjectionSource extends ResourceDefinition
     public static final String HUNG_TASK_THRESHOLD_PROP = "hungTaskThreshold";
     public static final String MAX_ASYNC_PROP = "maxAsync";
 
-    private static final String PROCESS_STATE_NOTIFIER_CAPABILITY_NAME = "org.wildfly.management.process-state-notifier";
     private static final String REQUEST_CONTROLLER_CAPABILITY_NAME = "org.wildfly.request-controller";
 
     private String contextServiceRef;
@@ -69,10 +69,10 @@ public void getResourceValue(final ResolutionContext context, final ServiceBuild
         try {
             // install the resource service
             final ServiceName resourceServiceName = ManagedExecutorServiceResourceDefinition.CAPABILITY.getCapabilityServiceName(resourceName);
-            final ServiceBuilder resourceServiceBuilder = phaseContext.getServiceTarget().addService(resourceServiceName);
+            final RequirementServiceBuilder<?> resourceServiceBuilder = phaseContext.getRequirementServiceTarget().addService();
             final Consumer<ManagedExecutorServiceAdapter> consumer = resourceServiceBuilder.provides(resourceServiceName);
             final Supplier<ManagedExecutorHungTasksPeriodicTerminationService> hungTasksPeriodicTerminationService = resourceServiceBuilder.requires(ConcurrentServiceNames.HUNG_TASK_PERIODIC_TERMINATION_SERVICE_NAME);
-            final Supplier<ProcessStateNotifier> processStateNotifierSupplier = resourceServiceBuilder.requires(capabilityServiceSupport.getCapabilityServiceName(PROCESS_STATE_NOTIFIER_CAPABILITY_NAME));
+            final Supplier<ProcessStateNotifier> processStateNotifierSupplier = resourceServiceBuilder.requires(ProcessStateNotifier.SERVICE_DESCRIPTOR);
             Supplier<RequestController> requestControllerSupplier = null;
             if (capabilityServiceSupport.hasCapability(REQUEST_CONTROLLER_CAPABILITY_NAME)) {
                 requestControllerSupplier = resourceServiceBuilder.requires(capabilityServiceSupport.getCapabilityServiceName(REQUEST_CONTROLLER_CAPABILITY_NAME));

ee/src/main/java/org/jboss/as/ee/concurrent/resource/definition/ManagedScheduledExecutorDefinitionInjectionSource.java

@@ -11,6 +11,7 @@
 import org.glassfish.enterprise.concurrent.AbstractManagedExecutorService;
 import org.glassfish.enterprise.concurrent.ManagedScheduledExecutorServiceAdapter;
 import org.jboss.as.controller.ProcessStateNotifier;
+import org.jboss.as.controller.RequirementServiceBuilder;
 import org.jboss.as.controller.capability.CapabilityServiceSupport;
 import org.jboss.as.ee.concurrent.ContextServiceImpl;
 import org.jboss.as.ee.concurrent.deployers.EEConcurrentDefaultBindingProcessor;
@@ -42,7 +43,6 @@ public class ManagedScheduledExecutorDefinitionInjectionSource extends ResourceD
     public static final String HUNG_TASK_THRESHOLD_PROP = "hungTaskThreshold";
     public static final String MAX_ASYNC_PROP = "maxAsync";
 
-    private static final String PROCESS_STATE_NOTIFIER_CAPABILITY_NAME = "org.wildfly.management.process-state-notifier";
     private static final String REQUEST_CONTROLLER_CAPABILITY_NAME = "org.wildfly.request-controller";
 
     private String contextServiceRef;
@@ -68,10 +68,10 @@ public void getResourceValue(final ResolutionContext context, final ServiceBuild
         try {
             // install the resource service
             final ServiceName resourceServiceName = ManagedScheduledExecutorServiceResourceDefinition.CAPABILITY.getCapabilityServiceName(resourceName);
-            final ServiceBuilder resourceServiceBuilder = phaseContext.getServiceTarget().addService(resourceServiceName);
+            final RequirementServiceBuilder<?> resourceServiceBuilder = phaseContext.getRequirementServiceTarget().addService();
             final Consumer<ManagedScheduledExecutorServiceAdapter> consumer = resourceServiceBuilder.provides(resourceServiceName);
             final Supplier<ManagedExecutorHungTasksPeriodicTerminationService> hungTasksPeriodicTerminationService = resourceServiceBuilder.requires(ConcurrentServiceNames.HUNG_TASK_PERIODIC_TERMINATION_SERVICE_NAME);
-            final Supplier<ProcessStateNotifier> processStateNotifierSupplier = resourceServiceBuilder.requires(capabilityServiceSupport.getCapabilityServiceName(PROCESS_STATE_NOTIFIER_CAPABILITY_NAME));
+            final Supplier<ProcessStateNotifier> processStateNotifierSupplier = resourceServiceBuilder.requires(ProcessStateNotifier.SERVICE_DESCRIPTOR);
             Supplier<RequestController> requestControllerSupplier = null;
             if (capabilityServiceSupport.hasCapability(REQUEST_CONTROLLER_CAPABILITY_NAME)) {
                 requestControllerSupplier = resourceServiceBuilder.requires(capabilityServiceSupport.getCapabilityServiceName(REQUEST_CONTROLLER_CAPABILITY_NAME));

ee/src/main/java/org/jboss/as/ee/subsystem/EeCapabilities.java

@@ -6,6 +6,7 @@
 package org.jboss.as.ee.subsystem;
 
 import org.jboss.as.controller.capability.RuntimeCapability;
+import org.jboss.as.controller.services.path.PathManager;
 
 /**
  * The capabilities provided by and required by this subsystem.
@@ -15,13 +16,11 @@
 public final class EeCapabilities {
     private static final String CAPABILITY_BASE = "org.wildfly.ee.";
 
-    static final String PATH_MANAGER_CAPABILITY = "org.wildfly.management.path-manager";
-
     public static final String EE_GLOBAL_DIRECTORY_CAPABILITY_NAME = CAPABILITY_BASE + "global-directory";
 
     public static final RuntimeCapability<Void> EE_GLOBAL_DIRECTORY_CAPABILITY = RuntimeCapability
             .Builder.of(EE_GLOBAL_DIRECTORY_CAPABILITY_NAME, true, GlobalDirectoryService.class)
-            .addRequirements(PATH_MANAGER_CAPABILITY)
+            .addRequirements(PathManager.SERVICE_DESCRIPTOR)
             .build();
 
     public static final String ELYTRON_JACC_CAPABILITY = "org.wildfly.security.jacc-policy";

ee/src/main/java/org/jboss/as/ee/subsystem/GlobalDirectoryResourceDefinition.java

@@ -9,7 +9,6 @@
 import static org.jboss.as.controller.SimpleAttributeDefinitionBuilder.create;
 import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.FILESYSTEM_PATH;
 import static org.jboss.as.ee.subsystem.EeCapabilities.EE_GLOBAL_DIRECTORY_CAPABILITY;
-import static org.jboss.as.ee.subsystem.EeCapabilities.PATH_MANAGER_CAPABILITY;
 
 import java.nio.file.Path;
 import java.util.Arrays;
@@ -110,7 +109,7 @@ protected void performRuntime(OperationContext context, ModelNode operation, Mod
             final CapabilityServiceBuilder<?> serviceBuilder = context.getCapabilityServiceTarget()
                     .addCapability(EE_GLOBAL_DIRECTORY_CAPABILITY);
             final Consumer<GlobalDirectory> provides = serviceBuilder.provides(EE_GLOBAL_DIRECTORY_CAPABILITY);
-            final Supplier<PathManager> pathManagerSupplier = serviceBuilder.requiresCapability(PATH_MANAGER_CAPABILITY, PathManager.class);
+            final Supplier<PathManager> pathManagerSupplier = serviceBuilder.requires(PathManager.SERVICE_DESCRIPTOR);
 
             Service globalDirectoryService = new GlobalDirectoryService(pathManagerSupplier, provides, context.getCurrentAddressValue(), path, relativeTo);