}
@Override
- protected Future<PrimaryShardInfo> findPrimaryShard(final String shardName) {
+ protected Future<PrimaryShardInfo> findPrimaryShard(final String shardName, final String txId) {
return getActorContext().findPrimaryShardAsync(shardName);
}