signature:
public class ComponentConfiguration { /** * Adds an interceptor factory to every method on the component .
 * @ param factory The interceptor factory to add
 * @ param priority The interceptors relative order
 * @ param publicOnly If true then then interceptor is only added to public methods */
public void addComponentInterceptors ( List < InterceptorFactory > factory , int priority , boolean publicOnly ) { } }

implementation: for ( Method method : ( Iterable < Method > ) classIndex . getClassMethods ( ) ) { if ( publicOnly && ! Modifier . isPublic ( method . getModifiers ( ) ) ) { continue ; } OrderedItemContainer < List < InterceptorFactory > > interceptors = componentInterceptors . get ( method ) ; if ( interceptors == null ) { componentInterceptors . put ( method , interceptors = new OrderedItemContainer < List < InterceptorFactory > > ( ) ) ; } interceptors . add ( factory , priority ) ; }


signature:
public class ComponentConfiguration { /** * Adds an interceptor factory to a given method . The method parameter * must * be retrived from either the
 * { @ link org . jboss . as . server . deployment . reflect . DeploymentReflectionIndex } or from { @ link # getDefinedComponentMethods ( ) } ,
 * as the methods are stored in an identity hash map
 * @ param method The method to add the interceptor to
 * @ param factory The interceptor factory to add
 * @ param priority The interceptors relative order */
public void addComponentInterceptor ( Method method , InterceptorFactory factory , int priority ) { } }

implementation: addComponentInterceptors ( method , Collections . singletonList ( factory ) , priority ) ;


signature:
public class ComponentConfiguration { /** * Adds an interceptor factory to a given method . The method parameter * must * be retrived from either the
 * { @ link org . jboss . as . server . deployment . reflect . DeploymentReflectionIndex } or from { @ link # getDefinedComponentMethods ( ) } ,
 * as the methods are stored in an identity hash map
 * @ param method The method to add the interceptor to
 * @ param factory The interceptor factory to add
 * @ param priority The interceptors relative order */
public void addComponentInterceptors ( Method method , List < InterceptorFactory > factory , int priority ) { } }

implementation: OrderedItemContainer < List < InterceptorFactory > > interceptors = componentInterceptors . get ( method ) ; if ( interceptors == null ) { componentInterceptors . put ( method , interceptors = new OrderedItemContainer < List < InterceptorFactory > > ( ) ) ; } interceptors . add ( factory , priority ) ;


signature:
public class ComponentConfiguration { /** * Adds a timeout interceptor factory to every method on the component .
 * @ param method The method to add it to
 * @ param factory The interceptor factory to add
 * @ param priority The interceptors relative order */
public void addTimeoutViewInterceptor ( final Method method , InterceptorFactory factory , int priority ) { } }

implementation: OrderedItemContainer < InterceptorFactory > interceptors = timeoutInterceptors . get ( method ) ; if ( interceptors == null ) { timeoutInterceptors . put ( method , interceptors = new OrderedItemContainer < InterceptorFactory > ( ) ) ; } interceptors . add ( factory , priority ) ;


signature:
public class ComponentConfiguration { /** * Get the around - construct interceptors .
 * This method should only be called after all interceptors have been added
 * @ return the sorted interceptors */
public List < InterceptorFactory > getAroundConstructInterceptors ( ) { } }

implementation: List < List < InterceptorFactory > > sortedItems = aroundConstructInterceptors . getSortedItems ( ) ; List < InterceptorFactory > interceptorFactories = new ArrayList < > ( ) ; for ( List < InterceptorFactory > i : sortedItems ) { interceptorFactories . addAll ( i ) ; } return interceptorFactories ;


signature:
public class ComponentConfiguration { /** * Adds an around - construct interceptor
 * @ param interceptorFactory The interceptor to add
 * @ param priority The priority */
public void addAroundConstructInterceptor ( InterceptorFactory interceptorFactory , int priority ) { } }

implementation: aroundConstructInterceptors . add ( Collections . singletonList ( interceptorFactory ) , priority ) ;


signature:
public class ComponentConfiguration { /** * Get the post - construct interceptors .
 * This method should only be called after all interceptors have been added
 * @ return the sorted interceptors */
public List < InterceptorFactory > getPostConstructInterceptors ( ) { } }

implementation: List < List < InterceptorFactory > > sortedItems = postConstructInterceptors . getSortedItems ( ) ; List < InterceptorFactory > interceptorFactories = new ArrayList < > ( ) ; for ( List < InterceptorFactory > i : sortedItems ) { interceptorFactories . addAll ( i ) ; } return interceptorFactories ;


signature:
public class ComponentConfiguration { /** * Adds a post construct interceptor
 * @ param interceptorFactory The interceptor to add
 * @ param priority The priority */
public void addPostConstructInterceptor ( InterceptorFactory interceptorFactory , int priority ) { } }

implementation: postConstructInterceptors . add ( Collections . singletonList ( interceptorFactory ) , priority ) ;


signature:
public class ComponentConfiguration { /** * Get the pre - destroy interceptors .
 * This method should only be called after all interceptors have been added
 * @ return the sorted interceptor */
public List < InterceptorFactory > getPreDestroyInterceptors ( ) { } }

implementation: List < List < InterceptorFactory > > sortedItems = preDestroyInterceptors . getSortedItems ( ) ; List < InterceptorFactory > interceptorFactories = new ArrayList < > ( ) ; for ( List < InterceptorFactory > i : sortedItems ) { interceptorFactories . addAll ( i ) ; } return interceptorFactories ;


signature:
public class ComponentConfiguration { /** * Adds a pre destroy interceptor
 * @ param interceptorFactory The interceptor factory to add
 * @ param priority The factories priority */
public void addPreDestroyInterceptor ( InterceptorFactory interceptorFactory , int priority ) { } }

implementation: preDestroyInterceptors . add ( Collections . singletonList ( interceptorFactory ) , priority ) ;


signature:
public class ComponentConfiguration { /** * Get the pre - passivate interceptors .
 * This method should only be called after all interceptors have been added
 * @ return the sorted interceptors */
public List < InterceptorFactory > getPrePassivateInterceptors ( ) { } }

implementation: List < List < InterceptorFactory > > sortedItems = prePassivateInterceptors . getSortedItems ( ) ; List < InterceptorFactory > interceptorFactories = new ArrayList < > ( ) ; for ( List < InterceptorFactory > i : sortedItems ) { interceptorFactories . addAll ( i ) ; } return interceptorFactories ;


signature:
public class ComponentConfiguration { /** * Adds a pre passivate interceptor
 * @ param interceptorFactory The interceptor to add
 * @ param priority The priority */
public void addPrePassivateInterceptor ( InterceptorFactory interceptorFactory , int priority ) { } }

implementation: prePassivateInterceptors . add ( Collections . singletonList ( interceptorFactory ) , priority ) ;


signature:
public class ComponentConfiguration { /** * Get the post - activate interceptors .
 * This method should only be called after all interceptors have been added
 * @ return the sorted interceptors */
public List < InterceptorFactory > getPostActivateInterceptors ( ) { } }

implementation: List < List < InterceptorFactory > > sortedItems = postActivateInterceptors . getSortedItems ( ) ; List < InterceptorFactory > interceptorFactories = new ArrayList < > ( ) ; for ( List < InterceptorFactory > i : sortedItems ) { interceptorFactories . addAll ( i ) ; } return interceptorFactories ;


signature:
public class ComponentConfiguration { /** * Adds a post activate interceptor
 * @ param interceptorFactory The interceptor to add
 * @ param priority The priority */
public void addPostActivateInterceptor ( InterceptorFactory interceptorFactory , int priority ) { } }

implementation: postActivateInterceptors . add ( Collections . singletonList ( interceptorFactory ) , priority ) ;


signature:
public class ComponentConfiguration { /** * Set the component create service factory for this component .
 * @ param componentCreateServiceFactory the component create service factory */
public void setComponentCreateServiceFactory ( final ComponentCreateServiceFactory componentCreateServiceFactory ) { } }

implementation: if ( componentCreateServiceFactory == null ) { throw EeLogger . ROOT_LOGGER . nullVar ( "componentCreateServiceFactory" , "component" , getComponentName ( ) ) ; } this . componentCreateServiceFactory = componentCreateServiceFactory ;


signature:
public class BasicComponentCreateService { /** * { @ inheritDoc } */
public synchronized Component getValue ( ) throws IllegalStateException , IllegalArgumentException { } }

implementation: Component component = this . component ; if ( component == null ) { throw EeLogger . ROOT_LOGGER . serviceNotStarted ( ) ; } return component ;


signature:
public class ProxyServicesImpl { /** * This method corresponds to the original { @ code _ getClassLoader ( ) } method and returns
 * { @ link Module } based on original class . This module is then used when defining proxy classes .
 * Most likely we want to return a { @ link Module } into which the originalClass belongs but in case such a module
 * doesn ' t know Weld dependencies , we need to return different module , one that was used by the deployment . */
private Module getModule ( Class < ? > originalClass ) { } }

implementation:
if ( originalClass . getName ( ) . startsWith ( "java" ) ) { return module ; } else { Module definingModule = Module . forClass ( originalClass ) ; Boolean hasWeldDependencies = processedStaticModules . get ( definingModule . getIdentifier ( ) ) ; boolean logWarning = false ; // only log for the first class in the module
if ( hasWeldDependencies == null ) { hasWeldDependencies = canLoadWeldProxies ( definingModule ) ; // may be run multiple times but that does not matter
logWarning = processedStaticModules . putIfAbsent ( definingModule . getIdentifier ( ) , hasWeldDependencies ) == null ; } if ( hasWeldDependencies ) { // this module declares Weld dependencies - we can use module ' s classloader to load the proxy class
// pros : package - private members will work fine
// cons : proxy classes will remain loaded by the module ' s classloader after undeployment ( nothing else leaks )
return definingModule ; } else { // no weld dependencies - we use deployment ' s classloader to load the proxy class
// pros : proxy classes unloaded with undeployment
// cons : package - private methods and constructors will yield IllegalAccessException
if ( logWarning ) { WeldLogger . ROOT_LOGGER . loadingProxiesUsingDeploymentClassLoader ( definingModule . getIdentifier ( ) , Arrays . toString ( REQUIRED_WELD_DEPENDENCIES ) ) ; } return this . module ; } }


signature:
public class ProxyServicesImpl { /** * without ProtectionDomain */
private ProtectionDomain getProtectionDomain ( final Class < ? > clazz ) { } }

implementation: final SecurityManager sm = System . getSecurityManager ( ) ; if ( sm != null ) { return doPrivileged ( ( PrivilegedAction < ProtectionDomain > ) clazz :: getProtectionDomain ) ; } else { return clazz . getProtectionDomain ( ) ; }


signature:
public class ExternalBeanArchiveProcessor { /** * The entry key is bean . xml URL , value is ( optional ) jandex index URL .
 * @ param dependencyModule
 * @ return the map of exported resources */
private Map < URL , URL > findExportedResources ( Module dependencyModule ) { } }

implementation: Set < URL > beanXmls = findExportedResource ( dependencyModule , META_INF_BEANS_XML ) ; if ( beanXmls . isEmpty ( ) ) { return Collections . emptyMap ( ) ; } Set < URL > indexes = findExportedResource ( dependencyModule , META_INF_JANDEX_IDX ) ; Map < URL , URL > ret = new HashMap < > ( ) ; for ( URL beansXml : beanXmls ) { String urlBase = beansXml . toString ( ) . substring ( 0 , beansXml . toString ( ) . length ( ) - META_INF_BEANS_XML . length ( ) ) ; URL idx = null ; for ( URL index : indexes ) { if ( index . toString ( ) . startsWith ( urlBase ) ) { idx = index ; break ; } } ret . put ( beansXml , idx ) ; } return ret ;


signature:
public class PooledConnectionFactoryRemove { /** * Remove JNDI alias ' binder services .
 * The 1st JNDI entry is not removed by this method as it is already handled when removing
 * the pooled - connection - factory service */
protected void removeJNDIAliases ( OperationContext context , List < ModelNode > entries ) { } }

implementation: if ( entries . size ( ) > 1 ) { for ( int i = 1 ; i < entries . size ( ) ; i ++ ) { ContextNames . BindInfo aliasBindInfo = ContextNames . bindInfoFor ( entries . get ( i ) . asString ( ) ) ; context . removeService ( aliasBindInfo . getBinderServiceName ( ) ) ; } }


signature:
public class WildFlyCustomJtaPlatform { /** * Hibernate native applications cannot know when the TransactionManager + TransactionSynchronizationRegistry
 * services are stopped but JPA container managed applications can and will call setTransactionSynchronizationRegistry
 * with the new ( global ) TransactionSynchronizationRegistry to use .
 * @ param tsr */
public static void setTransactionSynchronizationRegistry ( TransactionSynchronizationRegistry tsr ) { } }

implementation: if ( ( Assert . checkNotNullParam ( "tsr" , tsr ) ) != transactionSynchronizationRegistry ) { synchronized ( WildFlyCustomJtaPlatform . class ) { if ( tsr != transactionSynchronizationRegistry ) { transactionSynchronizationRegistry = tsr ; } } }


