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)MessageInterest
void 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 MessageInterest
Copyright © 2016–2025. All rights reserved.