Class ConnectedCommitterImpl (1.6.3) 

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

handleInitialResponse(StreamingCommitCursorResponse response)

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

handleStreamResponse(StreamingCommitCursorResponse response)

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