59
60
// NewExecutionManagerDLQWriter creates a new DLQWriter that uses the [ExecutionManager].
61
>
func NewExecutionManagerDLQWriter(executionManager ExecutionManager) *executionManagerDLQWriter {
dlq_writer.go
62
>
return &executionManagerDLQWriter{
63
>
executionManager: executionManager,
64
>
}
65
>
}
66
67
// NewDLQWriterAdapter creates a new DLQWriter from a QueueV2 [queues.DLQWriter].