| 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 | 
|---|---|
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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
FeedMessageHelper.provideEventIdFromMessage(UnmarshalledMessage o)
Provides the id of the associated event if available, otherwise an explanation why
 the eventId is not available get(ex: for a snapshot complete -> system message) 
 | 
static long | 
FeedMessageHelper.provideGenTimestampFromMessage(UnmarshalledMessage o)
Provides the message timestamp 
 | 
static Long | 
FeedMessageHelper.provideMessageGenTimestampFromMessage(UnmarshalledMessage o)
Provides the message generation timestamp,
 the generation timestamp is extracted only from the betstop and oddschange message 
 | 
static int | 
FeedMessageHelper.provideProducerIdFromMessage(UnmarshalledMessage o)
Provides the id of the message producer 
 | 
static Long | 
FeedMessageHelper.provideRequestIdFromMessage(UnmarshalledMessage o)
Provides the request id of the message (if present) 
 | 
Copyright © 2016–2025. All rights reserved.