Package ch.tocco.nice2.optional.einvoicingpostfinance.impl.action

Class PostfinanceRecipientLookupTask

java.lang.Object

ch.tocco.nice2.persist.core.api.exec.AbstractPartitionedPersistTask<PostfinanceRecipientLookupTask.RecipientLookupInput,Entity,Entity>

ch.tocco.nice2.optional.einvoicingpostfinance.impl.action.PostfinanceRecipientLookupTask

All Implemented Interfaces:

PersistTask<Iterable<PostfinanceRecipientLookupTask.RecipientLookupInput>,Iterable<Entity>>

public class PostfinanceRecipientLookupTask
extends AbstractPartitionedPersistTask<PostfinanceRecipientLookupTask.RecipientLookupInput,Entity,Entity>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PostfinanceRecipientLookupTask.RecipientLookupInput

Constructor Summary

Constructors

Constructor	Description
PostfinanceRecipientLookupTask(PersistenceService persistenceService, PostfinanceService postfinanceService, EbillRecipientLogService recipientLogService, TextResources textResources, org.slf4j.Logger log, PrimaryKey billerKey, Consumer<PostfinanceRecipientLookupTask.RecipientLookupInput> progressConsumer, Consumer<Tuple2<String,Map<String,String>>> progressLogConsumer)

Method Summary

Modifier and Type	Method	Description
protected Function<Context,Entity>	createTaskData()	Create a function that creates an instance of Z.
Iterable<Entity>	run(Optional<Iterable<PostfinanceRecipientLookupTask.RecipientLookupInput>> recipientLookupInputsOptional, CommandContext commandContext)

Methods inherited from class ch.tocco.nice2.persist.core.api.exec.AbstractPartitionedPersistTask

getTaskData, partition, partition, partition

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ch.tocco.nice2.persist.core.api.exec.PersistTask

andThenDo, compose, compose2, composeWhen, discardResult, expand, expand, getDescription, ifElse, orWhen, orWhenNot, passWhen, passWhenNot, skipErrors, unwrap

Constructor Details

PostfinanceRecipientLookupTask

public PostfinanceRecipientLookupTask(PersistenceService persistenceService,
 PostfinanceService postfinanceService,
 EbillRecipientLogService recipientLogService,
 TextResources textResources,
 org.slf4j.Logger log,
 PrimaryKey billerKey,
 Consumer<PostfinanceRecipientLookupTask.RecipientLookupInput> progressConsumer,
 Consumer<Tuple2<String,Map<String,String>>> progressLogConsumer)

Method Details

createTaskData

protected Function<Context,Entity> createTaskData()

Description copied from class: AbstractPartitionedPersistTask

Create a function that creates an instance of Z. This function is called once for each context and should be used to load entities (or other Context related objects) which are used in every iteration.

Specified by:

createTaskData in class AbstractPartitionedPersistTask<PostfinanceRecipientLookupTask.RecipientLookupInput,Entity,Entity>

run

public Iterable<Entity> run(Optional<Iterable<PostfinanceRecipientLookupTask.RecipientLookupInput>> recipientLookupInputsOptional,
 CommandContext commandContext)
                     throws Exception

Throws:

Exception