Package com.sportradar.unifiedodds.sdk.internal.di

Class MessageProcessorPipeline

java.lang.Object

com.google.inject.AbstractModule

com.sportradar.unifiedodds.sdk.internal.di.MessageProcessorPipeline

All Implemented Interfaces:

com.google.inject.Module

public class MessageProcessorPipeline
extends com.google.inject.AbstractModule

A derived injection module managing SDK message processing pipeline

Constructor Summary

Constructors

Constructor	Description
MessageProcessorPipeline()

Method Summary

Modifier and Type	Method	Description
protected void	configure()
protected FeedMessageProcessor	providesCacheMessageProcessor(SportEventStatusCache sportEventStatusCache, SportEventCache sportEventCache, ProcessedFixtureChangesTracker processedFixtureChangesTracker, SdkProducerManager producerManager)
protected CompositeMessageProcessor	providesCompositeMessageProcessor(FeedMessageProcessor cacheMessageProcessor)

Methods inherited from class com.google.inject.AbstractModule

addError, addError, addError, bind, bind, bind, bindConstant, binder, bindInterceptor, bindListener, bindListener, bindScope, configure, convertToTypes, currentStage, getMembersInjector, getMembersInjector, getProvider, getProvider, install, requestInjection, requestInjection, requestStaticInjection, requireBinding, requireBinding

Methods inherited from class java.lang.Object

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

Constructor Details

MessageProcessorPipeline

public MessageProcessorPipeline()

Method Details

configure

protected void configure()

Overrides:

configure in class com.google.inject.AbstractModule

providesCacheMessageProcessor

@Provides
protected FeedMessageProcessor providesCacheMessageProcessor(SportEventStatusCache sportEventStatusCache,
 SportEventCache sportEventCache,
 ProcessedFixtureChangesTracker processedFixtureChangesTracker,
 SdkProducerManager producerManager)

providesCompositeMessageProcessor

@Provides
protected CompositeMessageProcessor providesCompositeMessageProcessor(FeedMessageProcessor cacheMessageProcessor)