| Modifier and Type | Class and Description |
|---|---|
class |
RpcInvocation
RPC Invocation.
|
| Modifier and Type | Method and Description |
|---|---|
Invocation |
RpcContext.getInvocation()
Deprecated.
Replace to getMethodName(), getParameterTypes(), getArguments()
|
| Modifier and Type | Method and Description |
|---|---|
Result |
Invoker.invoke(Invocation invocation)
invoke.
|
Result |
Filter.invoke(Invoker<?> invoker,
Invocation invocation)
do invoke filter.
|
RpcContext |
RpcContext.setInvocation(Invocation invocation) |
| Constructor and Description |
|---|
RpcInvocation(Invocation invocation) |
RpcInvocation(Invocation invocation,
Invoker<?> invoker) |
| Modifier and Type | Method and Description |
|---|---|
Result |
AccessLogFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
CompatibleFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ClassLoaderFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ExecuteLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
TpsLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ActiveLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ExceptionFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
GenericImplFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
EchoFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
TokenFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
ContextFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
DeprecatedFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
TimeoutFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ConsumerContextFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
GenericFilter.invoke(Invoker<?> invoker,
Invocation inv) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultTPSLimiter.isAllowable(URL url,
Invocation invocation) |
boolean |
TPSLimiter.isAllowable(URL url,
Invocation invocation)
judge if the current invocation is allowed by TPS rule
|
| Modifier and Type | Method and Description |
|---|---|
Result |
ListenerInvokerWrapper.invoke(Invocation invocation) |
| Modifier and Type | Method and Description |
|---|---|
Result |
AbstractInvoker.invoke(Invocation inv) |
Result |
InvokerWrapper.invoke(Invocation invocation) |
| Modifier and Type | Method and Description |
|---|---|
Result |
AbstractProxyInvoker.invoke(Invocation invocation) |
| Modifier and Type | Method and Description |
|---|---|
static void |
RpcUtils.attachInvocationIdIfAsync(URL url,
Invocation inv)
Idempotent operation: invocation id will be added in async operation by default
|
static Object[] |
RpcUtils.getArguments(Invocation invocation) |
static Long |
RpcUtils.getInvocationId(Invocation inv) |
static String |
RpcUtils.getMethodName(Invocation invocation) |
static Class<?>[] |
RpcUtils.getParameterTypes(Invocation invocation) |
static Class<?> |
RpcUtils.getReturnType(Invocation invocation) |
static Type[] |
RpcUtils.getReturnTypes(Invocation invocation) |
Result |
MockInvoker.invoke(Invocation invocation) |
Result |
DelegateInvoker.invoke(Invocation invocation) |
static boolean |
RpcUtils.isAsync(URL url,
Invocation inv) |
static boolean |
RpcUtils.isOneway(URL url,
Invocation inv) |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.