signature:
public class EJBClientConfiguratorService { /** * Perform the configuration of the transport provider .
 * @ param builder the EJB client context builder ( not { @ code null } ) */
public void accept ( final EJBClientContext . Builder builder ) { } }

implementation: final EJBTransportProvider remoteTransportProvider = this . remoteTransportProvider ; if ( remoteTransportProvider != null ) { builder . addTransportProvider ( remoteTransportProvider ) ; builder . addTransportProvider ( remoteHttpTransportProvider ) ; }


signature:
public class ContextNames { /** * Get the base service name of a component ' s JNDI namespace .
 * @ param app the application name ( must not be { @ code null } )
 * @ param module the module name ( must not be { @ code null } )
 * @ param comp the component name ( must not be { @ code null } )
 * @ return the base service name */
public static ServiceName contextServiceNameOfComponent ( String app , String module , String comp ) { } }

implementation: return COMPONENT_CONTEXT_SERVICE_NAME . append ( app , module , comp ) ;


signature:
public class ContextNames { /** * Get the base service name of a module ' s JNDI namespace .
 * @ param app the application name ( must not be { @ code null } )
 * @ param module the module name ( must not be { @ code null } )
 * @ return the base service name */
public static ServiceName contextServiceNameOfModule ( String app , String module ) { } }

implementation: return MODULE_CONTEXT_SERVICE_NAME . append ( app , module ) ;


signature:
public class ContextNames { /** * Get the service name of a context , or { @ code null } if there is no service mapping for the context name .
 * @ param app the application name
 * @ param module the module name
 * @ param comp the component name
 * @ param context the context to check
 * @ return the BindInfo */
public static BindInfo bindInfoFor ( String app , String module , String comp , String context ) { } }

implementation:
if ( context . startsWith ( "java:" ) ) { final String namespace ; final int i = context . indexOf ( '/' ) ; if ( i == - 1 ) { namespace = context . substring ( 5 ) ; } else if ( i == 5 ) { // Absolute path
return new BindInfo ( JAVA_CONTEXT_SERVICE_NAME , context . substring ( 6 ) ) ; } else { namespace = context . substring ( 5 , i ) ; } sanitazeNameSpace ( namespace , context ) ; if ( namespace . equals ( "global" ) ) { return new BindInfo ( GLOBAL_CONTEXT_SERVICE_NAME , context . substring ( 12 ) ) ; } else if ( namespace . equals ( "jboss" ) ) { String rest = context . substring ( i ) ; if ( rest . startsWith ( "/exported/" ) ) { return new BindInfo ( EXPORTED_CONTEXT_SERVICE_NAME , context . substring ( 20 ) ) ; } else { return new BindInfo ( JBOSS_CONTEXT_SERVICE_NAME , context . substring ( 11 ) ) ; } } else if ( namespace . equals ( "app" ) ) { return new BindInfo ( contextServiceNameOfApplication ( app ) , context . substring ( 9 ) ) ; } else if ( namespace . equals ( "module" ) ) { return new BindInfo ( contextServiceNameOfModule ( app , module ) , context . substring ( 12 ) ) ; } else if ( namespace . equals ( "comp" ) ) { return new BindInfo ( contextServiceNameOfComponent ( app , module , comp ) , context . substring ( 10 ) ) ; } else { return new BindInfo ( JBOSS_CONTEXT_SERVICE_NAME , context ) ; } } else { return null ; }


signature:
public class ContextNames { /** * Get the service name of an environment entry
 * @ param app the application name
 * @ param module the module name
 * @ param comp the component name
 * @ param useCompNamespace If the component has its own comp namespace
 * @ param envEntryName The env entry name
 * @ return the service name or { @ code null } if there is no service */
public static BindInfo bindInfoForEnvEntry ( String app , String module , String comp , boolean useCompNamespace , final String envEntryName ) { } }

implementation: if ( envEntryName . startsWith ( "java:" ) ) { if ( useCompNamespace ) { return bindInfoFor ( app , module , comp , envEntryName ) ; } else { if ( envEntryName . startsWith ( "java:comp" ) ) { return bindInfoFor ( app , module , module , "java:module" + envEntryName . substring ( "java:comp" . length ( ) ) ) ; } else { return bindInfoFor ( app , module , module , envEntryName ) ; } } } else { if ( useCompNamespace ) { return bindInfoFor ( app , module , comp , "java:comp/env/" + envEntryName ) ; } else { return bindInfoFor ( app , module , module , "java:module/env/" + envEntryName ) ; } }


signature:
public class ContextNames { /** * Get the service name of a NamingStore
 * @ param jndiName the jndi name
 * @ return the bind info for the jndi name */
public static BindInfo bindInfoFor ( final String jndiName ) { } }

implementation:
// TODO : handle non java : schemes
String bindName ; if ( jndiName . startsWith ( "java:" ) ) { bindName = jndiName . substring ( 5 ) ; } else if ( ! jndiName . startsWith ( "jboss" ) && ! jndiName . startsWith ( "global" ) && ! jndiName . startsWith ( "/" ) ) { bindName = "/" + jndiName ; } else { bindName = jndiName ; } final ServiceName parentContextName ; if ( bindName . startsWith ( "jboss/exported/" ) ) { parentContextName = EXPORTED_CONTEXT_SERVICE_NAME ; bindName = bindName . substring ( 15 ) ; } else if ( bindName . startsWith ( "jboss/" ) ) { parentContextName = JBOSS_CONTEXT_SERVICE_NAME ; bindName = bindName . substring ( 6 ) ; } else if ( bindName . startsWith ( "global/" ) ) { parentContextName = GLOBAL_CONTEXT_SERVICE_NAME ; bindName = bindName . substring ( 7 ) ; } else if ( bindName . startsWith ( "/" ) ) { parentContextName = JAVA_CONTEXT_SERVICE_NAME ; bindName = bindName . substring ( 1 ) ; } else { throw NamingLogger . ROOT_LOGGER . illegalContextInName ( jndiName ) ; } return new BindInfo ( parentContextName , bindName ) ;


signature:
public class TransactionalEntityManagerHelper { /** * Save the specified EntityManager in the local threads active transaction . The TransactionSynchronizationRegistry
 * will clear the reference to the EntityManager when the transaction completes .
 * @ param scopedPuName
 * @ param entityManager */
public void putEntityManagerInTransactionRegistry ( String scopedPuName , EntityManager entityManager ) { } }

implementation: try { Transaction transaction = this . transactionManager . getTransaction ( ) ; transaction . registerSynchronization ( new TransactionalEntityManagerSynchronization ( entityManager ) ) ; this . transactionSynchronizationRegistry . putResource ( scopedPuName , entityManager ) ; } catch ( Exception e ) { throw PicketLinkLogger . ROOT_LOGGER . idmJpaFailedCreateTransactionEntityManager ( e ) ; }


signature:
public class AbstractParser { /** * Reads and trims the text for the given attribute and returns it or { @ code null }
 * @ param reader source for the attribute text
 * @ param attributeName the name of the attribute
 * @ return the string representing trimmed attribute text or { @ code null } if there is none */
public String rawAttributeText ( XMLStreamReader reader , String attributeName ) { } }

implementation: return rawAttributeText ( reader , attributeName , null ) ;


signature:
public class EjbSecurityDeployer { /** * { @ inheritDoc } */
@ Override protected JaccService < AttachmentList < EjbJaccConfig > > createService ( String contextId , AttachmentList < EjbJaccConfig > metaData , Boolean standalone ) { } }

implementation: return new EjbJaccService ( contextId , metaData , standalone ) ;


signature:
public class CorbaServiceUtil { /** * Adds a { @ code BinderService } to the specified target . The service binds the specified value to JNDI under the
 * { @ code java : / jboss / contextName } context .
 * @ param target the { @ code ServiceTarget } where the service will be added .
 * @ param contextName the JNDI context name where the value will be bound .
 * @ param value the value to be bound . */
public static void bindObject ( final ServiceTarget target , final String contextName , final Object value ) { } }

implementation: final BinderService binderService = new BinderService ( contextName ) ; binderService . getManagedObjectInjector ( ) . inject ( new ValueManagedReferenceFactory ( Values . immediateValue ( value ) ) ) ; target . addService ( ContextNames . buildServiceName ( ContextNames . JBOSS_CONTEXT_SERVICE_NAME , contextName ) , binderService ) . addDependency ( ContextNames . JBOSS_CONTEXT_SERVICE_NAME , ServiceBasedNamingStore . class , binderService . getNamingStoreInjector ( ) ) . install ( ) ;


signature:
public class DefaultAuthenticationCacheFactory { /** * Returns a default cache implementation
 * @ return cache implementation */
public ConcurrentMap < Principal , DomainInfo > getCache ( ) { } }

implementation: return new LRUCache < > ( 1000 , ( key , value ) -> { if ( value != null ) { value . logout ( ) ; } } ) ;


signature:
public class ValueDefImpl { /** * LocalIRObject implementation - - - - - */
public IRObject getReference ( ) { } }

implementation: if ( ref == null ) { ref = org . omg . CORBA . ValueDefHelper . narrow ( servantToReference ( new ValueDefPOATie ( this ) ) ) ; } return ref ;


signature:
public class ValueDefImpl { /** * IDLTypeOperations implementation - - - - - */
public TypeCode type ( ) { } }

implementation: if ( typeCode == null ) { short modifier = VM_NONE . value ; if ( is_custom ) modifier = VM_CUSTOM . value ; else if ( is_abstract ) modifier = VM_ABSTRACT . value ; typeCode = getORB ( ) . create_value_tc ( id , name , modifier , baseValueTypeCode , getValueMembersForTypeCode ( ) ) ; } return typeCode ;


signature:
public class ValueDefImpl { /** * ContainedImpl implementation - - - - - */
public Description describe ( ) { } }

implementation: String defined_in_id = "IR" ; if ( defined_in instanceof org . omg . CORBA . ContainedOperations ) defined_in_id = ( ( org . omg . CORBA . ContainedOperations ) defined_in ) . id ( ) ; ValueDescription md = new ValueDescription ( name , id , is_abstract , is_custom , defined_in_id , version , supported_interfaces , abstract_base_valuetypes , false , baseValue ) ; Any any = getORB ( ) . create_any ( ) ; ValueDescriptionHelper . insert ( any , md ) ; return new Description ( DefinitionKind . dk_Value , any ) ;


signature:
public class ValueDefImpl { /** * Create the valueMembers array , and return it . */
private ValueMember [ ] getValueMembers ( ) { } }

implementation: if ( valueMembers != null ) return valueMembers ; LocalContained [ ] c = _contents ( DefinitionKind . dk_ValueMember , false ) ; valueMembers = new ValueMember [ c . length ] ; for ( int i = 0 ; i < c . length ; ++ i ) { ValueMemberDefImpl vmdi = ( ValueMemberDefImpl ) c [ i ] ; valueMembers [ i ] = new ValueMember ( vmdi . name ( ) , vmdi . id ( ) , ( ( LocalContained ) vmdi . defined_in ) . id ( ) , vmdi . version ( ) , vmdi . type ( ) , vmdi . type_def ( ) , vmdi . access ( ) ) ; } return valueMembers ;


signature:
public class ValueDefImpl { /** * Create a valueMembers array for TypeCode creation only , and return it . */
private ValueMember [ ] getValueMembersForTypeCode ( ) { } }

implementation:
LocalContained [ ] c = _contents ( DefinitionKind . dk_ValueMember , false ) ; ValueMember [ ] vms = new ValueMember [ c . length ] ; for ( int i = 0 ; i < c . length ; ++ i ) { ValueMemberDefImpl vmdi = ( ValueMemberDefImpl ) c [ i ] ; vms [ i ] = new ValueMember ( vmdi . name ( ) , null , // ignore id
null , // ignore defined _ in
null , // ignore version
vmdi . type ( ) , null , // ignore type _ def
vmdi . access ( ) ) ; } return vms ;


signature:
public class ApplicationContextProcessor { /** * Add a ContextService for this module .
 * @ param phaseContext the deployment unit context
 * @ throws DeploymentUnitProcessingException */
public void deploy ( DeploymentPhaseContext phaseContext ) throws DeploymentUnitProcessingException { } }

