public interface MessageConsumer
| Modifier and Type | Method and Description |
|---|---|
String |
getConsumerDescription()
Returns a
String which describes the consumer |
MessageInterest |
getMessageInterest()
Returns the consumer
MessageInterest
(method most useful in custom consumer implementations) |
void |
onMessageDeserializationFailed(byte[] rawMessage,
Urn eventId)
Dispatches the "unparsable message received event"
|
void |
onMessageReceived(UnmarshalledMessage unmarshalledMessage,
byte[] body,
RoutingKeyInfo routingKeyInfo,
MessageTimestamp timestamp)
Consumes the provided message
|
void |
onRawFeedMessageReceived(RoutingKeyInfo routingKey,
UnmarshalledMessage feedMessage,
MessageTimestamp timestamp,
MessageInterest messageInterest)
Occurs when any feed message arrives
|
void onMessageReceived(UnmarshalledMessage unmarshalledMessage, byte[] body, RoutingKeyInfo routingKeyInfo, MessageTimestamp timestamp)
unmarshalledMessage - - an unmarshalled message payloadbody - - the raw payload (mainly used for logging and user exposure)routingKeyInfo - - a RoutingKeyInfo instance describing the message routing keytimestamp - - all message timestampsvoid onMessageDeserializationFailed(byte[] rawMessage,
Urn eventId)
rawMessage - - the raw message payloadeventId - - if available the related sport event id; otherwise nullString getConsumerDescription()
String which describes the consumerString which describes the consumerMessageInterest getMessageInterest()
MessageInterest
(method most useful in custom consumer implementations)MessageInterestvoid onRawFeedMessageReceived(RoutingKeyInfo routingKey, UnmarshalledMessage feedMessage, MessageTimestamp timestamp, MessageInterest messageInterest)
routingKey - the routing key associated with this messagefeedMessage - the message receivedtimestamp - the message timestampsmessageInterest - the associated MessageInterestCopyright © 2016–2025. All rights reserved.