api/no.nav.aap.behandlingsflyt.hendelse.kafka.inst2/InstitusjonsOppholdKafkaKonsument

InstitusjonsOppholdKafkaKonsument

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

Constructors

InstitusjonsOppholdKafkaKonsument

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

Properties

antallMeldinger

var antallMeldinger: Int

private val closeTimeout: Duration

private val dataSource: DataSource

gatewayProvider

private val gatewayProvider: GatewayProvider

institusjonsoppholdKlient

val institusjonsoppholdKlient: InstitusjonsoppholdGateway

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

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

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

fun lukk()