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 ProducerScope s. |
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()
Producer
public String getName()
Producer
public String getDescription()
Producer
getDescription
in interface Producer
public boolean isAvailable()
Producer
UofConfigurationImpl
isAvailable
in interface Producer
true
if the producer is available, otherwise false
public long getLastMessageTimestamp()
Producer
getLastMessageTimestamp
in interface Producer
public boolean isEnabled()
Producer
Producer.isAvailable()
,
but it can be disabled trough the ProducerManager
public boolean isFlaggedDown()
Producer
isFlaggedDown
in interface Producer
false
if the producer is up, otherwise true
public String getApiUrl()
Producer
public Set<ProducerScope> getProducerScopes()
Producer
Set
of possible ProducerScope
s.
ProducerScope
s indicate what type of event messages will be dispatched by the producer.getProducerScopes
in interface Producer
Set
of possible ProducerScope
spublic long getLastProcessedMessageGenTimestamp()
Producer
getLastProcessedMessageGenTimestamp
in interface Producer
public long getProcessingQueDelay()
Producer
getProcessingQueDelay
in interface Producer
public long getTimestampForRecovery()
Producer
ProducerManager.setProducerRecoveryFromTimestamp(int, long)
method.getTimestampForRecovery
in interface Producer
public int getStatefulRecoveryWindowInMinutes()
Producer
getStatefulRecoveryWindowInMinutes
in interface Producer
public RecoveryInfo getRecoveryInfo()
Producer
getRecoveryInfo
in interface Producer
Copyright © 2016–2025. All rights reserved.