io.confluent.kafka.replication.push.buffer

Class PushReplicationEvent.StopPayload

java.lang.Object

io.confluent.kafka.replication.push.buffer.PushReplicationEvent.StopPayload

Enclosing class:

PushReplicationEvent<T>

public static class PushReplicationEvent.StopPayload
extends Object

A payload for a PushReplicationEvent.Type.STOP_PUSH event, indicating whether the end of the push session should be signalled to the corresponding follower.

Constructor Summary

Constructors

Constructor and Description
StopPayload(boolean sendEndSessionRequest)

Method Summary

Modifier and Type	Method and Description
boolean	sendEndSessionRequest()
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StopPayload

public StopPayload(boolean sendEndSessionRequest)

Method Detail

sendEndSessionRequest

public boolean sendEndSessionRequest()

toString

public String toString()

Overrides:

toString in class Object