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.