return messageSpy;
}
- protected abstract OfHeader buildRequest(Xid xid, I input) throws Exception;
+ protected abstract OfHeader buildRequest(Xid xid, I input) throws ServiceException;
protected abstract FutureCallback<OfHeader> createCallback(RequestContext<O> context, Class<?> requestType);
- public final ListenableFuture<RpcResult<O>> handleServiceCall(@Nonnull final I input) {
+ public ListenableFuture<RpcResult<O>> handleServiceCall(@Nonnull final I input) {
Preconditions.checkNotNull(input);
final Class<?> requestType;