@@ 520-532 (lines=13) @@ | ||
517 | * @param int $flags |
|
518 | * @return bool |
|
519 | */ |
|
520 | protected function handleSendAsync($name, $message, $flags = Channel::MODE_DEFAULT) |
|
521 | { |
|
522 | if ($message->getType() === '') |
|
523 | { |
|
524 | $message->setType(Channel::TYPE_SND); |
|
525 | } |
|
526 | if ($message->getDestination() === '') |
|
527 | { |
|
528 | $message->setDestination($name); |
|
529 | } |
|
530 | ||
531 | return $this->getOutput()->handle($name, $message, $flags); |
|
532 | } |
|
533 | ||
534 | /** |
|
535 | * @param string $name |
@@ 509-521 (lines=13) @@ | ||
506 | * @override |
|
507 | * @inheritDoc |
|
508 | */ |
|
509 | protected function handleSendAsync($name, $message, $flags = Channel::MODE_DEFAULT) |
|
510 | { |
|
511 | if ($message->getType() === '') |
|
512 | { |
|
513 | $message->setType(Channel::TYPE_SND); |
|
514 | } |
|
515 | if ($message->getDestination() === '') |
|
516 | { |
|
517 | $message->setDestination($name); |
|
518 | } |
|
519 | ||
520 | return $this->getOutput()->handle($name, $message, $flags); |
|
521 | } |
|
522 | ||
523 | /** |
|
524 | * @override |