public class BaseRpcOutcomeListener<T> extends Object implements RpcOutcomeListener<T>
Constructor and Description |
---|
BaseRpcOutcomeListener() |
Modifier and Type | Method and Description |
---|---|
void |
failed(RpcException ex)
Called when an error occurred while waiting for the RPC outcome.
|
void |
interrupted(InterruptedException ex)
Called when the sending thread is interrupted.
|
void |
success(T value,
io.netty.buffer.ByteBuf buffer) |
public void failed(RpcException ex)
RpcOutcomeListener
failed
in interface RpcOutcomeListener<T>
public void success(T value, io.netty.buffer.ByteBuf buffer)
success
in interface RpcOutcomeListener<T>
public void interrupted(InterruptedException ex)
interrupted
in interface RpcOutcomeListener<T>
Copyright © 1970 The Apache Software Foundation. All rights reserved.