}
QueueKey: persistence.QueueKey{
QueueType: persistence.QueueTypeHistoryDLQ,
Category: category,
SourceCluster: req.DlqKey.SourceCluster,
TargetCluster: req.DlqKey.TargetCluster,
},
InclusiveMaxMessageMetadata: persistence.MessageMetadata{
ID: req.InclusiveMaxTaskMetadata.MessageId,
},
})
if err != nil {
return nil, err
}