Class ConnectedCommitterImpl (1.14.1)

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
Name Description
offset Offset

handleStreamResponse(StreamingCommitCursorResponse response)

protected void handleStreamResponse(StreamingCommitCursorResponse response)
Parameter
Name Description
response StreamingCommitCursorResponse
Overrides
Exceptions
Type Description
CheckedApiException