1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
package org.apache.tuscany.container.java.builder;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import junit.framework.Assert;
import junit.framework.TestCase;
import org.apache.tuscany.common.monitor.impl.NullMonitorFactory;
import org.apache.tuscany.container.java.invocation.mock.MockSyncInterceptor;
import org.apache.tuscany.container.java.mock.MockConfigContext;
import org.apache.tuscany.container.java.mock.MockFactory;
import org.apache.tuscany.container.java.mock.components.GenericComponent;
import org.apache.tuscany.container.java.mock.components.ModuleScopeComponent;
import org.apache.tuscany.core.builder.RuntimeConfiguration;
import org.apache.tuscany.core.builder.impl.DefaultWireBuilder;
import org.apache.tuscany.core.context.AggregateContext;
import org.apache.tuscany.core.context.EventContext;
import org.apache.tuscany.core.context.InstanceContext;
import org.apache.tuscany.core.context.ScopeContext;
import org.apache.tuscany.core.context.ScopeStrategy;
import org.apache.tuscany.core.context.impl.AggregateContextImpl;
import org.apache.tuscany.core.context.impl.EventContextImpl;
import org.apache.tuscany.core.context.scope.DefaultScopeStrategy;
import org.apache.tuscany.core.context.scope.ModuleScopeContext;
import org.apache.tuscany.core.invocation.ProxyConfiguration;
import org.apache.tuscany.core.invocation.jdk.JDKProxyFactoryFactory;
import org.apache.tuscany.core.invocation.spi.ProxyFactory;
import org.apache.tuscany.core.message.impl.MessageFactoryImpl;
import org.apache.tuscany.model.assembly.AssemblyFactory;
import org.apache.tuscany.model.assembly.AssemblyModelContext;
import org.apache.tuscany.model.assembly.Component;
import org.apache.tuscany.model.assembly.Module;
import org.apache.tuscany.model.assembly.impl.AssemblyFactoryImpl;
import org.apache.tuscany.model.assembly.impl.AssemblyModelContextImpl;
public class JavaComponentContextBuilderTestCase extends TestCase {
private AssemblyFactory factory = new AssemblyFactoryImpl();
private AssemblyModelContext assemblyContext = new AssemblyModelContextImpl(null,null);
public JavaComponentContextBuilderTestCase() {
}
public void testBuilder() throws Exception {
JavaComponentContextBuilder builder = new JavaComponentContextBuilder();
builder.setMessageFactory(new MessageFactoryImpl());
// HierarchicalBuilder refBuilder = new HierarchicalBuilder();
MockSyncInterceptor interceptor = new MockSyncInterceptor();
builder.addPolicyBuilder(new MockInterceptorBuilder(interceptor, true));
//builder.setPolicyBuilder(refBuilder);
AggregateContext ctx = createContext();
builder.setProxyFactoryFactory(new JDKProxyFactoryFactory());
JavaTargetWireBuilder javaWireBuilder = new JavaTargetWireBuilder();
ScopeStrategy strategy = new DefaultScopeStrategy();
DefaultWireBuilder wireBuilder = new DefaultWireBuilder();
wireBuilder.addWireBuilder(javaWireBuilder);
Module module = MockFactory.createModule();
EventContext eCtx = new EventContextImpl();
ScopeContext scopeContext = new ModuleScopeContext(eCtx);
scopeContext.start();
scopeContext.onEvent(EventContext.MODULE_START, null);
List<Component> components = module.getComponents();
Map<String, Component> compMap = new HashMap(components.size());
for (Component component : components) {
compMap.put(component.getName(), component);
builder.build(component, ctx);
RuntimeConfiguration config = (RuntimeConfiguration) component.getComponentImplementation().getRuntimeConfiguration();
Assert.assertNotNull(config);
}
for (Component component : components) {
RuntimeConfiguration source = (RuntimeConfiguration) component.getComponentImplementation().getRuntimeConfiguration();
Assert.assertNotNull(source);
for (ProxyFactory pFactory : (Collection<ProxyFactory>) source.getSourceProxyFactories().values()) {
ProxyConfiguration pConfig = pFactory.getProxyConfiguration();
Component target = compMap.get(pConfig.getTargetName().getPartName());
if (target != null) {
RuntimeConfiguration targetConfig = (RuntimeConfiguration) target.getComponentImplementation()
.getRuntimeConfiguration();
boolean downScope = strategy.downScopeReference(source.getScope(), targetConfig.getScope());
wireBuilder.connect(pFactory, targetConfig.getTargetProxyFactory(pFactory.getProxyConfiguration().getTargetName()
.getPortName()), targetConfig.getClass(), downScope, scopeContext);
}
pFactory.initialize();
}
scopeContext.registerConfiguration(source);
}
for (Component component : components) {
RuntimeConfiguration config = (RuntimeConfiguration) component.getComponentImplementation().getRuntimeConfiguration();
InstanceContext context = (InstanceContext) config.createInstanceContext();
if ("source".equals(component.getName())) {
ModuleScopeComponent source = (ModuleScopeComponent) context.getInstance(null);
Assert.assertNotNull(source);
GenericComponent gComp = (GenericComponent) source.getGenericComponent();
gComp.getString();
}
}
}
private static AggregateContext createContext() {
return new AggregateContextImpl("test.parent", null, new DefaultScopeStrategy(), new EventContextImpl(),
new MockConfigContext(null), new NullMonitorFactory());
}
}
|
