Package com.linkedin.davinci.kafka.consumer

Class PubSubMessageProcessedResultWrapper<K,V,OFFSET>

java.lang.Object

com.linkedin.davinci.kafka.consumer.PubSubMessageProcessedResultWrapper<K,V,OFFSET>

public class PubSubMessageProcessedResultWrapper<K,V,OFFSET>
extends Object

Constructor Summary

Constructors

Constructor	Description
PubSubMessageProcessedResultWrapper(PubSubMessage<K,V,OFFSET> message)

Method Summary

Modifier and Type	Method	Description
PubSubMessage<K,V,OFFSET>	getMessage()
PubSubMessageProcessedResult	getProcessedResult()
void	setProcessedResult(PubSubMessageProcessedResult processedResult)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PubSubMessageProcessedResultWrapper

public PubSubMessageProcessedResultWrapper(PubSubMessage<K,V,OFFSET> message)

Method Details

getMessage

public PubSubMessage<K,V,OFFSET> getMessage()

getProcessedResult

public PubSubMessageProcessedResult getProcessedResult()

setProcessedResult

public void setProcessedResult(PubSubMessageProcessedResult processedResult)