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  Setof possibleProducerScopes. | 
| 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()
UofConfigurationImpltrue if the producer is available, otherwise falseboolean isEnabled()
isAvailable(),
 but it can be disabled through the ProducerManagertrue if the producer is enabled, otherwise falseboolean isFlaggedDown()
false if the producer is up, otherwise trueString getApiUrl()
Set<ProducerScope> getProducerScopes()
Set of possible ProducerScopes.
 ProducerScopes indicate what type of event messages will be dispatched by the producer.Set of possible ProducerScopeslong getLastProcessedMessageGenTimestamp()
long getProcessingQueDelay()
long getTimestampForRecovery()
ProducerManager.setProducerRecoveryFromTimestamp(int, long) method.int getStatefulRecoveryWindowInMinutes()
default RecoveryInfo getRecoveryInfo()
Copyright © 2016–2025. All rights reserved.