Package no.skatteetaten.fastsetting.formueinntekt.felles.feed.stream

Class StreamProcessor<POINTER,TRANSACTION>

java.lang.Object

no.skatteetaten.fastsetting.formueinntekt.felles.feed.api.FeedProcessor.Simple<Long,POINTER,TRANSACTION>

no.skatteetaten.fastsetting.formueinntekt.felles.feed.stream.StreamProcessor<POINTER,TRANSACTION>

All Implemented Interfaces:

FeedProcessor<POINTER>

public class StreamProcessor<POINTER,TRANSACTION>
extends FeedProcessor.Simple<Long,POINTER,TRANSACTION>

Nested Class Summary

Nested classes/interfaces inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.feed.api.FeedProcessor

FeedProcessor.Activation, FeedProcessor.Simple<LOCATION extends Object,POINTER extends Object,TRANSACTION extends Object>

Field Summary

Fields inherited from class no.skatteetaten.fastsetting.formueinntekt.felles.feed.api.FeedProcessor.Simple

lastError, pointer, repository

Constructor Summary

Constructors

Constructor	Description
StreamProcessor(POINTER pointer, FeedRepository<Long,POINTER,TRANSACTION> repository, Executor executor, Supplier<Reader> sourceProvider, int batch, boolean abortOnError, long pause, FeedConsumer<? super Long,? super StreamEntry,? extends TRANSACTION> consumer)

Method Summary

Modifier and Type	Method	Description
protected void	doStart(BooleanSupplier isAlive)
protected void	onComplete()

Methods inherited from class no.skatteetaten.fastsetting.formueinntekt.felles.feed.api.FeedProcessor.Simple

complete, getCurrentState, reset, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.feed.api.FeedProcessor

findActivation, initialize, shutdown

Constructor Detail

StreamProcessor

public StreamProcessor(POINTER pointer,
                       FeedRepository<Long,POINTER,TRANSACTION> repository,
                       Executor executor,
                       Supplier<Reader> sourceProvider,
                       int batch,
                       boolean abortOnError,
                       long pause,
                       FeedConsumer<? super Long,? super StreamEntry,? extends TRANSACTION> consumer)

Method Detail

doStart

protected void doStart(BooleanSupplier isAlive)

Specified by:

doStart in class FeedProcessor.Simple<Long,POINTER,TRANSACTION>

onComplete

protected void onComplete()

Specified by:

onComplete in class FeedProcessor.Simple<Long,POINTER,TRANSACTION>