150
}
151
153
>
tm.data.Stop()
154
>
155
>
tm.priorityBacklogForwarders.Sync(nil, nil)
156
>
157
>
// When we're stopping, sync tasks and pollers will be cancelled by tqCtx being canceled.
158
>
// Backlog tasks held in this matcher will be dropped. That's okay if we're stopping the
159
>
// whole partition, or for tasks that came from this partition's readers. The exception is
160
>
// backlog tasks that were redirected from another versioned queue (or the default). To
161
>
// handle those, the caller of Stop should also call ReprocessRedirectedTasksAfterStop
162
>
// when applicable.
163
>
}
164
165
// TODO(pri): access to retrier is not synchronized