File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
yt/yt/client/queue_client Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -352,8 +352,8 @@ class TProducerSession
352
352
return transaction->Commit ();
353
353
}))
354
354
.Apply (BIND ([this , this_ = MakeStrong (this )] (const TTransactionCommitResult&) {
355
- if (Options_.AcknowledgmentCallback ) {
356
- Options_.AcknowledgmentCallback (LastSequenceNumber_);
355
+ if (Options_.AckCallback ) {
356
+ Options_.AckCallback (LastSequenceNumber_);
357
357
}
358
358
}));
359
359
})).AsVoid ();
Original file line number Diff line number Diff line change @@ -47,7 +47,7 @@ struct TProducerSessionOptions
47
47
TBackoffStrategy BackoffStrategy = TBackoffStrategy(TExponentialBackoffOptions{});
48
48
49
49
// ! Acknowledgment callback.
50
- TAckCallback AcknowledgmentCallback ;
50
+ TAckCallback AckCallback ;
51
51
};
52
52
53
53
struct IProducerSession
@@ -67,6 +67,7 @@ struct IProducerSession
67
67
// ! Cancel writing of all not flushed rows.
68
68
virtual void Cancel () = 0;
69
69
};
70
+
70
71
DEFINE_REFCOUNTED_TYPE (IProducerSession)
71
72
72
73
// //////////////////////////////////////////////////////////////////////////////
You can’t perform that action at this time.
0 commit comments