Documentation for a newer release is available. View Latest

Akka Bulk Aggregate

Akka Bulk Aggregate es una implementación de BulkAggregate que utiliza actores de Akka para ingerir componentes de bulk y realizar validación.

Dependencia Maven

Para usar Akka Bulk Aggregate, debe proporcionarse la siguiente dependencia, con una versión que coincida con ipf-bulker para garantizar la compatibilidad.

    <dependency>
        <groupId>com.iconsolutions.ipf.bulk</groupId>
        <artifactId>ipf-bulker-aggregate-akka</artifactId>
        <version>${ipf-bulker.version}</version>
    </dependency>

Configuración de reintentos

Akka Bulk Aggregate utiliza el patrón AskWithRetry al enviar comandos a los actores de Single y Recurring Bulk, con la siguiente configuración.

ipf.bulker.aggregate.retry {
    # The amount of time to wait for the Aggregate to process a single BulkCommand message
    processing-timeout = 5s

    # The number of times to attempt sending a single command to the aggregate
    max-attempts = 3

    # The delay multiplier to use on subsequent send attempts
    backoff-factor = 2

    # The percentage of randomness to use when retrying bulk commands
    jitter-factor = 0.2
}

Pasivación de actores de Bulk

En caso de que no haya interacción con el actor de recurring/single bulk, ese actor será pasivado después de un tiempo configurado. El valor predeterminado es '2m' (2 minutos), pero puede sobrescribirse usando esta propiedad: ipf.bulker.aggregate.actor-idle-timeout.