implementation: final DeploymentUnit deploymentUnit = phaseContext . getDeploymentUnit ( ) ; if ( deploymentUnit . getParent ( ) != null ) { return ; } EEModuleDescription moduleDescription = deploymentUnit . getAttachment ( org . jboss . as . ee . component . Attachments . EE_MODULE_DESCRIPTION ) ; final ServiceTarget serviceTarget = phaseContext . getServiceTarget ( ) ; final ServiceName applicationContextServiceName = ContextNames . contextServiceNameOfApplication ( moduleDescription . getApplicationName ( ) ) ; final NamingStoreService contextService = new NamingStoreService ( true ) ; serviceTarget . addService ( applicationContextServiceName , contextService ) . install ( ) ; final ServiceName appNameServiceName = applicationContextServiceName . append ( "AppName" ) ; final BinderService applicationNameBinder = new BinderService ( "AppName" ) ; applicationNameBinder . getManagedObjectInjector ( ) . inject ( new ValueManagedReferenceFactory ( Values . immediateValue ( moduleDescription . getApplicationName ( ) ) ) ) ; serviceTarget . addService ( appNameServiceName , applicationNameBinder ) . addDependency ( applicationContextServiceName , ServiceBasedNamingStore . class , applicationNameBinder . getNamingStoreInjector ( ) ) . install ( ) ; deploymentUnit . addToAttachmentList ( org . jboss . as . server . deployment . Attachments . JNDI_DEPENDENCIES , appNameServiceName ) ; deploymentUnit . putAttachment ( Attachments . APPLICATION_CONTEXT_CONFIG , applicationContextServiceName ) ;


signature:
public class AbstractFederationSubsystemReader { /** * Creates the root subsystem ' s root address .
 * @ return */
private ModelNode createSubsystemRoot ( ) { } }

implementation: ModelNode subsystemAddress = new ModelNode ( ) ; subsystemAddress . add ( ModelDescriptionConstants . SUBSYSTEM , FederationExtension . SUBSYSTEM_NAME ) ; subsystemAddress . protect ( ) ; return Util . getEmptyOperation ( ADD , subsystemAddress ) ;


signature:
public class AbstractFederationSubsystemReader { /** * Reads a element from the stream considering the parameters .
 * @ param reader XMLExtendedStreamReader instance from which the elements are read .
 * @ param xmlElement Name of the Model Element to be parsed .
 * @ param key Name of the attribute to be used to as the key for the model .
 * @ param addOperations List of operations .
 * @ param lastNode Parent ModelNode instance .
 * @ param attributes AttributeDefinition instances to be used to extract the attributes and populate the resulting model .
 * @ return A ModelNode instance populated .
 * @ throws javax . xml . stream . XMLStreamException */
protected ModelNode parseConfig ( XMLExtendedStreamReader reader , ModelElement xmlElement , String key , ModelNode lastNode , List < SimpleAttributeDefinition > attributes , List < ModelNode > addOperations ) throws XMLStreamException { } }

implementation: if ( ! reader . getLocalName ( ) . equals ( xmlElement . getName ( ) ) ) { return null ; } ModelNode modelNode = Util . getEmptyOperation ( ADD , null ) ; int attributeCount = reader . getAttributeCount ( ) ; for ( int i = 0 ; i < attributeCount ; i ++ ) { String attributeLocalName = reader . getAttributeLocalName ( i ) ; if ( ModelElement . forName ( attributeLocalName ) == null ) { throw unexpectedAttribute ( reader , i ) ; } } for ( SimpleAttributeDefinition simpleAttributeDefinition : attributes ) { String attributeValue = reader . getAttributeValue ( "" , simpleAttributeDefinition . getXmlName ( ) ) ; simpleAttributeDefinition . parseAndSetParameter ( attributeValue , modelNode , reader ) ; } String name = xmlElement . getName ( ) ; if ( key != null ) { name = key ; if ( modelNode . hasDefined ( key ) ) { name = modelNode . get ( key ) . asString ( ) ; } else { String attributeValue = reader . getAttributeValue ( "" , key ) ; if ( attributeValue != null ) { name = attributeValue ; } } } modelNode . get ( ModelDescriptionConstants . OP_ADDR ) . set ( lastNode . clone ( ) . get ( OP_ADDR ) . add ( xmlElement . getName ( ) , name ) ) ; addOperations . add ( modelNode ) ; return modelNode ;


signature:
public class NamingSubsystemXMLPersister { /** * { @ inheritDoc } */
@ Override public void writeContent ( final XMLExtendedStreamWriter writer , final SubsystemMarshallingContext context ) throws XMLStreamException { } }

implementation:
context . startSubsystemElement ( NamingExtension . NAMESPACE_2_0 , false ) ; ModelNode model = context . getModelNode ( ) ; // bindings
if ( model . hasDefined ( BINDING ) ) { writer . writeStartElement ( NamingSubsystemXMLElement . BINDINGS . getLocalName ( ) ) ; final ModelNode bindingModel = model . get ( BINDING ) ; this . writeBindings ( writer , bindingModel ) ; // < / timer - service >
writer . writeEndElement ( ) ; } if ( model . hasDefined ( SERVICE ) ) { final ModelNode service = model . get ( SERVICE ) ; if ( service . has ( REMOTE_NAMING ) ) { writer . writeEmptyElement ( REMOTE_NAMING ) ; } } // write the subsystem end element
writer . writeEndElement ( ) ;


signature:
public class CMResourceAdd { /** * { @ inheritDoc } */
@ Override protected void populateModel ( ModelNode operation , ModelNode model ) throws OperationFailedException { } }

implementation: String str = PathAddress . pathAddress ( operation . get ( OP_ADDR ) ) . getLastElement ( ) . getValue ( ) ; if ( ! str . startsWith ( "java:/" ) && ! str . startsWith ( "java:jboss/" ) ) { throw ROOT_LOGGER . jndiNameInvalidFormat ( ) ; } CMResourceResourceDefinition . CM_TABLE_NAME . validateAndSet ( operation , model ) ; CMResourceResourceDefinition . CM_TABLE_BATCH_SIZE . validateAndSet ( operation , model ) ; CMResourceResourceDefinition . CM_TABLE_IMMEDIATE_CLEANUP . validateAndSet ( operation , model ) ;


signature:
public class CMResourceAdd { /** * { @ inheritDoc } */
@ Override protected void performRuntime ( final OperationContext context , final ModelNode operation , final ModelNode model ) throws OperationFailedException { } }

implementation: PathAddress address = PathAddress . pathAddress ( operation . get ( OP_ADDR ) ) ; final String jndiName = address . getLastElement ( ) . getValue ( ) ; final String tableName = CMResourceResourceDefinition . CM_TABLE_NAME . resolveModelAttribute ( context , model ) . asString ( ) ; final int batchSize = CMResourceResourceDefinition . CM_TABLE_BATCH_SIZE . resolveModelAttribute ( context , model ) . asInt ( ) ; final boolean immediateCleanup = CMResourceResourceDefinition . CM_TABLE_IMMEDIATE_CLEANUP . resolveModelAttribute ( context , model ) . asBoolean ( ) ; ROOT_LOGGER . debugf ( "adding commit-markable-resource: jndi-name=%s, table-name=%s, batch-size=%d, immediate-cleanup=%b" , jndiName , tableName , batchSize , immediateCleanup ) ; CMResourceService service = new CMResourceService ( jndiName , tableName , immediateCleanup , batchSize ) ; context . getServiceTarget ( ) . addService ( TxnServices . JBOSS_TXN_CMR . append ( jndiName ) , service ) . addDependency ( TxnServices . JBOSS_TXN_JTA_ENVIRONMENT , JTAEnvironmentBean . class , service . getJTAEnvironmentBeanInjector ( ) ) . setInitialMode ( ServiceController . Mode . ACTIVE ) . install ( ) ; if ( ! context . isBooting ( ) ) { context . reloadRequired ( ) ; }


signature:
public class NamingService { /** * Creates a new NamingServer and sets the naming context to use the naming server .
 * @ param context The start context
 * @ throws StartException If any errors occur setting up the naming server */
public void start ( StartContext context ) throws StartException { } }

implementation: ROOT_LOGGER . startingService ( ) ; try { NamingContext . setActiveNamingStore ( namingStore . getValue ( ) ) ; } catch ( Throwable t ) { throw new StartException ( NamingLogger . ROOT_LOGGER . failedToStart ( "naming service" ) , t ) ; }


signature:
public class NamingSubsystem10Parser { /** * { @ inheritDoc } */
@ Override public void readElement ( XMLExtendedStreamReader reader , List < ModelNode > list ) throws XMLStreamException { } }

implementation:
ParseUtils . requireNoAttributes ( reader ) ; ParseUtils . requireNoContent ( reader ) ; list . add ( Util . createAddOperation ( PathAddress . pathAddress ( NamingExtension . SUBSYSTEM_PATH ) ) ) ; if ( ! appclient ) { // we do not add remote naming to the application client
// note that this is a bi
list . add ( Util . createAddOperation ( PathAddress . pathAddress ( NamingExtension . SUBSYSTEM_PATH ) . append ( NamingSubsystemModel . SERVICE , NamingSubsystemModel . REMOTE_NAMING ) ) ) ; }


signature:
public class JPAClassFileTransformerProcessor { /** * Add dependencies for modules required for JPA deployments */
public void deploy ( DeploymentPhaseContext phaseContext ) throws DeploymentUnitProcessingException { } }

implementation: final DeploymentUnit deploymentUnit = phaseContext . getDeploymentUnit ( ) ; setClassLoaderTransformer ( deploymentUnit ) ;


signature:
public class WeldComponentIntegrationProcessor { /** * As the weld based instantiator needs access to the bean manager it is installed as a service . */
private void addWeldIntegration ( final Iterable < ComponentIntegrator > componentIntegrators , final ComponentInterceptorSupport componentInterceptorSupport , final ServiceTarget target , final ComponentConfiguration configuration , final ComponentDescription description , final Class < ? > componentClass , final String beanName , final ServiceName weldServiceName , final ServiceName weldStartService , final ServiceName beanManagerService , final Set < Class < ? > > interceptorClasses , final ClassLoader classLoader , final String beanDeploymentArchiveId ) { } }

