270
_, _ = fmt.Fprintf(c.App.Writer, "Found last message ID: %d. Using this as the upper bound for merge operation.\n", lastMessageID)
271
}
273
>
defer cancel()
274
>
275
>
response, err := adminClient.MergeDLQTasks(ctx, &adminservice.MergeDLQTasksRequest{
276
>
DlqKey: ac.getDLQKey(),
277
>
InclusiveMaxTaskMetadata: &commonspb.HistoryDLQTaskMetadata{
278
>
MessageId: lastMessageID,
279
>
},
280
>
BatchSize: int32(c.Int(FlagPageSize)), // let the server handle validation and defaulting of batch size.
281
>
})
282
>
if err != nil {
283
return fmt.Errorf("call to MergeDLQTasks failed: %w", err)
284
}