|
@@ -84,11 +84,7 @@ public abstract class TransportBroadcastAction<Request extends BroadcastRequest<
|
|
|
|
|
|
protected abstract ShardResponse newShardResponse();
|
|
|
|
|
|
- protected abstract ShardResponse shardOperation(ShardRequest request) throws IOException;
|
|
|
-
|
|
|
- protected ShardResponse shardOperation(ShardRequest request, Task task) throws IOException {
|
|
|
- return shardOperation(request);
|
|
|
- }
|
|
|
+ protected abstract ShardResponse shardOperation(ShardRequest request, Task task) throws IOException;
|
|
|
|
|
|
/**
|
|
|
* Determines the shards this operation will be executed on. The operation is executed once per shard iterator, typically
|
|
@@ -284,7 +280,7 @@ public abstract class TransportBroadcastAction<Request extends BroadcastRequest<
|
|
|
|
|
|
@Override
|
|
|
public void messageReceived(ShardRequest request, TransportChannel channel, Task task) throws Exception {
|
|
|
- channel.sendResponse(shardOperation(request));
|
|
|
+ channel.sendResponse(shardOperation(request, task));
|
|
|
}
|
|
|
|
|
|
@Override
|