equip /
queue
| @@ 32-40 (lines=9) @@ | ||
| 29 | * |
|
| 30 | * @param AbstractOptions $options |
|
| 31 | */ |
|
| 32 | public function acknowledge(AbstractOptions $options) |
|
| 33 | { |
|
| 34 | array_map(function ($name) use ($options) { |
|
| 35 | $this->emitter->emit($name, $options); |
|
| 36 | }, [ |
|
| 37 | static::MESSAGE_ACKNOWLEDGE, |
|
| 38 | sprintf('%s.%s', static::MESSAGE_ACKNOWLEDGE, $options->command()) |
|
| 39 | ]); |
|
| 40 | } |
|
| 41 | ||
| 42 | /** |
|
| 43 | * Emits message finished events |
|
| @@ 47-55 (lines=9) @@ | ||
| 44 | * |
|
| 45 | * @param AbstractOptions $options |
|
| 46 | */ |
|
| 47 | public function finish(AbstractOptions $options) |
|
| 48 | { |
|
| 49 | array_map(function ($name) use ($options) { |
|
| 50 | $this->emitter->emit($name, $options) ; |
|
| 51 | }, [ |
|
| 52 | static::MESSAGE_FINISH, |
|
| 53 | sprintf('%s.%s', static::MESSAGE_FINISH, $options->command()) |
|
| 54 | ]); |
|
| 55 | } |
|
| 56 | ||
| 57 | /** |
|
| 58 | * Emits message rejection events |
|
| @@ 63-71 (lines=9) @@ | ||
| 60 | * @param AbstractOptions $options |
|
| 61 | * @param Exception $exception |
|
| 62 | */ |
|
| 63 | public function reject(AbstractOptions $options, Exception $exception) |
|
| 64 | { |
|
| 65 | array_map(function ($name) use ($options, $exception) { |
|
| 66 | $this->emitter->emit($name, $options, $exception); |
|
| 67 | }, [ |
|
| 68 | static::MESSAGE_REJECT, |
|
| 69 | sprintf('%s.%s', static::MESSAGE_REJECT, $options->command()) |
|
| 70 | ]); |
|
| 71 | } |
|
| 72 | } |
|
| 73 | ||
