behandlingsflyt/no.nav.aap.behandlingsflyt.prosessering.tilbakekreving

Package-level declarations

Types

data class FagsysteminfoSvarHendelse(val hendelsestype: String = "fagsysteminfo_svar", val versjon: Int = 1, val eksternFagsakId: String, val hendelseOpprettet: LocalDateTime, val mottaker: MottakerDto, val revurdering: FagsysteminfoSvarHendelse.RevurderingDto, val utvidPerioder: List<FagsysteminfoSvarHendelse.UtvidetPeriodeDto>?, val behandlendeEnhet: String?)

KafkaProducerConfig

data class KafkaProducerConfig<K, V>(val applicationId: String = requiredConfigForKey("NAIS_APP_NAME"), val brokers: String = requiredConfigForKey("KAFKA_BROKERS"), val ssl: SslConfig? = SslConfig(), val schemaRegistry: SchemaRegistryConfig? = SchemaRegistryConfig(), val additionalProperties: Properties = Properties())

KafkaProdusent

abstract class KafkaProdusent<K, V>(val topic: String, config: KafkaProducerConfig<K, V>, producerName: String)

MottakerDto

data class MottakerDto(val ident: String, val type: MottakerDto.MottakerType)

PeriodeDto

data class PeriodeDto(val fom: LocalDate, val tom: LocalDate)

SchemaRegistryConfig

data class SchemaRegistryConfig(val url: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY"), val user: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY_USER"), val password: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY_PASSWORD"))

SendFagsysteminfoBehovTilTilbakekrevingUtfører

class SendFagsysteminfoBehovTilTilbakekrevingUtfører(val sakRepository: SakRepository) : JobbUtfører

SslConfig

data class SslConfig(val truststorePath: String = requiredConfigForKey("KAFKA_TRUSTSTORE_PATH"), val keystorePath: String = requiredConfigForKey("KAFKA_KEYSTORE_PATH"), val credstorePsw: String = requiredConfigForKey("KAFKA_CREDSTORE_PASSWORD"))

TilbakekrevingFagsystemInfoProdusent

class TilbakekrevingFagsystemInfoProdusent(config: KafkaProducerConfig<String, String>) : KafkaProdusent<String, String>

Properties

TILBAKEKREVING_EVENT_TOPIC

const val TILBAKEKREVING_EVENT_TOPIC: String