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 |
---|---|
<T extends SportEvent> |
FeedMessageFactory.buildBetCancel(T sportEvent,
com.sportradar.uf.datamodel.UfBetCancel message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildBetSettlement(T sportEvent,
com.sportradar.uf.datamodel.UfBetSettlement message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildBetStop(T sportEvent,
com.sportradar.uf.datamodel.UfBetStop message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildCashOutProbabilities(T sportEvent,
com.sportradar.uf.datamodel.UfCashout cashoutData,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildFixtureChange(T sportEvent,
com.sportradar.uf.datamodel.UfFixtureChange message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildOddsChange(T sportEvent,
com.sportradar.uf.datamodel.UfOddsChange message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildRollbackBetCancel(T sportEvent,
com.sportradar.uf.datamodel.UfRollbackBetCancel message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildRollbackBetSettlement(T sportEvent,
com.sportradar.uf.datamodel.UfRollbackBetSettlement message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactory.buildUnparsableMessage(T sportEvent,
Integer producerId,
byte[] rawMessage,
MessageTimestamp timestamp) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageTimestampImpl |
Modifier and Type | Method and Description |
---|---|
<T extends SportEvent> |
FeedMessageFactoryImpl.buildBetCancel(T sportEvent,
com.sportradar.uf.datamodel.UfBetCancel message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildBetSettlement(T sportEvent,
com.sportradar.uf.datamodel.UfBetSettlement message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildBetStop(T sportEvent,
com.sportradar.uf.datamodel.UfBetStop message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildCashOutProbabilities(T sportEvent,
com.sportradar.uf.datamodel.UfCashout cashoutData,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildFixtureChange(T sportEvent,
com.sportradar.uf.datamodel.UfFixtureChange message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildOddsChange(T sportEvent,
com.sportradar.uf.datamodel.UfOddsChange message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildRollbackBetCancel(T sportEvent,
com.sportradar.uf.datamodel.UfRollbackBetCancel message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildRollbackBetSettlement(T sportEvent,
com.sportradar.uf.datamodel.UfRollbackBetSettlement message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
FeedMessageFactoryImpl.buildUnparsableMessage(T sportEvent,
Integer producerId,
byte[] rawMessage,
MessageTimestamp timestamp) |
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.
|
Modifier and Type | Method and Description |
---|---|
MessageTimestamp |
Message.getTimestamps()
Gets the timestamps when the message was generated, sent, received and dispatched by the sdk
|
Copyright © 2016–2025. All rights reserved.