modules/host-android/src/main/java/org/apache/tuscany/sca/host/embedded/impl/EmbeddedSCADomain.java [56:232]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class EmbeddedSCADomain extends SCADomain { private String uri; private Composite domainComposite; private RuntimeBootStrapper runtime; private ComponentManagerImpl componentManager = new ComponentManagerImpl(this); /** * Constructs a new domain facade. * * @param runtimeClassLoader * @param domainURI */ public EmbeddedSCADomain(ClassLoader runtimeClassLoader, String domainURI) { this.uri = domainURI; // Create a runtime runtime = new RuntimeBootStrapper(runtimeClassLoader); } public void start() throws ActivationException { // Start the runtime runtime.start(); // Create an in-memory domain level composite AssemblyFactory assemblyFactory = runtime.getAssemblyFactory(); domainComposite = assemblyFactory.createComposite(); domainComposite.setName(new QName(Constants.SCA10_NS, "domain")); domainComposite.setURI(uri); getCompositeActivator().setDomainComposite(domainComposite); } public void stop() throws ActivationException { // Stop the runtime runtime.stop(); // Cleanup domainComposite = null; } public void buildComposite(Composite composite) throws CompositeBuilderException { runtime.buildComposite(composite); } public ContributionService getContributionService() { return runtime.getContributionService(); } public CompositeBuilder getCompositeBuilder() { return runtime.getCompositeBuilder(); } public CompositeActivator getCompositeActivator() { return runtime.getCompositeActivator(); } public Composite getDomainComposite() { return domainComposite; } @Override public ComponentManager getComponentManager() { return componentManager; } @Override public void close() { super.close(); } @Override public > R cast(B target) throws IllegalArgumentException { return (R)runtime.getProxyFactory().cast(target); } @Override public B getService(Class businessInterface, String serviceName) { ServiceReference serviceReference = getServiceReference(businessInterface, serviceName); if (serviceReference == null) { throw new ServiceRuntimeException("Service not found: " + serviceName); } return serviceReference.getService(); } private ServiceReference createServiceReference(Class businessInterface, String targetURI) { try { AssemblyFactory assemblyFactory = runtime.getAssemblyFactory(); Composite composite = assemblyFactory.createComposite(); composite.setName(new QName(Constants.SCA10_TUSCANY_NS, "default")); RuntimeComponent component = (RuntimeComponent)assemblyFactory.createComponent(); component.setName("default"); component.setURI("default"); runtime.getCompositeActivator().configureComponentContext(component); composite.getComponents().add(component); RuntimeComponentReference reference = (RuntimeComponentReference)assemblyFactory.createComponentReference(); reference.setName("default"); ModelFactoryExtensionPoint factories = runtime.getExtensionPointRegistry().getExtensionPoint(ModelFactoryExtensionPoint.class); JavaInterfaceFactory javaInterfaceFactory = factories.getFactory(JavaInterfaceFactory.class); InterfaceContract interfaceContract = javaInterfaceFactory.createJavaInterfaceContract(); interfaceContract.setInterface(javaInterfaceFactory.createJavaInterface(businessInterface)); reference.setInterfaceContract(interfaceContract); component.getReferences().add(reference); reference.setComponent(component); SCABindingFactory scaBindingFactory = factories.getFactory(SCABindingFactory.class); SCABinding binding = scaBindingFactory.createSCABinding(); binding.setURI(targetURI); reference.getBindings().add(binding); return new ServiceReferenceImpl(businessInterface, component, reference, binding, runtime .getProxyFactory(), runtime.getCompositeActivator()); } catch (Exception e) { throw new ServiceRuntimeException(e); } } @Override public ServiceReference getServiceReference(Class businessInterface, String name) { // Extract the component name String componentName; String serviceName; int i = name.indexOf('/'); if (i != -1) { componentName = name.substring(0, i); serviceName = name.substring(i + 1); } else { componentName = name; serviceName = null; } // Lookup the component in the domain Component component = componentManager.getComponent(componentName); if (component == null) { // The component is not local in the partition, try to create a remote service ref return createServiceReference(businessInterface, name); } RuntimeComponentContext componentContext = null; // If the component is a composite, then we need to find the // non-composite component that provides the requested service if (component.getImplementation() instanceof Composite) { for (ComponentService componentService : component.getServices()) { if (serviceName == null || serviceName.equals(componentService.getName())) { CompositeService compositeService = (CompositeService)componentService.getService(); if (compositeService != null) { if (serviceName != null) { serviceName = "$promoted$" + component.getName() + "$slash$" + serviceName; } componentContext = ((RuntimeComponent)compositeService.getPromotedComponent()).getComponentContext(); return componentContext.createSelfReference(businessInterface, compositeService .getPromotedService()); } break; } } // No matching service is found throw new ServiceRuntimeException("Composite service not found: " + name); } else { componentContext = ((RuntimeComponent)component).getComponentContext(); if (serviceName != null) { return componentContext.createSelfReference(businessInterface, serviceName); } else { return componentContext.createSelfReference(businessInterface); } } } @Override public String getURI() { return uri; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - modules/host-embedded/src/main/java/org/apache/tuscany/sca/host/embedded/impl/EmbeddedSCADomain.java [56:232]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class EmbeddedSCADomain extends SCADomain { private String uri; private Composite domainComposite; private RuntimeBootStrapper runtime; private ComponentManagerImpl componentManager = new ComponentManagerImpl(this); /** * Constructs a new domain facade. * * @param runtimeClassLoader * @param domainURI */ public EmbeddedSCADomain(ClassLoader runtimeClassLoader, String domainURI) { this.uri = domainURI; // Create a runtime runtime = new RuntimeBootStrapper(runtimeClassLoader); } public void start() throws ActivationException { // Start the runtime runtime.start(); // Create an in-memory domain level composite AssemblyFactory assemblyFactory = runtime.getAssemblyFactory(); domainComposite = assemblyFactory.createComposite(); domainComposite.setName(new QName(Constants.SCA10_NS, "domain")); domainComposite.setURI(uri); getCompositeActivator().setDomainComposite(domainComposite); } public void stop() throws ActivationException { // Stop the runtime runtime.stop(); // Cleanup domainComposite = null; } public void buildComposite(Composite composite) throws CompositeBuilderException { runtime.buildComposite(composite); } public ContributionService getContributionService() { return runtime.getContributionService(); } public CompositeBuilder getCompositeBuilder() { return runtime.getCompositeBuilder(); } public CompositeActivator getCompositeActivator() { return runtime.getCompositeActivator(); } public Composite getDomainComposite() { return domainComposite; } @Override public ComponentManager getComponentManager() { return componentManager; } @Override public void close() { super.close(); } @Override public > R cast(B target) throws IllegalArgumentException { return (R)runtime.getProxyFactory().cast(target); } @Override public B getService(Class businessInterface, String serviceName) { ServiceReference serviceReference = getServiceReference(businessInterface, serviceName); if (serviceReference == null) { throw new ServiceRuntimeException("Service not found: " + serviceName); } return serviceReference.getService(); } private ServiceReference createServiceReference(Class businessInterface, String targetURI) { try { AssemblyFactory assemblyFactory = runtime.getAssemblyFactory(); Composite composite = assemblyFactory.createComposite(); composite.setName(new QName(Constants.SCA10_TUSCANY_NS, "default")); RuntimeComponent component = (RuntimeComponent)assemblyFactory.createComponent(); component.setName("default"); component.setURI("default"); runtime.getCompositeActivator().configureComponentContext(component); composite.getComponents().add(component); RuntimeComponentReference reference = (RuntimeComponentReference)assemblyFactory.createComponentReference(); reference.setName("default"); ModelFactoryExtensionPoint factories = runtime.getExtensionPointRegistry().getExtensionPoint(ModelFactoryExtensionPoint.class); JavaInterfaceFactory javaInterfaceFactory = factories.getFactory(JavaInterfaceFactory.class); InterfaceContract interfaceContract = javaInterfaceFactory.createJavaInterfaceContract(); interfaceContract.setInterface(javaInterfaceFactory.createJavaInterface(businessInterface)); reference.setInterfaceContract(interfaceContract); component.getReferences().add(reference); reference.setComponent(component); SCABindingFactory scaBindingFactory = factories.getFactory(SCABindingFactory.class); SCABinding binding = scaBindingFactory.createSCABinding(); binding.setURI(targetURI); reference.getBindings().add(binding); return new ServiceReferenceImpl(businessInterface, component, reference, binding, runtime .getProxyFactory(), runtime.getCompositeActivator()); } catch (Exception e) { throw new ServiceRuntimeException(e); } } @Override public ServiceReference getServiceReference(Class businessInterface, String name) { // Extract the component name String componentName; String serviceName; int i = name.indexOf('/'); if (i != -1) { componentName = name.substring(0, i); serviceName = name.substring(i + 1); } else { componentName = name; serviceName = null; } // Lookup the component in the domain Component component = componentManager.getComponent(componentName); if (component == null) { // The component is not local in the partition, try to create a remote service ref return createServiceReference(businessInterface, name); } RuntimeComponentContext componentContext = null; // If the component is a composite, then we need to find the // non-composite component that provides the requested service if (component.getImplementation() instanceof Composite) { for (ComponentService componentService : component.getServices()) { if (serviceName == null || serviceName.equals(componentService.getName())) { CompositeService compositeService = (CompositeService)componentService.getService(); if (compositeService != null) { if (serviceName != null) { serviceName = "$promoted$" + component.getName() + "$slash$" + serviceName; } componentContext = ((RuntimeComponent)compositeService.getPromotedComponent()).getComponentContext(); return componentContext.createSelfReference(businessInterface, compositeService .getPromotedService()); } break; } } // No matching service is found throw new ServiceRuntimeException("Composite service not found: " + name); } else { componentContext = ((RuntimeComponent)component).getComponentContext(); if (serviceName != null) { return componentContext.createSelfReference(businessInterface, serviceName); } else { return componentContext.createSelfReference(businessInterface); } } } @Override public String getURI() { return uri; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -