| Constructor and Description | 
|---|
ProducerImpl(ProducerData pData)  | 
| 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 ProducerScopes. | 
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 
 | 
String | 
toString()  | 
public ProducerImpl(ProducerData pData)
public int getId()
Producerpublic String getName()
Producerpublic String getDescription()
ProducergetDescription in interface Producerpublic boolean isAvailable()
ProducerUofConfigurationImplisAvailable in interface Producertrue if the producer is available, otherwise falsepublic long getLastMessageTimestamp()
ProducergetLastMessageTimestamp in interface Producerpublic boolean isEnabled()
ProducerProducer.isAvailable(),
 but it can be disabled through the ProducerManagerpublic boolean isFlaggedDown()
ProducerisFlaggedDown in interface Producerfalse if the producer is up, otherwise truepublic String getApiUrl()
Producerpublic Set<ProducerScope> getProducerScopes()
ProducerSet of possible ProducerScopes.
 ProducerScopes indicate what type of event messages will be dispatched by the producer.getProducerScopes in interface ProducerSet of possible ProducerScopespublic long getLastProcessedMessageGenTimestamp()
ProducergetLastProcessedMessageGenTimestamp in interface Producerpublic long getProcessingQueDelay()
ProducergetProcessingQueDelay in interface Producerpublic long getTimestampForRecovery()
ProducerProducerManager.setProducerRecoveryFromTimestamp(int, long) method.getTimestampForRecovery in interface Producerpublic int getStatefulRecoveryWindowInMinutes()
ProducergetStatefulRecoveryWindowInMinutes in interface Producerpublic RecoveryInfo getRecoveryInfo()
ProducergetRecoveryInfo in interface ProducerCopyright © 2016–2025. All rights reserved.