Class ConnectedCommitterImpl

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

handleInitialResponse(StreamingCommitCursorResponse response)

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

handleStreamResponse(StreamingCommitCursorResponse response)

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