+ protected OfHeader buildRequest(final Xid xid, final SendExperimenterMpRequestInput input) {
+ return new MultipartRequestBuilder()
+ .setXid(xid.getValue())
+ .setVersion(getVersion())
+ .setRequestMore(false)
+ .setMultipartRequestBody(new MultipartRequestExperimenterBuilder(input).build())
+ .build();
+ }
+
+ @Override
+ public ListenableFuture<RpcResult<SendExperimenterMpRequestOutput>> handleAndReply(
+ SendExperimenterMpRequestInput input) {