messaging-activemq/src/main/java/org/wildfly/extension/messaging/activemq/TransportConfigOperationHandlers.java
static Map<String, TransportConfiguration> processConnectors(final OperationContext context, final String configServerName, final ModelNode params, final Set<String> bindings) throws OperationFailedException {
        final Map<String, TransportConfiguration> connectors = new HashMap<String, TransportConfiguration>();
        if (params.hasDefined(CONNECTOR)) {
            for (final Property property : params.get(CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(TransportConstants.ALLOWABLE_CONNECTOR_KEYS, parameters);
                ModelNode socketBinding = GenericTransportDefinition.SOCKET_BINDING.resolveModelAttribute(context, config);
                if (socketBinding.isDefined()) {
                    bindings.add(socketBinding.asString());
                    // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start()
                    parameters.put(GenericTransportDefinition.SOCKET_BINDING.getName(), socketBinding.asString());
                }
                final String clazz = FACTORY_CLASS.resolveModelAttribute(context, config).asString();
                connectors.put(connectorName, new TransportConfiguration(clazz, parameters, connectorName, extraParameters));
            }
        }
        if (params.hasDefined(REMOTE_CONNECTOR)) {
            for (final Property property : params.get(REMOTE_CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(TransportConstants.ALLOWABLE_CONNECTOR_KEYS, parameters);
                final String binding = config.get(RemoteTransportDefinition.SOCKET_BINDING.getName()).asString();
                bindings.add(binding);
                // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start()
                parameters.put(RemoteTransportDefinition.SOCKET_BINDING.getName(), binding);
                connectors.put(connectorName, new TransportConfiguration(NettyConnectorFactory.class.getName(), parameters, connectorName, extraParameters));
            }
        }
        if (params.hasDefined(IN_VM_CONNECTOR)) {
            for (final Property property : params.get(IN_VM_CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(IN_VM_ALLOWABLE_KEYS, parameters);
                parameters.put(CONNECTORS_KEYS_MAP.get(InVMTransportDefinition.SERVER_ID.getName()), InVMTransportDefinition.SERVER_ID.resolveModelAttribute(context, config).asInt());
                connectors.put(connectorName, new TransportConfiguration(InVMConnectorFactory.class.getName(), parameters, connectorName, extraParameters));
            }
        }
        if (params.hasDefined(HTTP_CONNECTOR)) {
            for (final Property property : params.get(HTTP_CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(TransportConstants.ALLOWABLE_CONNECTOR_KEYS, parameters);

                final String binding = HTTPConnectorDefinition.SOCKET_BINDING.resolveModelAttribute(context, config).asString();
                bindings.add(binding);
                // ARTEMIS-803 Artemis knows that is must not offset the HTTP port when it is used by colocated backups
                parameters.put(TransportConstants.HTTP_UPGRADE_ENABLED_PROP_NAME, true);
                parameters.put(TransportConstants.HTTP_UPGRADE_ENDPOINT_PROP_NAME, HTTPConnectorDefinition.ENDPOINT.resolveModelAttribute(context, config).asString());
                // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start()
                parameters.put(HTTPConnectorDefinition.SOCKET_BINDING.getName(), binding);
                ModelNode serverNameModelNode = HTTPConnectorDefinition.SERVER_NAME.resolveModelAttribute(context, config);
                // use the name of this server if the server-name attribute is undefined
                String serverName = serverNameModelNode.isDefined() ? serverNameModelNode.asString() : configServerName;
                parameters.put(ACTIVEMQ_SERVER_NAME, serverName);

                connectors.put(connectorName, new TransportConfiguration(NettyConnectorFactory.class.getName(), parameters, connectorName, extraParameters));
            }
        }
        return connectors;
    }
static Map<String, TransportConfiguration> processConnectors(final OperationContext context, final String configServerName, final ModelNode params, final Set<String> bindings) throws OperationFailedException {
        final Map<String, TransportConfiguration> connectors = new HashMap<String, TransportConfiguration>();
        if (params.hasDefined(CONNECTOR)) {
            for (final Property property : params.get(CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(TransportConstants.ALLOWABLE_CONNECTOR_KEYS, parameters);
                ModelNode socketBinding = GenericTransportDefinition.SOCKET_BINDING.resolveModelAttribute(context, config);
                if (socketBinding.isDefined()) {
                    bindings.add(socketBinding.asString());
                    // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start()
                    parameters.put(GenericTransportDefinition.SOCKET_BINDING.getName(), socketBinding.asString());
                }
                final String clazz = FACTORY_CLASS.resolveModelAttribute(context, config).asString();
                connectors.put(connectorName, new TransportConfiguration(clazz, parameters, connectorName, extraParameters));
            }
        }
        if (params.hasDefined(REMOTE_CONNECTOR)) {
            for (final Property property : params.get(REMOTE_CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(TransportConstants.ALLOWABLE_CONNECTOR_KEYS, parameters);
                final String binding = config.get(RemoteTransportDefinition.SOCKET_BINDING.getName()).asString();
                bindings.add(binding);
                // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start()
                parameters.put(RemoteTransportDefinition.SOCKET_BINDING.getName(), binding);
                connectors.put(connectorName, new TransportConfiguration(NettyConnectorFactory.class.getName(), parameters, connectorName, extraParameters));
            }
        }
        if (params.hasDefined(IN_VM_CONNECTOR)) {
            for (final Property property : params.get(IN_VM_CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(IN_VM_ALLOWABLE_KEYS, parameters);
                parameters.put(CONNECTORS_KEYS_MAP.get(InVMTransportDefinition.SERVER_ID.getName()), InVMTransportDefinition.SERVER_ID.resolveModelAttribute(context, config).asInt());
                connectors.put(connectorName, new TransportConfiguration(InVMConnectorFactory.class.getName(), parameters, connectorName, extraParameters));
            }
        }
        if (params.hasDefined(HTTP_CONNECTOR)) {
            for (final Property property : params.get(HTTP_CONNECTOR).asPropertyList()) {
                final String connectorName = property.getName();
                final ModelNode config = property.getValue();
                final Map<String, Object> parameters = getParameters(context, config, CONNECTORS_KEYS_MAP);
                final Map<String, Object> extraParameters = getExtraParameters(TransportConstants.ALLOWABLE_CONNECTOR_KEYS, parameters);

                final String binding = HTTPConnectorDefinition.SOCKET_BINDING.resolveModelAttribute(context, config).asString();
                bindings.add(binding);
                // ARTEMIS-803 Artemis knows that is must not offset the HTTP port when it is used by colocated backups
                parameters.put(TransportConstants.HTTP_UPGRADE_ENABLED_PROP_NAME, true);
                parameters.put(TransportConstants.HTTP_UPGRADE_ENDPOINT_PROP_NAME, HTTPConnectorDefinition.ENDPOINT.resolveModelAttribute(context, config).asString());
                // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start()
                parameters.put(HTTPConnectorDefinition.SOCKET_BINDING.getName(), binding);
                ModelNode serverNameModelNode = HTTPConnectorDefinition.SERVER_NAME.resolveModelAttribute(context, config);
                // use the name of this server if the server-name attribute is undefined
                String serverName = serverNameModelNode.isDefined() ? serverNameModelNode.asString() : configServerName;
                parameters.put(ACTIVEMQ_SERVER_NAME, serverName);

                connectors.put(connectorName, new TransportConfiguration(NettyConnectorFactory.class.getName(), parameters, connectorName, extraParameters));
            }
        }
        return connectors;
    }
static Map < String , TransportConfiguration > processConnectors ( final OperationContext context , final String configServerName , final ModelNode params , final Set < String > bindings ) throws OperationFailedException { final Map < String , TransportConfiguration > connectors = new HashMap < String , TransportConfiguration > ( ) ; if ( params . hasDefined ( CONNECTOR ) ) { for ( final Property property : params . get ( CONNECTOR ) . asPropertyList ( ) ) { final String connectorName = property . getName ( ) ; final ModelNode config = property . getValue ( ) ; final Map < String , Object > parameters = getParameters ( context , config , CONNECTORS_KEYS_MAP ) ; final Map < String , Object > extraParameters = getExtraParameters ( TransportConstants . ALLOWABLE_CONNECTOR_KEYS , parameters ) ; ModelNode socketBinding = GenericTransportDefinition . SOCKET_BINDING . resolveModelAttribute ( context , config ) ; if ( socketBinding . isDefined ( ) ) { bindings . add ( socketBinding . asString ( ) ) ; // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start() parameters . put ( GenericTransportDefinition . SOCKET_BINDING . getName ( ) , socketBinding . asString ( ) ) ; } final String clazz = FACTORY_CLASS . resolveModelAttribute ( context , config ) . asString ( ) ; connectors . put ( connectorName , new TransportConfiguration ( clazz , parameters , connectorName , extraParameters ) ) ; } } if ( params . hasDefined ( REMOTE_CONNECTOR ) ) { for ( final Property property : params . get ( REMOTE_CONNECTOR ) . asPropertyList ( ) ) { final String connectorName = property . getName ( ) ; final ModelNode config = property . getValue ( ) ; final Map < String , Object > parameters = getParameters ( context , config , CONNECTORS_KEYS_MAP ) ; final Map < String , Object > extraParameters = getExtraParameters ( TransportConstants . ALLOWABLE_CONNECTOR_KEYS , parameters ) ; final String binding = config . get ( RemoteTransportDefinition . SOCKET_BINDING . getName ( ) ) . asString ( ) ; bindings . add ( binding ) ; // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start() parameters . put ( RemoteTransportDefinition . SOCKET_BINDING . getName ( ) , binding ) ; connectors . put ( connectorName , new TransportConfiguration ( NettyConnectorFactory . class . getName ( ) , parameters , connectorName , extraParameters ) ) ; } } if ( params . hasDefined ( IN_VM_CONNECTOR ) ) { for ( final Property property : params . get ( IN_VM_CONNECTOR ) . asPropertyList ( ) ) { final String connectorName = property . getName ( ) ; final ModelNode config = property . getValue ( ) ; final Map < String , Object > parameters = getParameters ( context , config , CONNECTORS_KEYS_MAP ) ; final Map < String , Object > extraParameters = getExtraParameters ( IN_VM_ALLOWABLE_KEYS , parameters ) ; parameters . put ( CONNECTORS_KEYS_MAP . get ( InVMTransportDefinition . SERVER_ID . getName ( ) ) , InVMTransportDefinition . SERVER_ID . resolveModelAttribute ( context , config ) . asInt ( ) ) ; connectors . put ( connectorName , new TransportConfiguration ( InVMConnectorFactory . class . getName ( ) , parameters , connectorName , extraParameters ) ) ; } } if ( params . hasDefined ( HTTP_CONNECTOR ) ) { for ( final Property property : params . get ( HTTP_CONNECTOR ) . asPropertyList ( ) ) { final String connectorName = property . getName ( ) ; final ModelNode config = property . getValue ( ) ; final Map < String , Object > parameters = getParameters ( context , config , CONNECTORS_KEYS_MAP ) ; final Map < String , Object > extraParameters = getExtraParameters ( TransportConstants . ALLOWABLE_CONNECTOR_KEYS , parameters ) ; final String binding = HTTPConnectorDefinition . SOCKET_BINDING . resolveModelAttribute ( context , config ) . asString ( ) ; bindings . add ( binding ) ; // ARTEMIS-803 Artemis knows that is must not offset the HTTP port when it is used by colocated backups parameters . put ( TransportConstants . HTTP_UPGRADE_ENABLED_PROP_NAME , true ) ; parameters . put ( TransportConstants . HTTP_UPGRADE_ENDPOINT_PROP_NAME , HTTPConnectorDefinition . ENDPOINT . resolveModelAttribute ( context , config ) . asString ( ) ) ; // uses the parameters to pass the socket binding name that will be read in ActiveMQServerService.start() parameters . put ( HTTPConnectorDefinition . SOCKET_BINDING . getName ( ) , binding ) ; ModelNode serverNameModelNode = HTTPConnectorDefinition . SERVER_NAME . resolveModelAttribute ( context , config ) ; // use the name of this server if the server-name attribute is undefined String serverName = serverNameModelNode . isDefined ( ) ? serverNameModelNode . asString ( ) : configServerName ; parameters . put ( ACTIVEMQ_SERVER_NAME , serverName ) ; connectors . put ( connectorName , new TransportConfiguration ( NettyConnectorFactory . class . getName ( ) , parameters , connectorName , extraParameters ) ) ; } } return connectors ; }
Process the connector information.

@param context       the operation context
@param configuration the ActiveMQ configuration
@param params        the detyped operation parameters
@param bindings      the referenced socket bindings
@throws OperationFailedException
Process the connector information .