Modifier and Type | Method and Description |
---|---|
static MessageInterest |
MessageInterest.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static MessageInterest[] |
MessageInterest.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
UofSessionBuilder |
UofSessionBuilder.setMessageInterest(MessageInterest msgInterest) |
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 |
---|---|
MessageInterest |
UofSessionImpl.getMessageInterest()
Returns the consumer
MessageInterest |
MessageInterest |
MessageConsumer.getMessageInterest()
Returns the consumer
MessageInterest
(method most useful in custom consumer implementations) |
Modifier and Type | Method and Description |
---|---|
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.open(List<String> routingKeys,
MessageInterest messageInterest,
UofListener uofListener,
UofExtListener uofExtListener) |
Modifier and Type | Method and Description |
---|---|
static Map<Integer,List<String>> |
OddsFeedRoutingKeyBuilder.generateKeys(Map<Integer,Map.Entry<MessageInterest,Set<Urn>>> sessionsData,
SdkInternalConfiguration oddsFeedConfiguration)
Builds a valid list of routing keys for the provided sessions
k -> session identifier
v -> a
List of routing keys for the associated session |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryManagerImpl.onSnapshotCompleteReceived(int producerId,
long nowTimestamp,
long requestId,
MessageInterest sessionMessageInterest) |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryManager.onSnapshotCompleteReceived(int producerId,
long now,
long requestId,
MessageInterest sessionMessageInterest)
Method invoked when the message of type "SnapshotComplete" is received
|
Copyright © 2016–2025. All rights reserved.