blob: f84c5b7ed18abbb0b4f24e6e2ffcb36bf5c00c66 (
plain)
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/**
*
* Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
* License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS"
* BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
* governing permissions and limitations under the License.
*/
package org.apache.tuscany.core.injection;
import org.apache.tuscany.core.builder.ObjectFactory;
import org.apache.tuscany.core.context.AggregateContext;
import org.apache.tuscany.core.context.InstanceContext;
import org.apache.tuscany.core.context.QualifiedName;
import org.apache.tuscany.core.context.TargetException;
import org.apache.tuscany.model.assembly.Component;
import org.apache.tuscany.model.assembly.ConfiguredReference;
import org.apache.tuscany.model.assembly.ConfiguredService;
import org.apache.tuscany.model.assembly.EntryPoint;
import org.apache.tuscany.model.assembly.ExternalService;
/**
* Returns a direct reference to a target service, i.e. the factory avoids creating proxies and returns the actual
* target instance
*
* @version $Rev$ $Date$
*/
public class ReferenceTargetFactory<T> implements ObjectFactory<T> {
private AggregateContext parentContext;
// the SCDL name of the target component/service for this reference
private String targetName;
private QualifiedName targetComponentName;
// the reference target is in another module
private boolean interModule;
// ----------------------------------
// Constructors
// ----------------------------------
/**
* Constructs a reference object factory from a configured reference on a type
*/
public ReferenceTargetFactory(ConfiguredReference reference, AggregateContext parentContext)
throws FactoryInitException {
// FIXME how to handle a reference that is a list - may take different proxy factories for each entry
assert (reference != null) : "Reference was null";
assert (parentContext != null) : "Parent context was null";
this.parentContext = parentContext;
// targetName = reference.getReference().getName();
ConfiguredService targetService = reference.getTargetConfiguredServices().get(0);
if (targetService.getAggregatePart() instanceof ExternalService) {
targetName = ((ExternalService) targetService.getAggregatePart()).getName();
} else if (targetService.getAggregatePart() instanceof Component) {
Component targetComponent = (Component) targetService.getAggregatePart();
targetName = targetComponent.getName();
} else if (targetService.getAggregatePart() instanceof EntryPoint) {
targetName = ((EntryPoint) targetService.getAggregatePart()).getName();
} else if (targetService.getAggregatePart() == null) {
// FIXME not correct
if (targetService.getService() == null) {
throw new FactoryInitException("No target service specified");
}
targetName = targetService.getService().getName();
} else {
FactoryInitException fie = new FactoryInitException("Unknown reference target type");
fie.setIdentifier(reference.getReference().getName());
throw fie;
}
}
/**
* Reference source is an external service, target is in another module
*
* @param service
* @param parentContext
* @throws FactoryInitException
*/
public ReferenceTargetFactory(String targetName, AggregateContext parentContext) throws FactoryInitException {
//assert (service != null) : "Service was null";
assert (parentContext != null) : "Parent context was null";
interModule = true; // an external service with a reference target in another module
this.targetName = targetName;// service.getAggregatePart().getName();
targetComponentName = new QualifiedName(targetName);
this.parentContext = parentContext;
}
// ----------------------------------
// Methods
// ----------------------------------
public T getInstance() throws ObjectCreationException {
if (interModule) {
// only return entry points since this is an inter-module wire
Object o = parentContext.getInstance(targetComponentName);
if (o != null) {
return (T) o;
} else {
// walk up the hierarchy of aggregate contexts
AggregateContext ctx = parentContext;
do {
if (ctx == null) {
break; // reached top of context hierarchy
}
InstanceContext compContext = ctx.getContext(targetComponentName.getPartName());
if (compContext != null) {
o = compContext.getInstance(targetComponentName);
if (o != null) {
return (T) o;
}
}
ctx = ctx.getParent();
} while (ctx != null);
TargetException e= new TargetException("Target reference not found");
e.setIdentifier(targetName);
throw e;
}
} else {
// the target is in the same module, so just locate it
return (T) parentContext.locateInstance(targetName);
}
}
}
|
