public class SingleRecoveryManagerSupervisor extends Object
Constructor and Description |
---|
SingleRecoveryManagerSupervisor(SdkInternalConfiguration config,
SdkProducerManager producerManager,
SdkProducerStatusListener producerStatusListener,
SdkEventRecoveryStatusListener eventRecoveryStatusListener,
SnapshotRequestManager snapshotRequestManager,
SdkTaskScheduler taskScheduler,
ScheduledExecutorService executorServices,
HttpHelper httpHelper,
FeedMessageFactory messageFactory,
WhoAmIReader whoAmIReader,
SequenceGenerator sequenceGenerator,
TimeUtils timeUtils,
TelemetryFactory usageTelemetryFactory) |
Modifier and Type | Method and Description |
---|---|
RecoveryManagerImpl |
getRecoveryManager() |
void |
startSupervising() |
void |
stopSupervising() |
@Inject public SingleRecoveryManagerSupervisor(SdkInternalConfiguration config, SdkProducerManager producerManager, SdkProducerStatusListener producerStatusListener, SdkEventRecoveryStatusListener eventRecoveryStatusListener, SnapshotRequestManager snapshotRequestManager, SdkTaskScheduler taskScheduler, ScheduledExecutorService executorServices, HttpHelper httpHelper, FeedMessageFactory messageFactory, WhoAmIReader whoAmIReader, SequenceGenerator sequenceGenerator, TimeUtils timeUtils, TelemetryFactory usageTelemetryFactory)
public RecoveryManagerImpl getRecoveryManager()
public void startSupervising()
public void stopSupervising()
Copyright © 2016–2025. All rights reserved.