Package | Description |
---|---|
com.sportradar.unifiedodds.sdk.extended | |
com.sportradar.unifiedodds.sdk.internal.impl | |
com.sportradar.unifiedodds.sdk.internal.impl.processing.pipeline |
Modifier and Type | Method and Description |
---|---|
void |
UofExtListener.onRawFeedMessageReceived(RoutingKeyInfo routingKey,
UnmarshalledMessage feedMessage,
MessageTimestamp timestamp,
MessageInterest messageInterest)
Occurs when any feed message arrives
|
Modifier and Type | Method and Description |
---|---|
RoutingKeyInfo |
RoutingKeyParser.getRoutingKeyInfo(String routingKey)
Returns a
RoutingKeyInfo containing the parsed routing key data |
RoutingKeyInfo |
RegexRoutingKeyParser.getRoutingKeyInfo(String routingKey)
Returns a
RoutingKeyInfo containing the parsed routing key data |
Modifier and Type | Method and Description |
---|---|
void |
UofSessionImpl.onMessageReceived(UnmarshalledMessage unmarshalledMessage,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Consumes the provided message
|
void |
MessageConsumer.onMessageReceived(UnmarshalledMessage unmarshalledMessage,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Consumes the provided message
|
void |
UofSessionImpl.onRawFeedMessageReceived(RoutingKeyInfo routingKey,
UnmarshalledMessage feedMessage,
MessageTimestamp timestamp,
MessageInterest messageInterest)
Occurs when any feed message arrives
|
void |
MessageConsumer.onRawFeedMessageReceived(RoutingKeyInfo routingKey,
UnmarshalledMessage feedMessage,
MessageTimestamp timestamp,
MessageInterest messageInterest)
Occurs when any feed message arrives
|
void |
UofSessionImpl.processMessage(UnmarshalledMessage o,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Dispatches the processed message to the client
|
void |
FeedMessageProcessor.processMessage(UnmarshalledMessage message,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Processes the provided message.
|
ValidationResult |
FeedMessageValidatorImpl.validate(UnmarshalledMessage message,
RoutingKeyInfo rkInfo)
Validates the provided
UnmarshalledMessage instance |
ValidationResult |
FeedMessageValidator.validate(UnmarshalledMessage message,
RoutingKeyInfo rkInfo)
Validates the provided
UnmarshalledMessage instance |
Modifier and Type | Method and Description |
---|---|
void |
CompositeMessageProcessor.processMessage(UnmarshalledMessage message,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Starts the processing pipeline by calling the
CompositeMessageProcessor.firstProcessor |
void |
CacheMessageProcessor.processMessage(UnmarshalledMessage message,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Processes the provided message.
|
Copyright © 2016–2025. All rights reserved.