Modifier and Type | Method and Description |
---|---|
protected FeedMessageProcessor |
MessageProcessorPipeline.providesCacheMessageProcessor(SportEventStatusCache sportEventStatusCache,
SportEventCache sportEventCache,
ProcessedFixtureChangesTracker processedFixtureChangesTracker,
SdkProducerManager producerManager) |
Modifier and Type | Method and Description |
---|---|
protected CompositeMessageProcessor |
MessageProcessorPipeline.providesCompositeMessageProcessor(FeedMessageProcessor cacheMessageProcessor) |
Modifier and Type | Interface and Description |
---|---|
interface |
CompositeFeedMessageProcessor
Defines methods implemented by the composite message processor
|
Modifier and Type | Class and Description |
---|---|
class |
UofSessionImpl |
Modifier and Type | Method and Description |
---|---|
void |
CompositeFeedMessageProcessor.init(FeedMessageProcessor dispatchingProcessor)
Initializes and prepares the composite processor instance
|
void |
UofSessionImpl.setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)
This method should be ignored since the
UofSessionImpl is the final dispatching message processor. |
void |
FeedMessageProcessor.setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)
Sets the next message processor that should be invoked after the message processing is finished
|
Modifier and Type | Class and Description |
---|---|
class |
CacheMessageProcessor
A
FeedMessageProcessor implementation which is used in the message processing pipeline |
class |
CompositeMessageProcessor
The master
FeedMessageProcessor implementation that handles the flow
trough the message processing pipeline |
Modifier and Type | Method and Description |
---|---|
void |
CompositeMessageProcessor.init(FeedMessageProcessor dispatchingProcessor)
Initializes and prepares the composite processor instance
|
void |
CompositeMessageProcessor.setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)
This method should be ignored since the
CompositeMessageProcessor is the trigger/starter
of the processing pipeline and can't have a successor processor |
void |
CacheMessageProcessor.setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor) |
Constructor and Description |
---|
CompositeMessageProcessor(List<FeedMessageProcessor> processors)
Constructs a new
CompositeMessageProcessor instance |
Copyright © 2016–2025. All rights reserved.