Updated lib version + changed listener
This commit is contained in:
parent
07eab0c129
commit
73c97dd73a
@ -24,7 +24,7 @@ repositories {
|
|||||||
|
|
||||||
val exposedVersion = "0.38.2"
|
val exposedVersion = "0.38.2"
|
||||||
dependencies {
|
dependencies {
|
||||||
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha74")
|
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75")
|
||||||
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
|
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
|
||||||
|
|
||||||
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha9")
|
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha9")
|
||||||
|
|||||||
@ -14,6 +14,7 @@ import no.iktdev.streamit.library.kafka.dto.Status
|
|||||||
import no.iktdev.streamit.library.kafka.dto.StatusType
|
import no.iktdev.streamit.library.kafka.dto.StatusType
|
||||||
import no.iktdev.streamit.library.kafka.listener.collector.CollectorMessageListener
|
import no.iktdev.streamit.library.kafka.listener.collector.CollectorMessageListener
|
||||||
import no.iktdev.streamit.library.kafka.listener.collector.ICollectedMessagesEvent
|
import no.iktdev.streamit.library.kafka.listener.collector.ICollectedMessagesEvent
|
||||||
|
import no.iktdev.streamit.library.kafka.listener.collector.NeedyMessageListener
|
||||||
import no.iktdev.streamit.library.kafka.listener.deserializer.IMessageDataDeserialization
|
import no.iktdev.streamit.library.kafka.listener.deserializer.IMessageDataDeserialization
|
||||||
import no.iktdev.streamit.library.kafka.listener.sequential.ISequentialMessageEvent
|
import no.iktdev.streamit.library.kafka.listener.sequential.ISequentialMessageEvent
|
||||||
import no.iktdev.streamit.library.kafka.listener.sequential.SequentialMessageListener
|
import no.iktdev.streamit.library.kafka.listener.sequential.SequentialMessageListener
|
||||||
@ -26,11 +27,16 @@ private val logger = KotlinLogging.logger {}
|
|||||||
@Service
|
@Service
|
||||||
class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesEvent<ResultCollection> {
|
class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesEvent<ResultCollection> {
|
||||||
|
|
||||||
val collectionListener = CollectorMessageListener<ResultCollection>(
|
val collectionListener = NeedyMessageListener<ResultCollection>(
|
||||||
topic = CommonConfig.kafkaTopic,
|
topic = CommonConfig.kafkaTopic,
|
||||||
consumer = defaultConsumer,
|
consumer = defaultConsumer,
|
||||||
initiatorEvent = KafkaEvents.EVENT_READER_RECEIVED_FILE,
|
initiatorEvent = KafkaEvents.EVENT_READER_RECEIVED_FILE,
|
||||||
completionEvent = KafkaEvents.EVENT_READER_DETERMINED_FILENAME,
|
completionEvent = KafkaEvents.EVENT_READER_DETERMINED_FILENAME,
|
||||||
|
needs = listOf(
|
||||||
|
KafkaEvents.EVENT_READER_RECEIVED_FILE,
|
||||||
|
KafkaEvents.EVENT_READER_RECEIVED_STREAMS,
|
||||||
|
KafkaEvents.EVENT_READER_DETERMINED_FILENAME
|
||||||
|
),
|
||||||
listener = this,
|
listener = this,
|
||||||
eventCollectionClass = ResultCollection::class.java
|
eventCollectionClass = ResultCollection::class.java
|
||||||
)
|
)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user