implementation: final ServiceName serviceName = configuration . getComponentDescription ( ) . getServiceName ( ) . append ( "WeldInstantiator" ) ; final ServiceBuilder < ? > builder = target . addService ( serviceName ) ; builder . requires ( weldStartService ) ; configuration . setInstanceFactory ( WeldManagedReferenceFactory . INSTANCE ) ; configuration . getStartDependencies ( ) . add ( new DependencyConfigurator < ComponentStartService > ( ) { @ Override public void configureDependency ( final ServiceBuilder < ? > serviceBuilder , ComponentStartService service ) throws DeploymentUnitProcessingException { serviceBuilder . requires ( serviceName ) ; } } ) ; boolean isComponentIntegrationPerformed = false ; for ( ComponentIntegrator componentIntegrator : componentIntegrators ) { Supplier < ServiceName > bindingServiceNameSupplier = ( ) -> { if ( componentInterceptorSupport == null ) { throw WeldLogger . DEPLOYMENT_LOGGER . componentInterceptorSupportNotAvailable ( componentClass ) ; } return addWeldInterceptorBindingService ( target , configuration , componentClass , beanName , weldServiceName , weldStartService , beanDeploymentArchiveId , componentInterceptorSupport ) ; } ; DefaultInterceptorIntegrationAction integrationAction = ( bindingServiceName ) -> { if ( componentInterceptorSupport == null ) { throw WeldLogger . DEPLOYMENT_LOGGER . componentInterceptorSupportNotAvailable ( componentClass ) ; } addJsr299BindingsCreateInterceptor ( configuration , description , beanName , weldServiceName , builder , bindingServiceName , componentInterceptorSupport ) ; addCommonLifecycleInterceptionSupport ( configuration , builder , bindingServiceName , beanManagerService , componentInterceptorSupport ) ; configuration . addComponentInterceptor ( new UserInterceptorFactory ( factory ( InterceptionType . AROUND_INVOKE , builder , bindingServiceName , componentInterceptorSupport ) , factory ( InterceptionType . AROUND_TIMEOUT , builder , bindingServiceName , componentInterceptorSupport ) ) , InterceptorOrder . Component . CDI_INTERCEPTORS , false ) ; } ; if ( componentIntegrator . integrate ( beanManagerService , configuration , description , builder , bindingServiceNameSupplier , integrationAction , componentInterceptorSupport ) ) { isComponentIntegrationPerformed = true ; break ; }


signature:
public class BatchServiceNames { /** * Creates the service name used for the job operator registered for the deployment .
 * @ param deploymentRuntimeName the runtime name for the deployment
 * @ param subdeploymentName the name of the subdeployment
 * @ return the service name */
public static ServiceName jobOperatorServiceName ( final String deploymentRuntimeName , final String subdeploymentName ) { } }

implementation: return Services . deploymentUnitName ( deploymentRuntimeName , subdeploymentName ) . append ( "batch" ) . append ( "job-operator" ) ;


signature:
public class EEApplicationDescription { /** * Add a component to this application .
 * @ param description the component description
 * @ param deploymentRoot */
public void addComponent ( final ComponentDescription description , final VirtualFile deploymentRoot ) { } }

implementation: for ( final ViewDescription viewDescription : description . getViews ( ) ) { List < ViewInformation > viewComponents = componentsByViewName . get ( viewDescription . getViewClassName ( ) ) ; if ( viewComponents == null ) { viewComponents = new ArrayList < ViewInformation > ( 1 ) ; componentsByViewName . put ( viewDescription . getViewClassName ( ) , viewComponents ) ; } viewComponents . add ( new ViewInformation ( viewDescription , deploymentRoot , description . getComponentName ( ) ) ) ; } List < Description > components = componentsByName . get ( description . getComponentName ( ) ) ; if ( components == null ) { componentsByName . put ( description . getComponentName ( ) , components = new ArrayList < Description > ( 1 ) ) ; } components . add ( new Description ( description , deploymentRoot ) ) ;


signature:
public class EEApplicationDescription { /** * Add a message destination to the application
 * @ param name The message destination name
 * @ param resolvedName The resolved JNDI name
 * @ param deploymentRoot The deployment root */
public void addMessageDestination ( final String name , final String resolvedName , final VirtualFile deploymentRoot ) { } }

implementation: List < MessageDestinationMapping > components = messageDestinationJndiMapping . get ( name ) ; if ( components == null ) { messageDestinationJndiMapping . put ( name , components = new ArrayList < MessageDestinationMapping > ( 1 ) ) ; } components . add ( new MessageDestinationMapping ( resolvedName , deploymentRoot ) ) ;


signature:
public class EEApplicationDescription { /** * Get all views that have the given type in the application
 * @ param viewType The view type
 * @ return All views of the given type */
public Set < ViewDescription > getComponentsForViewName ( final String viewType , final VirtualFile deploymentRoot ) { } }

implementation: final List < ViewInformation > info = componentsByViewName . get ( viewType ) ; if ( info == null ) { return Collections . < ViewDescription > emptySet ( ) ; } final Set < ViewDescription > ret = new HashSet < ViewDescription > ( ) ; final Set < ViewDescription > currentDep = new HashSet < ViewDescription > ( ) ; for ( ViewInformation i : info ) { if ( deploymentRoot . equals ( i . deploymentRoot ) ) { currentDep . add ( i . viewDescription ) ; } ret . add ( i . viewDescription ) ; } if ( ! currentDep . isEmpty ( ) ) { return currentDep ; } return ret ;


signature:
public class EEApplicationDescription { /** * Get all components in the application that have the given name
 * @ param componentName The name of the component
 * @ param deploymentRoot The deployment root of the component doing the lookup
 * @ return A set of all views for the given component name and type */
public Set < ComponentDescription > getComponents ( final String componentName , final VirtualFile deploymentRoot ) { } }

implementation:
if ( componentName . contains ( "#" ) ) { final String [ ] parts = componentName . split ( "#" ) ; String path = parts [ 0 ] ; if ( ! path . startsWith ( "../" ) ) { path = "../" + path ; } final VirtualFile virtualPath = deploymentRoot . getChild ( path ) ; final String name = parts [ 1 ] ; final List < Description > info = componentsByName . get ( name ) ; if ( info == null ) { return Collections . emptySet ( ) ; } final Set < ComponentDescription > ret = new HashSet < ComponentDescription > ( ) ; for ( Description i : info ) { // now we need to check the path
if ( virtualPath . equals ( i . deploymentRoot ) ) { ret . add ( i . componentDescription ) ; } } return ret ; } else { final List < Description > info = componentsByName . get ( componentName ) ; if ( info == null ) { return Collections . emptySet ( ) ; } final Set < ComponentDescription > all = new HashSet < ComponentDescription > ( ) ; final Set < ComponentDescription > thisDeployment = new HashSet < ComponentDescription > ( ) ; for ( Description i : info ) { all . add ( i . componentDescription ) ; if ( i . deploymentRoot . equals ( deploymentRoot ) ) { thisDeployment . add ( i . componentDescription ) ; } } // if there are multiple e
if ( all . size ( ) > 1 ) { return thisDeployment ; } return all ; }


signature:
public class EEApplicationDescription { /** * Get all views in the application that have the given name and view type
 * @ param componentName The name of the component
 * @ param viewName The view type
 * @ param deploymentRoot The deployment root of the component doing the lookup
 * @ return A set of all views for the given component name and type */
public Set < ViewDescription > getComponents ( final String componentName , final String viewName , final VirtualFile deploymentRoot ) { } }

implementation:
final List < ViewInformation > info = componentsByViewName . get ( viewName ) ; if ( info == null ) { return Collections . < ViewDescription > emptySet ( ) ; } if ( componentName . contains ( "#" ) ) { final String [ ] parts = componentName . split ( "#" ) ; String path = parts [ 0 ] ; if ( ! path . startsWith ( "../" ) ) { path = "../" + path ; } final VirtualFile virtualPath = deploymentRoot . getChild ( path ) ; final String name = parts [ 1 ] ; final Set < ViewDescription > ret = new HashSet < ViewDescription > ( ) ; for ( ViewInformation i : info ) { if ( i . beanName . equals ( name ) ) { // now we need to check the path
if ( virtualPath . equals ( i . deploymentRoot ) ) { ret . add ( i . viewDescription ) ; } } } return ret ; } else { final Set < ViewDescription > all = new HashSet < ViewDescription > ( ) ; final Set < ViewDescription > thisDeployment = new HashSet < ViewDescription > ( ) ; for ( ViewInformation i : info ) { if ( i . beanName . equals ( componentName ) ) { all . add ( i . viewDescription ) ; if ( i . deploymentRoot . equals ( deploymentRoot ) ) { thisDeployment . add ( i . viewDescription ) ; } } } if ( all . size ( ) > 1 ) { return thisDeployment ; } return all ; }


signature:
public class EEApplicationDescription { /** * Resolves a message destination name into a JNDI name */
public Set < String > resolveMessageDestination ( final String messageDestName , final VirtualFile deploymentRoot ) { } }

implementation:
if ( messageDestName . contains ( "#" ) ) { final String [ ] parts = messageDestName . split ( "#" ) ; String path = parts [ 0 ] ; if ( ! path . startsWith ( "../" ) ) { path = "../" + path ; } final VirtualFile virtualPath = deploymentRoot . getChild ( path ) ; final String name = parts [ 1 ] ; final Set < String > ret = new HashSet < String > ( ) ; final List < MessageDestinationMapping > data = messageDestinationJndiMapping . get ( name ) ; if ( data != null ) { for ( final MessageDestinationMapping i : data ) { // now we need to check the path
if ( virtualPath . equals ( i . deploymentRoot ) ) { ret . add ( i . jndiName ) ; } } } return ret ; } else { final Set < String > all = new HashSet < String > ( ) ; final Set < String > thisDeployment = new HashSet < String > ( ) ; final List < MessageDestinationMapping > data = messageDestinationJndiMapping . get ( messageDestName ) ; if ( data != null ) { for ( final MessageDestinationMapping i : data ) { all . add ( i . jndiName ) ; if ( i . deploymentRoot . equals ( deploymentRoot ) ) { thisDeployment . add ( i . jndiName ) ; } } } if ( all . size ( ) > 1 ) { return thisDeployment ; } return all ; }


signature:
public class MessagingTransformers { /** * Transformation for WildFly 8.1.0 . Final */
private static void buildTransformers2_1_0 ( ResourceTransformationDescriptionBuilder builder ) { } }

implementation: ResourceTransformationDescriptionBuilder hornetqServer = builder . addChildResource ( pathElement ( HORNETQ_SERVER ) ) ; ResourceTransformationDescriptionBuilder addressSetting = hornetqServer . addChildResource ( AddressSettingDefinition . PATH ) ; rejectDefinedAttributeWithDefaultValue ( addressSetting , MAX_REDELIVERY_DELAY , REDELIVERY_MULTIPLIER ) ; ResourceTransformationDescriptionBuilder bridge = hornetqServer . addChildResource ( BridgeDefinition . PATH ) ; bridge . getAttributeBuilder ( ) . setValueConverter ( new DoubleToBigDecimalConverter ( ) , RETRY_INTERVAL_MULTIPLIER ) ; ResourceTransformationDescriptionBuilder clusterConnection = hornetqServer . addChildResource ( ClusterConnectionDefinition . PATH ) ; clusterConnection . getAttributeBuilder ( ) . setValueConverter ( new DoubleToBigDecimalConverter ( ) , RETRY_INTERVAL_MULTIPLIER ) ; ResourceTransformationDescriptionBuilder connectionFactory = hornetqServer . addChildResource ( ConnectionFactoryDefinition . PATH ) ; connectionFactory . getAttributeBuilder ( ) . setValueConverter ( new DoubleToBigDecimalConverter ( ) , RETRY_INTERVAL_MULTIPLIER ) ; ResourceTransformationDescriptionBuilder pooledConnectionFactory = hornetqServer . addChildResource ( PooledConnectionFactoryDefinition . PATH ) ; pooledConnectionFactory . getAttributeBuilder ( ) . setValueConverter ( new DoubleToBigDecimalConverter ( ) , RETRY_INTERVAL_MULTIPLIER ) ;


signature:
public class MessagingTransformers { /** * Transformers for EAP 6.4 / AS7 7.5.0 */
private static void buildTransformers1_4_0 ( ResourceTransformationDescriptionBuilder builder ) { } }

implementation: ResourceTransformationDescriptionBuilder hornetqServer = builder . addChildResource ( pathElement ( HORNETQ_SERVER ) ) ; renameAttribute ( hornetqServer , CommonAttributes . STATISTICS_ENABLED , CommonAttributes . MESSAGE_COUNTER_ENABLED ) ; ResourceTransformationDescriptionBuilder bridge = hornetqServer . addChildResource ( BridgeDefinition . PATH ) ; rejectDefinedAttributeWithDefaultValue ( bridge , BridgeDefinition . RECONNECT_ATTEMPTS_ON_SAME_NODE , BridgeDefinition . INITIAL_CONNECT_ATTEMPTS ) ; ResourceTransformationDescriptionBuilder clusterConnection = hornetqServer . addChildResource ( ClusterConnectionDefinition . PATH ) ; rejectDefinedAttributeWithDefaultValue ( clusterConnection , ClusterConnectionDefinition . INITIAL_CONNECT_ATTEMPTS ) ; ResourceTransformationDescriptionBuilder addressSetting = hornetqServer . addChildResource ( AddressSettingDefinition . PATH ) ; rejectDefinedAttributeWithDefaultValue ( addressSetting , AddressSettingDefinition . EXPIRY_DELAY ) ;


signature:
public class MessagingTransformers { /** * Transformation for EAP 6.2.0 / AS7 7.3.0 */
private static void buildTransformers1_3_0 ( ResourceTransformationDescriptionBuilder builder ) { } }

implementation: ResourceTransformationDescriptionBuilder hornetqServer = builder . addChildResource ( pathElement ( HORNETQ_SERVER ) ) ; rejectDefinedAttributeWithDefaultValue ( hornetqServer , OVERRIDE_IN_VM_SECURITY ) ; hornetqServer . rejectChildResource ( HTTPAcceptorDefinition . PATH ) ; hornetqServer . rejectChildResource ( pathElement ( CommonAttributes . HTTP_CONNECTOR ) ) ; ResourceTransformationDescriptionBuilder addressSetting = hornetqServer . addChildResource ( AddressSettingDefinition . PATH ) ; rejectDefinedAttributeWithDefaultValue ( addressSetting , SLOW_CONSUMER_CHECK_PERIOD , SLOW_CONSUMER_POLICY , SLOW_CONSUMER_THRESHOLD ) ;


signature:
public class MessagingTransformers { /** * Reject the attributes if they are defined or discard them if they are undefined or set to their default value . */
private static void rejectDefinedAttributeWithDefaultValue ( ResourceTransformationDescriptionBuilder builder , AttributeDefinition ... attrs ) { } }

implementation: for ( AttributeDefinition attr : attrs ) { builder . getAttributeBuilder ( ) . setDiscard ( new DiscardAttributeValueChecker ( attr . getDefaultValue ( ) ) , attr ) . addRejectCheck ( DEFINED , attr ) ; }


signature:
public class MessagingTransformers { /** * Rename an attribute */
private static void renameAttribute ( ResourceTransformationDescriptionBuilder builder , AttributeDefinition attribute , AttributeDefinition alias ) { } }

implementation: builder . getAttributeBuilder ( ) . addRename ( attribute , alias . getName ( ) ) ;


signature:
public class ConnectionSecurityContext { /** * Obtain a { @ link Collection } containing the { @ link Principal } instances for the user associated with the connection .
 * Note : This method should be called from within a { @ link PrivilegedAction } .
 * @ return The Collection of Principals for the user authenticated with the connection . An empty Collection will be returned
 * of no user is associated with the connection , { @ code null } will be returned if no connection is associated with
 * the { @ link Thread } */
public static Collection < Principal > getConnectionPrincipals ( ) { } }

implementation: RemoteConnection con = RemotingContext . getRemoteConnection ( ) ; if ( con != null ) { Collection < Principal > principals = new HashSet < > ( ) ; SecurityIdentity localIdentity = con . getSecurityIdentity ( ) ; if ( localIdentity != null ) { final Principal principal = localIdentity . getPrincipal ( ) ; final String realm = principal instanceof RealmPrincipal ? ( ( RealmPrincipal ) principal ) . getRealm ( ) : null ; principals . add ( new RealmUser ( realm , principal . getName ( ) ) ) ; for ( String role : localIdentity . getRoles ( ) ) { principals . add ( new RealmGroup ( role ) ) ; principals . add ( new RealmRole ( role ) ) ; } return principals ; } else { return Collections . emptySet ( ) ; } } return null ;


signature:
public class ConnectionSecurityContext { /** * Push a new { @ link Principal } and Credential pair .
 * This method is to be called before an EJB invocation is passed through it ' s security interceptor , at that point the
 * Principal and Credential pair can be verified .
 * Note : This method should be called from within a { @ link PrivilegedAction } .
 * @ param principal - The alternative { @ link Principal } to use in verification before the next EJB is called .
 * @ param credential - The credential to verify with the { @ linl Principal }
 * @ return A { @ link ContextStateCache } that can later be used to pop the identity pushed here and restore internal state to it ' s previous values .
 * @ throws Exception If there is a problem associating the new { @ link Principal } and Credential pair . */
public static ContextStateCache pushIdentity ( final Principal principal , final Object credential ) throws Exception { } }

implementation: SecurityContext current = SecurityContextAssociation . getSecurityContext ( ) ; SecurityContext nextContext = SecurityContextFactory . createSecurityContext ( principal , credential , new Subject ( ) , "USER_DELEGATION" ) ; SecurityContextAssociation . setSecurityContext ( nextContext ) ; RemoteConnection con = RemotingContext . getRemoteConnection ( ) ; RemotingContext . clear ( ) ; return new ContextStateCache ( con , current ) ;


signature:
public class ConnectionSecurityContext { /** * Pop the identity previously associated and restore internal state to it ' s previous value .
 * @ param stateCache - The cache containing the state as it was when pushIdentity was called . */
public static void popIdentity ( final ContextStateCache stateCache ) { } }

implementation: RemotingContext . setConnection ( stateCache . getConnection ( ) ) ; SecurityContextAssociation . setSecurityContext ( stateCache . getSecurityContext ( ) ) ;


signature:
public class SecurityDomainJndiInjectable { /** * { @ inheritDoc }
 * This method returns a Context proxy that is only able to handle a lookup operation for an atomic name of a security
 * domain . */
public ManagedReference getReference ( ) { } }

implementation: final ClassLoader loader ; try { loader = SecurityActions . getModuleClassLoader ( ) ; } catch ( ModuleLoadException e ) { throw SecurityLogger . ROOT_LOGGER . unableToGetModuleClassLoader ( e ) ; } Class < ? > [ ] interfaces = { Context . class } ; return new ValueManagedReference ( new ImmediateValue < Object > ( Proxy . newProxyInstance ( loader , interfaces , this ) ) ) ;


signature:
public class SecurityDomainJndiInjectable { /** * This is the InvocationHandler callback for the Context interface that was created by our getObjectInstance ( ) method . We
 * handle the java : jboss / jaas / domain level operations here . */
public Object invoke ( Object proxy , Method method , Object [ ] args ) throws Throwable { } }

implementation:
Context ctx = new InitialContext ( ) ; NameParser parser = ctx . getNameParser ( "" ) ; String securityDomain = null ; Name name = null ; final JNDIBasedSecurityManagement securityManagement = JNDIBasedSecurityManagement . class . cast ( securityManagementValue . getValue ( ) ) ; final ConcurrentHashMap < String , SecurityDomainContext > securityManagerMap = securityManagement . getSecurityManagerMap ( ) ; String methodName = method . getName ( ) ; if ( methodName . equals ( "toString" ) ) return SecurityConstants . JAAS_CONTEXT_ROOT + " Context proxy" ; if ( methodName . equals ( "list" ) ) return new DomainEnumeration ( securityManagerMap . keys ( ) , securityManagerMap ) ; if ( methodName . equals ( "bind" ) || methodName . equals ( "rebind" ) ) { if ( args [ 0 ] instanceof String ) name = parser . parse ( ( String ) args [ 0 ] ) ; else name = ( Name ) args [ 0 ] ; securityDomain = name . get ( 0 ) ; SecurityDomainContext val = ( SecurityDomainContext ) args [ 1 ] ; securityManagerMap . put ( securityDomain , val ) ; return proxy ; } if ( ! methodName . equals ( "lookup" ) ) throw SecurityLogger . ROOT_LOGGER . operationNotSupported ( method ) ; if ( args [ 0 ] instanceof String ) name = parser . parse ( ( String ) args [ 0 ] ) ; else name = ( Name ) args [ 0 ] ; securityDomain = name . get ( 0 ) ; SecurityDomainContext securityDomainCtx = lookupSecurityDomain ( securityManagement , securityManagerMap , securityDomain ) ; Object binding = securityDomainCtx . getAuthenticationManager ( ) ; // Look for requests against the security domain context
if ( name . size ( ) == 2 ) { String request = name . get ( 1 ) ; binding = lookup ( securityDomainCtx , request ) ; } return binding ;


signature:
public class SecurityDomainJndiInjectable { /** * Creates a { @ code SecurityDomainContext } if one cannot be found in JNDI for a given security domain
 * @ param securityManagement security management
 * @ param securityManagerMap security manager map
 * @ param securityDomain the name of the security domain
 * @ return an instance of { @ code SecurityDomainContext }
 * @ throws Exception if an error occurs */
private SecurityDomainContext lookupSecurityDomain ( final JNDIBasedSecurityManagement securityManagement , final ConcurrentHashMap < String , SecurityDomainContext > securityManagerMap , final String securityDomain ) throws Exception { } }

implementation: SecurityDomainContext sdc = securityManagerMap . get ( securityDomain ) ; if ( sdc == null ) { sdc = securityManagement . createSecurityDomainContext ( securityDomain , new DefaultAuthenticationCacheFactory ( ) ) ; securityManagerMap . put ( securityDomain , sdc ) ; } return sdc ;


signature:
public class JSFModuleIdFactory { /** * just provide the default implementations */
private void loadIdsManually ( ) { } }

implementation: implIds . put ( "main" , ModuleIdentifier . create ( IMPL_MODULE ) ) ; apiIds . put ( "main" , ModuleIdentifier . create ( API_MODULE ) ) ; injectionIds . put ( "main" , ModuleIdentifier . create ( INJECTION_MODULE ) ) ; allVersions . add ( "main" ) ; activeVersions . add ( "main" ) ;


signature:
public class JSFModuleIdFactory { /** * make sure that each version has api , impl , and injection */
private void checkVersionIntegrity ( ) { } }

implementation: activeVersions . addAll ( allVersions ) ; for ( String version : allVersions ) { if ( ! apiIds . containsKey ( version ) ) { JSFLogger . ROOT_LOGGER . missingJSFModule ( version , API_MODULE ) ; activeVersions . remove ( version ) ; } if ( ! implIds . containsKey ( version ) ) { JSFLogger . ROOT_LOGGER . missingJSFModule ( version , IMPL_MODULE ) ; activeVersions . remove ( version ) ; } if ( ! injectionIds . containsKey ( version ) ) { JSFLogger . ROOT_LOGGER . missingJSFModule ( version , INJECTION_MODULE ) ; activeVersions . remove ( version ) ; } }


signature:
public class JSFModuleIdFactory { /** * If needed , convert old JSFVersionMarker values to slot values .
 * @ param jsfVersion The version value from JSFVersionMarker , or null for default slot .
 * @ return The equivalent slot value . */
String computeSlot ( String jsfVersion ) { } }

implementation: if ( jsfVersion == null ) return defaultSlot ; if ( JsfVersionMarker . JSF_2_0 . equals ( jsfVersion ) ) return defaultSlot ; return jsfVersion ;


signature:
public class JSFExtension { /** * { @ inheritDoc } */
@ Override public void initialize ( final ExtensionContext context ) { } }

implementation: JSFLogger . ROOT_LOGGER . debug ( "Activating JSF(Mojarra) Extension" ) ; final SubsystemRegistration subsystem = context . registerSubsystem ( SUBSYSTEM_NAME , CURRENT_MODEL_VERSION ) ; subsystem . registerSubsystemModel ( JSFResourceDefinition . INSTANCE ) ; subsystem . registerXMLElementWriter ( JSFSubsystemParser_1_1 . INSTANCE ) ;


signature:
public class JSFExtension { /** * { @ inheritDoc } */
@ Override public void initializeParsers ( final ExtensionParsingContext context ) { } }

implementation: context . setSubsystemXmlMapping ( SUBSYSTEM_NAME , JSFExtension . NAMESPACE_1_0 , ( ) -> JSFSubsystemParser_1_0 . INSTANCE ) ; context . setSubsystemXmlMapping ( SUBSYSTEM_NAME , JSFExtension . NAMESPACE_1_1 , ( ) -> JSFSubsystemParser_1_1 . INSTANCE ) ;


signature:
public class SecurityManagementService { /** * { @ inheritDoc } */
@ Override public void start ( StartContext context ) throws StartException { } }

implementation:
SecurityLogger . ROOT_LOGGER . debugf ( "Starting SecurityManagementService" ) ; // set properties of JNDIBasedSecurityManagement
JNDIBasedSecurityManagement securityManagement = new JNDIBasedSecurityManagement ( serviceModuleLoaderValue . getValue ( ) ) ; securityManagement . setAuthenticationManagerClassName ( authenticationManagerClassName ) ; securityManagement . setDeepCopySubjectMode ( deepCopySubjectMode ) ; securityManagement . setCallbackHandlerClassName ( callbackHandlerClassName ) ; securityManagement . setAuthorizationManagerClassName ( authorizationManagerClassName ) ; securityManagement . setAuditManagerClassName ( auditManagerClassName ) ; securityManagement . setIdentityTrustManagerClassName ( identityTrustManagerClassName ) ; securityManagement . setMappingManagerClassName ( mappingManagerClassName ) ; this . securityManagement = securityManagement ; previousSecurityManagement = SecurityFactory . getSecurityManagement ( ) ; SecurityFactory . setSecurityManagement ( securityManagement ) ;


signature:
public class BasicComponentInstance { /** * { @ inheritDoc } */
public Object getInstance ( ) { } }

implementation:
ManagedReference managedReference = ( ManagedReference ) getInstanceData ( INSTANCE_KEY ) ; if ( managedReference == null ) { // can happen if around construct chain returns null
return null ; } return managedReference . getInstance ( ) ;


signature:
public class BasicComponentInstance { /** * { @ inheritDoc } */
public Interceptor getInterceptor ( final Method method ) throws IllegalStateException { } }

implementation: Interceptor interceptor = methodMap . get ( method ) ; if ( interceptor == null ) { throw EeLogger . ROOT_LOGGER . methodNotFound ( method ) ; } return interceptor ;


signature:
public class BasicComponentInstance { /** * { @ inheritDoc } */
public final void destroy ( ) { } }

implementation: if ( doneUpdater . compareAndSet ( this , 0 , 1 ) ) try { preDestroy ( ) ; final Object instance = getInstance ( ) ; if ( instance != null ) { final InterceptorContext interceptorContext = prepareInterceptorContext ( ) ; interceptorContext . setTarget ( instance ) ; interceptorContext . putPrivateData ( InvocationType . class , InvocationType . PRE_DESTROY ) ; preDestroy . processInvocation ( interceptorContext ) ; } } catch ( Exception e ) { ROOT_LOGGER . componentDestroyFailure ( e , this ) ; } finally { component . finishDestroy ( ) ; }


signature:
public class ExternalPooledConnectionFactoryService { /** * Configure password from a credential - reference ( as an alternative to the password attribute )
 * and add it to the RA properties . */
private void configureCredential ( List < ConfigProperty > properties ) { } }

implementation:
// if a credential - reference has been defined , get the password property from it
if ( credentialSourceSupplier != null ) { try { CredentialSource credentialSource = credentialSourceSupplier . get ( ) ; if ( credentialSource != null ) { char [ ] password = credentialSource . getCredential ( PasswordCredential . class ) . getPassword ( ClearPassword . class ) . getPassword ( ) ; if ( password != null ) { // add the password property
properties . add ( simpleProperty15 ( "password" , String . class . getName ( ) , new String ( password ) ) ) ; } } } catch ( Exception e ) { throw new RuntimeException ( e ) ; } }


signature:
public class ServletContainerInitializerDeploymentProcessor { /** * Process SCIs . */
public void deploy ( final DeploymentPhaseContext phaseContext ) throws DeploymentUnitProcessingException { } }

implementation:
final DeploymentUnit deploymentUnit = phaseContext . getDeploymentUnit ( ) ; final ModuleSpecification moduleSpecification = deploymentUnit . getAttachment ( Attachments . MODULE_SPECIFICATION ) ; final ServiceModuleLoader loader = deploymentUnit . getAttachment ( Attachments . SERVICE_MODULE_LOADER ) ; if ( ! DeploymentTypeMarker . isType ( DeploymentType . WAR , deploymentUnit ) ) { return ; // Skip non web deployments
} WarMetaData warMetaData = deploymentUnit . getAttachment ( WarMetaData . ATTACHMENT_KEY ) ; assert warMetaData != null ; final Module module = deploymentUnit . getAttachment ( Attachments . MODULE ) ; if ( module == null ) { throw UndertowLogger . ROOT_LOGGER . failedToResolveModule ( deploymentUnit ) ; } final ClassLoader classLoader = module . getClassLoader ( ) ; ScisMetaData scisMetaData = deploymentUnit . getAttachment ( ScisMetaData . ATTACHMENT_KEY ) ; if ( scisMetaData == null ) { scisMetaData = new ScisMetaData ( ) ; deploymentUnit . putAttachment ( ScisMetaData . ATTACHMENT_KEY , scisMetaData ) ; } Set < ServletContainerInitializer > scis = scisMetaData . getScis ( ) ; Set < Class < ? extends ServletContainerInitializer > > sciClasses = new HashSet < > ( ) ; if ( scis == null ) { scis = new LinkedHashSet < > ( ) ; scisMetaData . setScis ( scis ) ; } Map < ServletContainerInitializer , Set < Class < ? > > > handlesTypes = scisMetaData . getHandlesTypes ( ) ; if ( handlesTypes == null ) { handlesTypes = new HashMap < ServletContainerInitializer , Set < Class < ? > > > ( ) ; scisMetaData . setHandlesTypes ( handlesTypes ) ; } // Find the SCIs from shared modules
for ( ModuleDependency dependency : moduleSpecification . getAllDependencies ( ) ) { // Should not include SCI if services is not included
if ( ! dependency . isImportServices ( ) ) { continue ; } try { Module depModule = loader . loadModule ( dependency . getIdentifier ( ) ) ; ServiceLoader < ServletContainerInitializer > serviceLoader = depModule . loadService ( ServletContainerInitializer . class ) ; for ( ServletContainerInitializer service : serviceLoader ) { if ( sciClasses . add ( service . getClass ( ) ) ) { scis . add ( service ) ; } } } catch ( ModuleLoadException e ) { if ( ! dependency . isOptional ( ) ) { throw UndertowLogger . ROOT_LOGGER . errorLoadingSCIFromModule ( dependency . getIdentifier ( ) . toString ( ) , e ) ; } } } // Find local ServletContainerInitializer services
List < String > order = warMetaData . getOrder ( ) ; Map < String , VirtualFile > localScis = warMetaData . getScis ( ) ; if ( order != null && localScis != null ) { for ( String jar : order ) { VirtualFile sci = localScis . get ( jar ) ; if ( sci != null ) { scis . addAll ( loadSci ( classLoader , sci , jar , true , sciClasses ) ) ; } } } // SCI ' s deployed in the war itself
if ( localScis != null ) { VirtualFile warDeployedScis = localScis . get ( "classes" ) ; if ( warDeployedScis != null ) { scis . addAll ( loadSci ( classLoader , warDeployedScis , deploymentUnit . getName ( ) , true , sciClasses ) ) ; } } // Process HandlesTypes for ServletContainerInitializer
Map < Class < ? > , Set < ServletContainerInitializer > > typesMap = new HashMap < Class < ? > , Set < ServletContainerInitializer > > ( ) ; for ( ServletContainerInitializer service : scis ) { if ( service . getClass ( ) . isAnnotationPresent ( HandlesTypes . class ) ) { HandlesTypes handlesTypesAnnotation = service . getClass ( ) . getAnnotation ( HandlesTypes . class ) ; Class < ? > [ ] typesArray = handlesTypesAnnotation . value ( ) ; if ( typesArray != null ) { for ( Class < ? > type : typesArray ) { Set < ServletContainerInitializer > servicesSet = typesMap . get ( type ) ; if ( servicesSet == null ) { servicesSet = new HashSet < ServletContainerInitializer > ( ) ; typesMap . put ( type , servicesSet ) ; } servicesSet . add ( service ) ; handlesTypes . put ( service , new HashSet < Class < ? > > ( ) ) ; } } } } Class < ? > [ ] typesArray = typesMap . keySet ( ) . toArray ( new Class < ? > [ 0 ] ) ; final CompositeIndex index = deploymentUnit . getAttachment ( Attachments . COMPOSITE_ANNOTATION_INDEX ) ; if ( index == null ) { throw UndertowLogger . ROOT_LOGGER . unableToResolveAnnotationIndex ( deploymentUnit ) ; } final CompositeIndex parent ; if ( deploymentUnit . getParent ( ) != null ) { parent = deploymentUnit . getParent ( ) . getAttachment ( Attachments . COMPOSITE_ANNOTATION_INDEX ) ; } else { parent = null ; } // WFLY - 4205 , look in the parent as well as the war
CompositeIndex parentIndex = deploymentUnit . getParent ( ) == null ? null : deploymentUnit . getParent ( ) . getAttachment ( Attachments . COMPOSITE_ANNOTATION_INDEX ) ; // Find classes which extend , implement , or are annotated by HandlesTypes
for ( Class < ? > type : typesArray ) { DotName className = DotName . createSimple ( type . getName ( ) ) ; Set < ClassInfo > classInfos = new HashSet < > ( ) ; classInfos . addAll ( processHandlesType ( className , type , index , parent ) ) ; if ( parentIndex != null ) { classInfos . addAll ( processHandlesType ( className , type , parentIndex , parent ) ) ; } Set < Class < ? > > classes = loadClassInfoSet ( classInfos , classLoader ) ; Set < ServletContainerInitializer > sciSet = typesMap . get ( type ) ; for ( ServletContainerInitializer sci : sciSet ) { handlesTypes . get ( sci ) . addAll ( classes ) ; } }


signature:
public class TimerServiceAdd { /** * Populate the < code > timerService < / code > from the < code > operation < / code >
 * @ param operation the operation
 * @ param timerServiceModel strict - max - pool ModelNode
 * @ throws org . jboss . as . controller . OperationFailedException */
protected void populateModel ( ModelNode operation , ModelNode timerServiceModel ) throws OperationFailedException { } }

implementation: for ( AttributeDefinition attr : TimerServiceResourceDefinition . ATTRIBUTES . values ( ) ) { attr . validateAndSet ( operation , timerServiceModel ) ; }


signature:
public class InterfaceRepository { /** * Returns the TypeCode suitable for an IDL constant .
 * @ param cls The Java class denoting the type of the constant . */
private TypeCode getConstantTypeCode ( Class cls ) throws IRConstructionException { } }

implementation: if ( cls == null ) throw IIOPLogger . ROOT_LOGGER . invalidNullClass ( ) ; TypeCode ret = constantTypeCodeMap . get ( cls ) ; if ( ret == null ) throw IIOPLogger . ROOT_LOGGER . badClassForConstant ( cls . getName ( ) ) ; return ret ;


signature:
public class InterfaceRepository { /** * Returns the TypeCode IDL TypeCodes for parameter , result , attribute
 * and value member types .
 * This may provoke a mapping of the class argument .
 * Exception classes map to both values and exceptions . For these , this
 * method returns the typecode for the value , and you can use the
 * < code > getExceptionTypeCode < / code > TODO method to get the typecode for the
 * mapping to exception .
 * @ param cls The Java class denoting the java type . */
private TypeCode getTypeCode ( Class cls ) throws IRConstructionException , RMIIIOPViolationException { } }

implementation:
if ( cls == null ) throw IIOPLogger . ROOT_LOGGER . invalidNullClass ( ) ; TypeCode ret = ( TypeCode ) typeCodeMap . get ( cls ) ; if ( ret == null ) { if ( cls == java . lang . String . class ) ret = getJavaLangString ( ) . type ( ) ; else if ( cls == java . lang . Object . class ) ret = getJavaLang_Object ( ) . type ( ) ; else if ( cls == java . lang . Class . class ) ret = getJavaxRmiCORBAClassDesc ( ) . type ( ) ; else if ( cls == java . io . Serializable . class ) ret = getJavaIoSerializable ( ) . type ( ) ; else if ( cls == java . io . Externalizable . class ) ret = getJavaIoExternalizable ( ) . type ( ) ; else { // Try adding a mapping of the the class to the IR
addClass ( cls ) ; // Lookup again , it should be there now .
ret = ( TypeCode ) typeCodeMap . get ( cls ) ; if ( ret == null ) throw IIOPLogger . ROOT_LOGGER . unknownTypeCodeForClass ( cls . getName ( ) ) ; else return ret ; } typeCodeMap . put ( cls , ret ) ; } return ret ;


signature:
public class InterfaceRepository { /** * Add a new IDL TypeCode for a mapped class .
 * @ param cls The Java class denoting the java type .
 * @ param typeCode The IDL type code of the mapped java class . */
private void addTypeCode ( Class cls , TypeCode typeCode ) throws IRConstructionException { } }

implementation: if ( cls == null ) throw IIOPLogger . ROOT_LOGGER . invalidNullClass ( ) ; TypeCode tc = ( TypeCode ) typeCodeMap . get ( cls ) ; if ( tc != null ) throw IIOPLogger . ROOT_LOGGER . duplicateTypeCodeForClass ( cls . getName ( ) ) ; typeCodeMap . put ( cls , typeCode ) ;


signature:
public class InterfaceRepository { /** * Get a reference to the special case mapping for java . lang . Object .
 * This is according to " Java ( TM ) Language to IDL Mapping Specification " ,
 * section 1.3.10.2 */
private AliasDefImpl getJavaLang_Object ( ) throws IRConstructionException { } }

implementation:
if ( javaLang_Object == null ) { final String id = "IDL:java/lang/_Object:1.0" ; final String name = "_Object" ; final String version = "1.0" ; // Get module to add typedef to .
ModuleDefImpl m = ensurePackageExists ( "java.lang" ) ; TypeCode typeCode = orb . create_alias_tc ( id , name , orb . get_primitive_tc ( TCKind . tk_any ) ) ; // TypeCode typeCode = new TypeCodeImpl ( TCKind . _ tk _ alias , id , name ,
// new TypeCodeImpl ( TCKind . tk _ any ) ) ;
javaLang_Object = new AliasDefImpl ( id , name , version , m , typeCode , impl ) ; m . add ( name , javaLang_Object ) ; } return javaLang_Object ;


signature:
public class InterfaceRepository { /** * Get a reference to the special case mapping for java . lang . String .
 * This is according to " Java ( TM ) Language to IDL Mapping Specification " ,
 * section 1.3.5.10 */
private ValueDefImpl getJavaLangString ( ) throws IRConstructionException { } }

implementation: if ( javaLangString == null ) { ModuleDefImpl m = ensurePackageExists ( "org.omg.CORBA" ) ; ValueDefImpl val = new ValueDefImpl ( "IDL:omg.org/CORBA/WStringValue:1.0" , "WStringValue" , "1.0" , m , false , false , new String [ 0 ] , new String [ 0 ] , orb . get_primitive_tc ( TCKind . tk_null ) , impl ) ; ValueMemberDefImpl vmdi = new ValueMemberDefImpl ( "IDL:omg.org/CORBA/WStringValue.data:1.0" , "data" , "1.0" , orb . create_wstring_tc ( 0 ) , true , val , impl ) ; val . add ( "data" , vmdi ) ; m . add ( "WStringValue" , val ) ; javaLangString = val ; } return javaLangString ;


signature:
public class InterfaceRepository { /** * Get a reference to the special case mapping for java . lang . Class .
 * This is according to " Java ( TM ) Language to IDL Mapping Specification " ,
 * section 1.3.5.11. */
private ValueDefImpl getJavaxRmiCORBAClassDesc ( ) throws IRConstructionException , RMIIIOPViolationException { } }

implementation:
if ( javaxRmiCORBAClassDesc == null ) { // Just map the right value class
ValueAnalysis va = ValueAnalysis . getValueAnalysis ( javax . rmi . CORBA . ClassDesc . class ) ; ValueDefImpl val = addValue ( va ) ; // Warn if it does not conform to the specification .
if ( ! "RMI:javax.rmi.CORBA.ClassDesc:B7C4E3FC9EBDC311:CFBF02CF5294176B" . equals ( val . id ( ) ) ) IIOPLogger . ROOT_LOGGER . warnClassDescDoesNotConformToSpec ( ) ; javaxRmiCORBAClassDesc = val ; } return javaxRmiCORBAClassDesc ;


signature:
public class InterfaceRepository { /** * Ensure that a package exists in the IR .
 * This will create modules in the IR as needed .
 * @ param c The container that the remainder of modules should be defined in .
 * @ param previous The IDL module name , from root to < code > c < / code > .
 * @ param remainder The java package name , relative to < code > c < / code > .
 * @ return A reference to the IR module that represents the package . */
private ModuleDefImpl ensurePackageExists ( LocalContainer c , String previous , String remainder ) throws IRConstructionException { } }

implementation:
if ( "" . equals ( remainder ) ) return ( ModuleDefImpl ) c ; // done
int idx = remainder . indexOf ( '.' ) ; String base ; if ( idx == - 1 ) base = remainder ; else base = remainder . substring ( 0 , idx ) ; base = Util . javaToIDLName ( base ) ; if ( previous . equals ( "" ) ) previous = base ; else previous = previous + "/" + base ; if ( idx == - 1 ) remainder = "" ; else remainder = remainder . substring ( idx + 1 ) ; LocalContainer next = null ; LocalContained contained = ( LocalContained ) c . _lookup ( base ) ; if ( contained instanceof LocalContainer ) next = ( LocalContainer ) contained ; else if ( contained != null ) throw IIOPLogger . ROOT_LOGGER . collisionWhileCreatingPackage ( ) ; if ( next == null ) { String id = "IDL:" + previous + ":1.0" ; // Create module
ModuleDefImpl m = new ModuleDefImpl ( id , base , "1.0" , c , impl ) ; c . add ( base , m ) ; if ( idx == - 1 ) return m ; // done
next = ( LocalContainer ) c . _lookup ( base ) ; // Better be there now . . .
} else // Check that next _ is _ a module
if ( next . def_kind ( ) != DefinitionKind . dk_Module ) throw IIOPLogger . ROOT_LOGGER . collisionWhileCreatingPackage ( ) ; return ensurePackageExists ( next , previous , remainder ) ;


signature:
public class InterfaceRepository { /** * Add a set of constants to a container ( interface or value class ) . */
private void addConstants ( LocalContainer container , ContainerAnalysis ca ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation: ConstantAnalysis [ ] consts = ca . getConstants ( ) ; for ( int i = 0 ; i < consts . length ; ++ i ) { ConstantDefImpl cDef ; String cid = ca . getMemberRepositoryId ( consts [ i ] . getJavaName ( ) ) ; String cName = consts [ i ] . getIDLName ( ) ; Class cls = consts [ i ] . getType ( ) ; TypeCode typeCode = getConstantTypeCode ( cls ) ; Any value = orb . create_any ( ) ; consts [ i ] . insertValue ( value ) ; cDef = new ConstantDefImpl ( cid , cName , "1.0" , typeCode , value , container , impl ) ; container . add ( cName , cDef ) ; }


signature:
public class InterfaceRepository { /** * Add a set of attributes to a container ( interface or value class ) . */
private void addAttributes ( LocalContainer container , ContainerAnalysis ca ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation: AttributeAnalysis [ ] attrs = ca . getAttributes ( ) ; for ( int i = 0 ; i < attrs . length ; ++ i ) { AttributeDefImpl aDef ; String aid = ca . getMemberRepositoryId ( attrs [ i ] . getJavaName ( ) ) ; String aName = attrs [ i ] . getIDLName ( ) ; Class cls = attrs [ i ] . getCls ( ) ; TypeCode typeCode = getTypeCode ( cls ) ; aDef = new AttributeDefImpl ( aid , aName , "1.0" , attrs [ i ] . getMode ( ) , typeCode , container , impl ) ; container . add ( aName , aDef ) ; }


signature:
public class InterfaceRepository { /** * Add a set of operations to a container ( interface or value class ) . */
private void addOperations ( LocalContainer container , ContainerAnalysis ca ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation:
OperationAnalysis [ ] ops = ca . getOperations ( ) ; for ( int i = 0 ; i < ops . length ; ++ i ) { OperationDefImpl oDef ; String oName = ops [ i ] . getIDLName ( ) ; String oid = ca . getMemberRepositoryId ( oName ) ; Class cls = ops [ i ] . getReturnType ( ) ; TypeCode typeCode = getTypeCode ( cls ) ; ParameterAnalysis [ ] ps = ops [ i ] . getParameters ( ) ; ParameterDescription [ ] params = new ParameterDescription [ ps . length ] ; for ( int j = 0 ; j < ps . length ; ++ j ) { params [ j ] = new ParameterDescription ( ps [ j ] . getIDLName ( ) , getTypeCode ( ps [ j ] . getCls ( ) ) , null , // filled in later
ParameterMode . PARAM_IN ) ; } ExceptionAnalysis [ ] exc = ops [ i ] . getMappedExceptions ( ) ; ExceptionDef [ ] exceptions = new ExceptionDef [ exc . length ] ; for ( int j = 0 ; j < exc . length ; ++ j ) { ExceptionDefImpl e = addException ( exc [ j ] ) ; exceptions [ j ] = ExceptionDefHelper . narrow ( e . getReference ( ) ) ; } oDef = new OperationDefImpl ( oid , oName , "1.0" , container , typeCode , params , exceptions , impl ) ; container . add ( oName , oDef ) ; }


signature:
public class InterfaceRepository { /** * Add a set of interfaces to the IR .
 * @ return An array of the IR IDs of the interfaces . */
private String [ ] addInterfaces ( ContainerAnalysis ca ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation: InterfaceAnalysis [ ] interfaces = ca . getInterfaces ( ) ; List base_interfaces = new ArrayList ( ) ; for ( int i = 0 ; i < interfaces . length ; ++ i ) { InterfaceDefImpl idi = addInterface ( interfaces [ i ] ) ; base_interfaces . add ( idi . id ( ) ) ; } String [ ] strArr = new String [ base_interfaces . size ( ) ] ; return ( String [ ] ) base_interfaces . toArray ( strArr ) ;


signature:
public class InterfaceRepository { /** * Add a set of abstract valuetypes to the IR .
 * @ return An array of the IR IDs of the abstract valuetypes . */
private String [ ] addAbstractBaseValuetypes ( ContainerAnalysis ca ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation: ValueAnalysis [ ] abstractValuetypes = ca . getAbstractBaseValuetypes ( ) ; List abstract_base_valuetypes = new ArrayList ( ) ; for ( int i = 0 ; i < abstractValuetypes . length ; ++ i ) { ValueDefImpl vdi = addValue ( abstractValuetypes [ i ] ) ; abstract_base_valuetypes . add ( vdi . id ( ) ) ; } String [ ] strArr = new String [ abstract_base_valuetypes . size ( ) ] ; return ( String [ ] ) abstract_base_valuetypes . toArray ( strArr ) ;


signature:
public class InterfaceRepository { /** * Map the class and add its IIOP mapping to the repository . */
private void addClass ( Class cls ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation:
if ( cls . isPrimitive ( ) ) return ; // No need to add primitives .
if ( cls . isArray ( ) ) { // Add array mapping
addArray ( cls ) ; } else if ( cls . isInterface ( ) ) { if ( ! RmiIdlUtil . isAbstractValueType ( cls ) ) { // Analyse the interface
InterfaceAnalysis ia = InterfaceAnalysis . getInterfaceAnalysis ( cls ) ; // Add analyzed interface ( which may be abstract )
addInterface ( ia ) ; } else { // Analyse the value
ValueAnalysis va = ValueAnalysis . getValueAnalysis ( cls ) ; // Add analyzed value
addValue ( va ) ; } } else if ( Exception . class . isAssignableFrom ( cls ) ) { // Exception type .
// Analyse the exception
ExceptionAnalysis ea = ExceptionAnalysis . getExceptionAnalysis ( cls ) ; // Add analyzed exception
addException ( ea ) ; } else { // Got to be a value type .
// Analyse the value
ValueAnalysis va = ValueAnalysis . getValueAnalysis ( cls ) ; // Add analyzed value
addValue ( va ) ; }


signature:
public class InterfaceRepository { /** * Add an array . */
private ValueBoxDefImpl addArray ( Class cls ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation:
if ( ! cls . isArray ( ) ) throw IIOPLogger . ROOT_LOGGER . classIsNotArray ( cls . getName ( ) ) ; ValueBoxDefImpl vbDef ; // Lookup : Has it already been added ?
vbDef = ( ValueBoxDefImpl ) arrayMap . get ( cls ) ; if ( vbDef != null ) return vbDef ; // Yes , just return it .
int dimensions = 0 ; Class compType = cls ; do { compType = compType . getComponentType ( ) ; ++ dimensions ; } while ( compType . isArray ( ) ) ; String typeName ; String moduleName ; TypeCode typeCode ; if ( compType . isPrimitive ( ) ) { if ( compType == Boolean . TYPE ) { typeName = "boolean" ; typeCode = orb . get_primitive_tc ( TCKind . tk_boolean ) ; } else if ( compType == Character . TYPE ) { typeName = "wchar" ; typeCode = orb . get_primitive_tc ( TCKind . tk_wchar ) ; } else if ( compType == Byte . TYPE ) { typeName = "octet" ; typeCode = orb . get_primitive_tc ( TCKind . tk_octet ) ; } else if ( compType == Short . TYPE ) { typeName = "short" ; typeCode = orb . get_primitive_tc ( TCKind . tk_short ) ; } else if ( compType == Integer . TYPE ) { typeName = "long" ; typeCode = orb . get_primitive_tc ( TCKind . tk_long ) ; } else if ( compType == Long . TYPE ) { typeName = "long_long" ; typeCode = orb . get_primitive_tc ( TCKind . tk_longlong ) ; } else if ( compType == Float . TYPE ) { typeName = "float" ; typeCode = orb . get_primitive_tc ( TCKind . tk_float ) ; } else if ( compType == Double . TYPE ) { typeName = "double" ; typeCode = orb . get_primitive_tc ( TCKind . tk_double ) ; } else { throw IIOPLogger . ROOT_LOGGER . unknownPrimitiveType ( compType . getName ( ) ) ; } moduleName = "org.omg.boxedRMI" ; } else { typeCode = getTypeCode ( compType ) ; // map the component type .
if ( compType == java . lang . String . class ) typeName = getJavaLangString ( ) . name ( ) ; else if ( compType == java . lang . Object . class ) typeName = getJavaLang_Object ( ) . name ( ) ; else if ( compType == java . lang . Class . class ) typeName = getJavaxRmiCORBAClassDesc ( ) . name ( ) ; else if ( compType == java . io . Serializable . class ) typeName = getJavaIoSerializable ( ) . name ( ) ; else if ( compType == java . io . Externalizable . class ) typeName = getJavaIoExternalizable ( ) . name ( ) ; else if ( compType . isInterface ( ) && ! RmiIdlUtil . isAbstractValueType ( compType ) ) typeName = ( ( InterfaceDefImpl ) interfaceMap . get ( compType ) ) . name ( ) ; else if ( Exception . class . isAssignableFrom ( compType ) ) // exception type
typeName = ( ( ExceptionDefImpl ) exceptionMap . get ( compType ) ) . name ( ) ; else // must be value type
typeName = ( ( ValueDefImpl ) valueMap . get ( compType ) ) . name ( ) ; moduleName = "org.omg.boxedRMI." + compType . getPackage ( ) . getName ( ) ; } // Get module to add array to .
ModuleDefImpl m = ensurePackageExists ( moduleName ) ; // Create an array of the types for the dimensions
Class [ ] types = new Class [ dimensions ] ; types [ dimensions - 1 ] = cls ; for ( int i = dimensions - 2 ; i >= 0 ; -- i ) types [ i ] = types [ i + 1 ] . getComponentType ( ) ; // Create boxed sequences for all dimensions .
for ( int i = 0 ; i < dimensions ; ++ i ) { Class type = types [ i ] ; typeCode = orb . create_sequence_tc ( 0 , typeCode ) ; vbDef = ( ValueBoxDefImpl ) arrayMap . get ( type ) ; if ( vbDef == null ) { String id = Util . getIRIdentifierOfClass ( type ) ; SequenceDefImpl sdi = new SequenceDefImpl ( typeCode , impl ) ; String name = "seq" + ( i + 1 ) + "_" + typeName ; // TypeCode boxTypeCode = new TypeCodeImpl ( TCKind . _ tk _ value _ box ,
// id , name , typeCode ) ;
TypeCode boxTypeCode = orb . create_value_box_tc ( id , name , typeCode ) ; vbDef = new ValueBoxDefImpl ( id , name , "1.0" , m , boxTypeCode , impl ) ; addTypeCode ( type , vbDef . type ( ) ) ; m . add ( name , vbDef ) ; impl . putSequenceImpl ( id , typeCode , sdi , vbDef ) ; arrayMap . put ( type , vbDef ) ; // Remember we mapped this .
typeCode = boxTypeCode ; } else typeCode = vbDef . type ( ) ; } // Return the box of highest dimension .
return vbDef ;


signature:
public class InterfaceRepository { /** * Add an interface . */
private InterfaceDefImpl addInterface ( InterfaceAnalysis ia ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation:
InterfaceDefImpl iDef ; Class cls = ia . getCls ( ) ; // Lookup : Has it already been added ?
iDef = ( InterfaceDefImpl ) interfaceMap . get ( cls ) ; if ( iDef != null ) return iDef ; // Yes , just return it .
// Get module to add interface to .
ModuleDefImpl m = ensurePackageExists ( cls . getPackage ( ) . getName ( ) ) ; // Add superinterfaces
String [ ] base_interfaces = addInterfaces ( ia ) ; // Create the interface
String base = cls . getName ( ) ; base = base . substring ( base . lastIndexOf ( '.' ) + 1 ) ; base = Util . javaToIDLName ( base ) ; iDef = new InterfaceDefImpl ( ia . getRepositoryId ( ) , base , "1.0" , m , base_interfaces , impl ) ; addTypeCode ( cls , iDef . type ( ) ) ; m . add ( base , iDef ) ; interfaceMap . put ( cls , iDef ) ; // Remember we mapped this .
// Fill in constants
addConstants ( iDef , ia ) ; // Add attributes
addAttributes ( iDef , ia ) ; // Fill in operations
addOperations ( iDef , ia ) ; return iDef ;


signature:
public class InterfaceRepository { /** * Add a value type . */
private ValueDefImpl addValue ( ValueAnalysis va ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation:
ValueDefImpl vDef ; Class cls = va . getCls ( ) ; // Lookup : Has it already been added ?
vDef = ( ValueDefImpl ) valueMap . get ( cls ) ; if ( vDef != null ) return vDef ; // Yes , just return it .
// Get module to add value to .
ModuleDefImpl m = ensurePackageExists ( cls . getPackage ( ) . getName ( ) ) ; // Add implemented interfaces
String [ ] supported_interfaces = addInterfaces ( va ) ; // Add abstract base valuetypes
String [ ] abstract_base_valuetypes = addAbstractBaseValuetypes ( va ) ; // Add superclass
ValueDefImpl superValue = null ; ValueAnalysis superAnalysis = va . getSuperAnalysis ( ) ; if ( superAnalysis != null ) superValue = addValue ( superAnalysis ) ; // Create the value
String base = cls . getName ( ) ; base = base . substring ( base . lastIndexOf ( '.' ) + 1 ) ; base = Util . javaToIDLName ( base ) ; TypeCode baseTypeCode ; if ( superValue == null ) baseTypeCode = orb . get_primitive_tc ( TCKind . tk_null ) ; else baseTypeCode = superValue . type ( ) ; vDef = new ValueDefImpl ( va . getRepositoryId ( ) , base , "1.0" , m , va . isAbstractValue ( ) , va . isCustom ( ) , supported_interfaces , abstract_base_valuetypes , baseTypeCode , impl ) ; addTypeCode ( cls , vDef . type ( ) ) ; m . add ( base , vDef ) ; valueMap . put ( cls , vDef ) ; // Remember we mapped this .
// Fill in constants .
addConstants ( vDef , va ) ; // Add value members
ValueMemberAnalysis [ ] vmas = va . getMembers ( ) ; for ( int i = 0 ; i < vmas . length ; ++ i ) { ValueMemberDefImpl vmDef ; String vmid = va . getMemberRepositoryId ( vmas [ i ] . getJavaName ( ) ) ; String vmName = vmas [ i ] . getIDLName ( ) ; Class vmCls = vmas [ i ] . getCls ( ) ; TypeCode typeCode = getTypeCode ( vmCls ) ; boolean vmPublic = vmas [ i ] . isPublic ( ) ; vmDef = new ValueMemberDefImpl ( vmid , vmName , "1.0" , typeCode , vmPublic , vDef , impl ) ; vDef . add ( vmName , vmDef ) ; } // Add attributes
addAttributes ( vDef , va ) ; // TODO : Fill in operations .
return vDef ;


signature:
public class InterfaceRepository { /** * Add an exception type . */
private ExceptionDefImpl addException ( ExceptionAnalysis ea ) throws RMIIIOPViolationException , IRConstructionException { } }

implementation:
ExceptionDefImpl eDef ; Class cls = ea . getCls ( ) ; // Lookup : Has it already been added ?
eDef = ( ExceptionDefImpl ) exceptionMap . get ( cls ) ; if ( eDef != null ) return eDef ; // Yes , just return it .
// 1.3.7.1 : map to value
ValueDefImpl vDef = addValue ( ea ) ; // 1.3.7.2 : map to exception
ModuleDefImpl m = ensurePackageExists ( cls . getPackage ( ) . getName ( ) ) ; String base = cls . getName ( ) ; base = base . substring ( base . lastIndexOf ( '.' ) + 1 ) ; if ( base . endsWith ( "Exception" ) ) base = base . substring ( 0 , base . length ( ) - 9 ) ; base = Util . javaToIDLName ( base + "Ex" ) ; StructMember [ ] members = new StructMember [ 1 ] ; members [ 0 ] = new StructMember ( "value" , vDef . type ( ) , null /* ignored */
) ; TypeCode typeCode = orb . create_exception_tc ( ea . getExceptionRepositoryId ( ) , base , members ) ; eDef = new ExceptionDefImpl ( ea . getExceptionRepositoryId ( ) , base , "1.0" , typeCode , vDef , m , impl ) ; m . add ( base , eDef ) ; exceptionMap . put ( cls , eDef ) ; // Remember we mapped this .
return eDef ;


signature:
public class JPAAnnotationProcessor { /** * Based on the the annotation type , its either entitymanager or entitymanagerfactory
 * @ param annotation
 * @ return */
private String getClassLevelInjectionType ( final AnnotationInstance annotation ) { } }

implementation: boolean isPC = annotation . name ( ) . local ( ) . equals ( "PersistenceContext" ) ; return isPC ? ENTITY_MANAGER_CLASS : ENTITY_MANAGERFACTORY_CLASS ;


signature:
public class WSIntegrationProcessorJAXWS_HANDLER { /** * TODO this could be moved to a separate DeploymentUnitProcessor operating on endpoints ( together with the rest of the config resolution mechanism ) */
private void registerConfigMapping ( String endpointClassName , EndpointConfig config , DeploymentUnit unit ) { } }

implementation: WSEndpointConfigMapping mapping = unit . getAttachment ( WSAttachmentKeys . WS_ENDPOINT_CONFIG_MAPPING_KEY ) ; if ( mapping == null ) { mapping = new WSEndpointConfigMapping ( ) ; unit . putAttachment ( WSAttachmentKeys . WS_ENDPOINT_CONFIG_MAPPING_KEY , mapping ) ; } mapping . registerEndpointConfig ( endpointClassName , config ) ;


signature:
public class WeldSubsystemAdd { /** * not necessary . */
private boolean checkJtsEnabled ( final OperationContext context ) { } }

implementation: try { final ModelNode jtsNode = context . readResourceFromRoot ( PathAddress . pathAddress ( "subsystem" , "transactions" ) , false ) . getModel ( ) . get ( "jts" ) ; return jtsNode . isDefined ( ) ? jtsNode . asBoolean ( ) : false ; } catch ( NoSuchResourceException ex ) { return false ; }


signature:
public class NamingStoreService { /** * Creates the naming store if not provided by the constructor .
 * @ param context The start context
 * @ throws StartException If any problems occur creating the context */
public void start ( final StartContext context ) throws StartException { } }

implementation: if ( store == null ) { final ServiceRegistry serviceRegistry = context . getController ( ) . getServiceContainer ( ) ; final ServiceName serviceNameBase = context . getController ( ) . getName ( ) ; final ServiceTarget serviceTarget = context . getChildTarget ( ) ; store = readOnly ? new ServiceBasedNamingStore ( serviceRegistry , serviceNameBase ) : new WritableServiceBasedNamingStore ( serviceRegistry , serviceNameBase , serviceTarget ) ; }


signature:
public class NamingStoreService { /** * Destroys the naming store .
 * @ param context The stop context */
public void stop ( StopContext context ) { } }

implementation: if ( store != null ) { try { store . close ( ) ; store = null ; } catch ( NamingException e ) { throw NamingLogger . ROOT_LOGGER . failedToDestroyRootContext ( e ) ; } }


signature:
public class AddressValidator { /** * { @ inheritDoc } */
@ Override public void validateParameter ( String parameterName , ModelNode value ) throws OperationFailedException { } }

implementation: super . validateParameter ( parameterName , value ) ; if ( value . isDefined ( ) && value . getType ( ) != ModelType . EXPRESSION ) { String address = value . asString ( ) ; if ( address . startsWith ( "[" ) && address . endsWith ( "]" ) ) { address = address . substring ( 1 , address . length ( ) - 1 ) ; } if ( ! AddressUtils . isValidAddress ( address ) ) { throw new OperationFailedException ( Messages . MESSAGES . invalidAddressProvided ( address ) ) ; } }


signature:
public class SecurityDependencyProcessor { /** * { @ inheritDoc } */
public void deploy ( DeploymentPhaseContext phaseContext ) throws DeploymentUnitProcessingException { } }

implementation:
final DeploymentUnit deploymentUnit = phaseContext . getDeploymentUnit ( ) ; final ModuleLoader moduleLoader = Module . getBootModuleLoader ( ) ; final ModuleSpecification moduleSpecification = deploymentUnit . getAttachment ( Attachments . MODULE_SPECIFICATION ) ; moduleSpecification . addSystemDependency ( new ModuleDependency ( moduleLoader , PICKETBOX_ID , false , false , false , false ) ) ; // add the remoting login module
final ModuleDependency remoting = new ModuleDependency ( moduleLoader , REMOTING_LOGIN_MODULE , false , false , false , false ) ; remoting . addImportFilter ( PathFilters . is ( RemotingLoginModule . class . getName ( ) . replace ( "." , "/" ) ) , true ) ; moduleSpecification . addSystemDependency ( remoting ) ; moduleSpecification . addSystemDependency ( new ModuleDependency ( moduleLoader , JACC_API , false , false , true , false ) ) ; moduleSpecification . addSystemDependency ( new ModuleDependency ( moduleLoader , AUTH_MESSAGE_API , false , false , true , false ) ) ;


signature:
public class EntityProviderService { /** * < p > Configure the STS Token Providers . < / p > */
private void configureTokenProviders ( ) { } }

implementation: STSType stsType = getFederationService ( ) . getValue ( ) . getStsType ( ) ; if ( stsType != null ) { int tokenTimeout = stsType . getTokenTimeout ( ) ; int clockSkew = stsType . getClockSkew ( ) ; STSType providerStsType = getPicketLinkType ( ) . getStsType ( ) ; providerStsType . setTokenTimeout ( tokenTimeout ) ; providerStsType . setClockSkew ( clockSkew ) ; List < TokenProviderType > tokenProviders = providerStsType . getTokenProviders ( ) . getTokenProvider ( ) ; for ( TokenProviderType tokenProviderType : tokenProviders ) { if ( tokenProviderType . getTokenType ( ) . equals ( JBossSAMLURIConstants . ASSERTION_NSURI . get ( ) ) ) { KeyValueType keyValueTypeTokenTimeout = new KeyValueType ( ) ; keyValueTypeTokenTimeout . setKey ( GeneralConstants . ASSERTIONS_VALIDITY ) ; keyValueTypeTokenTimeout . setValue ( String . valueOf ( tokenTimeout ) ) ; KeyValueType keyValueTypeClockSkew = new KeyValueType ( ) ; keyValueTypeClockSkew . setKey ( GeneralConstants . CLOCK_SKEW ) ; keyValueTypeClockSkew . setValue ( String . valueOf ( clockSkew ) ) ; tokenProviderType . add ( keyValueTypeTokenTimeout ) ; tokenProviderType . add ( keyValueTypeClockSkew ) ; } } }


signature:
public class EntityProviderService { /** * < p > Configure the SAML Handlers . < / p > */
private void configureHandlers ( ) { } }

implementation: Handlers actualHandlers = new Handlers ( ) ; actualHandlers . setHandlers ( new ArrayList < Handler > ( ) ) ; if ( this . handlers . isEmpty ( ) ) { for ( Class < ? extends SAML2Handler > commonHandlerClass : getDefaultHandlers ( ) ) { addHandler ( commonHandlerClass , actualHandlers ) ; } } else { for ( Handler handler : this . handlers ) { actualHandlers . add ( handler ) ; } } getPicketLinkType ( ) . setHandlers ( actualHandlers ) ;


signature:
public class AllowedMethodsInformation { /** * Checks that the current method */
public static void checkAllowed ( final MethodType methodType ) { } }

implementation: final InterceptorContext context = CurrentInvocationContext . get ( ) ; if ( context == null ) { return ; } final Component component = context . getPrivateData ( Component . class ) ; if ( ! ( component instanceof EJBComponent ) ) { return ; } final InvocationType invocationType = context . getPrivateData ( InvocationType . class ) ; ( ( EJBComponent ) component ) . getAllowedMethodsInformation ( ) . realCheckPermission ( methodType , invocationType ) ;


signature:
public class AllowedMethodsInformation { /** * transaction sync is not affected by the current invocation , as multiple ejb methods may be invoked from afterCompletion */
private void checkTransactionSync ( MethodType methodType ) { } }

implementation:
// first we have to check the synchronization status
// as the sync is not affected by the current invocation
final CurrentSynchronizationCallback . CallbackType currentSync = CurrentSynchronizationCallback . get ( ) ; if ( currentSync != null ) { if ( deniedSyncMethods . contains ( new DeniedSyncMethodKey ( currentSync , methodType ) ) ) { throwException ( methodType , currentSync ) ; } }


signature:
public class AllowedMethodsInformation { /** * throw an exception when a method cannot be invoked
 * @ param methodType the method
 * @ param invocationType the type of invocation that caused it to be disabled */
protected void throwException ( MethodType methodType , InvocationType invocationType ) { } }

implementation: throw EjbLogger . ROOT_LOGGER . cannotCallMethod ( methodType . getLabel ( ) , invocationType . getLabel ( ) ) ;