blob: 78a87191de76e8e7e6b65430987fbd17a1ab4950 (
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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you 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.sca.runtime;
import java.lang.reflect.InvocationTargetException;
import java.util.List;
import org.apache.tuscany.sca.assembly.Binding;
import org.apache.tuscany.sca.assembly.Component;
import org.apache.tuscany.sca.assembly.Contract;
import org.apache.tuscany.sca.context.CompositeContext;
import org.apache.tuscany.sca.core.ExtensionPointRegistry;
import org.apache.tuscany.sca.interfacedef.Operation;
import org.apache.tuscany.sca.invocation.InvocationChain;
import org.apache.tuscany.sca.invocation.Message;
import org.apache.tuscany.sca.provider.PolicyProvider;
/**
* The abstraction of an invocable model that contains invocation chains
* @tuscany.spi.extension.asclient
*/
public interface Invocable {
/**
* Bind the invocable to the composite context
* @param context
*/
void bind(CompositeContext context);
/**
* Bind the invocable to the extension point registry and endpoint registry. This is typically
* called after the endpoint or endpoint reference is deserialized
* @param registry
* @param domainRegistry
*/
void bind(ExtensionPointRegistry registry, DomainRegistry domainRegistry);
/**
* Get the associated composite context
* @return
*/
CompositeContext getCompositeContext();
/**
* Unbind the invocable from the composite context
*/
void unbind();
/**
* Get the component
* @return
*/
Component getComponent();
/**
* Get the service or reference (contract)
* @return
*/
Contract getContract();
/**
* Get the binding
* @return
*/
Binding getBinding();
/**
* Returns the invocation chains for service operations associated with the
* wire
*
* @return the invocation chains for service operations associated with the
* wire
*/
List<InvocationChain> getInvocationChains();
/**
* Lookup the invocation chain by operation
* @param operation The operation
* @return The invocation chain for the given operation
*/
InvocationChain getInvocationChain(Operation operation);
/**
* Get the invocation chain for the binding-specific handling
* @return The binding invocation chain
*/
InvocationChain getBindingInvocationChain();
/**
* This invoke method assumes that the binding invocation chain is in force
* and that there will be an operation selector element there to
* determine which operation to call
* @param msg The request message
* @return The response message
*/
Message invoke(Message msg);
/**
* Invoke an operation with given arguments
* @param operation The operation
* @param args The arguments
* @return The result
* @throws InvocationTargetException
*/
Object invoke(Operation operation, Object[] args) throws InvocationTargetException;
/**
* Invoke an operation with a context message
* @param operation The operation
* @param msg The request message
* @return The response message
* @throws InvocationTargetException
*/
Message invoke(Operation operation, Message msg);
/**
* Asynchronously invoke an operation with a context message
* @param operation The operation
* @param msg The request message
* @return The ticket that can be used to identify this invocation
* @throws InvocationTargetException
*/
void invokeAsync(Operation operation, Message msg);
/**
* Asynchronously invoke an operation with a context message
* This invoke method assumes that the binding invocation chain is in force
* and that there will be an operation selector element there to
* determine which operation to call
* @param msg The request message
*/
void invokeAsync(Message msg);
/**
* Asynchronously invoke an operation with a context message
* @param tailInvoker the invoker at the end of the chain
* @param msg The request message
*/
void invokeAsyncResponse(Message msg);
/**
* Get a list of policy providers
* @return
*/
List<PolicyProvider> getPolicyProviders();
}
|
