Class ConnectedCommitterImpl (1.12.16)

public class ConnectedCommitterImpl extends SingleConnection<StreamingCommitCursorRequest,StreamingCommitCursorResponse,SequencedCommitCursorResponse> implements ConnectedCommitter

Inheritance

java.lang.Object > SingleConnection > ConnectedCommitterImpl

Implements

com.google.cloud.pubsublite.internal.wire.ConnectedCommitter

Methods

commit(Offset offset)

public void commit(Offset offset)
Parameter
NameDescription
offsetOffset

handleStreamResponse(StreamingCommitCursorResponse response)

protected void handleStreamResponse(StreamingCommitCursorResponse response)
Parameter
NameDescription
responseStreamingCommitCursorResponse
Overrides
Exceptions
TypeDescription
CheckedApiException