Package com.linkedin.venice.pubsub.mock

Class InMemoryPubSubMessage

java.lang.Object

com.linkedin.venice.pubsub.mock.InMemoryPubSubMessage

public class InMemoryPubSubMessage
extends Object

A single Kafka message, strongly typed for the types that Venice uses.

See Also:

• InMemoryPubSubTopic

Field Summary

Fields

Modifier and Type	Field	Description
final PubSubMessageHeaders	headers
final KafkaKey	key
final KafkaMessageEnvelope	value

Constructor Summary

Constructors

Constructor	Description
InMemoryPubSubMessage(KafkaKey key, KafkaMessageEnvelope value, PubSubMessageHeaders headers)

Method Summary

Modifier and Type	Method	Description
boolean	isPutValueChanged()
void	putValueChanged()

Methods inherited from class java.lang.Object

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

Field Details

key

public final KafkaKey key

value

public final KafkaMessageEnvelope value

headers

public final PubSubMessageHeaders headers

Constructor Details

InMemoryPubSubMessage

public InMemoryPubSubMessage(KafkaKey key,
 KafkaMessageEnvelope value,
 PubSubMessageHeaders headers)

Method Details

isPutValueChanged

public boolean isPutValueChanged()

putValueChanged

public void putValueChanged()