public interface Producer
Modifier and Type | Method and Description |
---|---|
String |
getApiUrl()
Returns the producer API url.
|
String |
getDescription()
Returns a short description of the producer
|
int |
getId()
Returns the unique producer identifier
|
long |
getLastMessageTimestamp()
Returns a timestamp indicating when was the last message received from the associated producer
|
long |
getLastProcessedMessageGenTimestamp()
Returns the last processed message generation timestamp
|
String |
getName()
Returns the name of the producer
|
long |
getProcessingQueDelay()
Returns the messaging queue processing delay in milliseconds (current time - message generation timestamp difference)
|
Set<ProducerScope> |
getProducerScopes()
Returns a
Set of possible ProducerScope s. |
default RecoveryInfo |
getRecoveryInfo()
Gets the recovery info about last recovery attempt
|
int |
getStatefulRecoveryWindowInMinutes()
Returns the max allowed stateful recovery window in minutes
|
long |
getTimestampForRecovery()
Returns a timestamp which indicates the last known verified time in which the SDK was in sync with the feed.
|
boolean |
isAvailable()
An indication if the producer is available with the token provided with the
UofConfigurationImpl |
boolean |
isEnabled()
An indication if the producer is enabled.
|
boolean |
isFlaggedDown()
An indication if the producer is down/out of sync/invalid state
|
int getId()
String getName()
String getDescription()
long getLastMessageTimestamp()
boolean isAvailable()
UofConfigurationImpl
true
if the producer is available, otherwise false
boolean isEnabled()
isAvailable()
,
but it can be disabled trough the ProducerManager
true
if the producer is enabled, otherwise false
boolean isFlaggedDown()
false
if the producer is up, otherwise true
String getApiUrl()
Set<ProducerScope> getProducerScopes()
Set
of possible ProducerScope
s.
ProducerScope
s indicate what type of event messages will be dispatched by the producer.Set
of possible ProducerScope
slong getLastProcessedMessageGenTimestamp()
long getProcessingQueDelay()
long getTimestampForRecovery()
ProducerManager.setProducerRecoveryFromTimestamp(int, long)
method.int getStatefulRecoveryWindowInMinutes()
default RecoveryInfo getRecoveryInfo()
Copyright © 2016–2025. All rights reserved.