Class PersistentQueueKt
-
- All Implemented Interfaces:
public final class PersistentQueueKt
-
-
Field Summary
Fields Modifier and Type Field Description private final static Topic<String>ACTIVE_EVENT_LOG_FILE_NAME_TOPIC
-
Method Summary
Modifier and Type Method Description final Topic<String>getACTIVE_EVENT_LOG_FILE_NAME_TOPIC()final static <E extends Any> PersistentQueue<E>persistentQueue(MessageBus messageBus, FileStorage fileStorage, FusJsonSerializer jsonSerializer, FusLoggerFactory loggerFactory, Duration defaultDelay, EventLogBuildType buildType, Long maxFileBytes, Duration maxFileAge)-
-
Method Detail
-
getACTIVE_EVENT_LOG_FILE_NAME_TOPIC
final Topic<String> getACTIVE_EVENT_LOG_FILE_NAME_TOPIC()
-
persistentQueue
final static <E extends Any> PersistentQueue<E> persistentQueue(MessageBus messageBus, FileStorage fileStorage, FusJsonSerializer jsonSerializer, FusLoggerFactory loggerFactory, Duration defaultDelay, EventLogBuildType buildType, Long maxFileBytes, Duration maxFileAge)
-
-
-
-