api/no.nav.aap.behandlingsflyt.hendelse.kafka.foreldrepenger/ForeldrepengevedtakKafkaKonsument

ForeldrepengevedtakKafkaKonsument

class ForeldrepengevedtakKafkaKonsument(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, val dataSource: DataSource, val repositoryRegistry: RepositoryRegistry, val gatewayProvider: GatewayProvider) : KafkaKonsument<String, String> (source)

Constructors

ForeldrepengevedtakKafkaKonsument

constructor(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, dataSource: DataSource, repositoryRegistry: RepositoryRegistry, gatewayProvider: GatewayProvider)

Properties

antallMeldinger

var antallMeldinger: Int

private val closeTimeout: Duration

private val dataSource: DataSource

gatewayProvider

private val gatewayProvider: GatewayProvider

private val konsument: KafkaConsumer<K, V>

private val log: Logger?

private val log: Logger?

private val lukket: AtomicBoolean

private val pollTimeout: Duration

repositoryRegistry

private val repositoryRegistry: RepositoryRegistry

val topic: String

Functions

fun erLukket(): Boolean

finnPersonMedIdenterFraPdl

private fun finnPersonMedIdenterFraPdl(ident: Ident, personRepository: PersonRepository): Person?

fun håndter(melding: ConsumerRecord<String, String>)

open override fun håndter(meldinger: ConsumerRecords<String, String>)

fun håndter(meldingKey: String, meldingVerdi: String)

fun lukk()