(ctx context.Context)
| 507 | } |
| 508 | |
| 509 | func (dd *msgpipelineDelivery) Commit(ctx context.Context) error { |
| 510 | dd.close() |
| 511 | |
| 512 | for _, delivery := range dd.deliveries { |
| 513 | if err := delivery.Commit(ctx); err != nil { |
| 514 | // No point in Committing remaining deliveries, everything is broken already. |
| 515 | return err |
| 516 | } |
| 517 | } |
| 518 | return nil |
| 519 | } |
| 520 | |
| 521 | func (dd *msgpipelineDelivery) close() { |
| 522 | dd.checkRunner.close() |