replicationTaskSerializer TaskSerializer,
currentClusterName string,
return &DLQWriterAdapter{
dlqWriter: dlqWriter,
replicationTaskSerializer: replicationTaskSerializer,
currentClusterName: currentClusterName,
}
}
// This creates a new [DLQWriter] that can be toggled between the two implementations.