Code Duplication    Length = 13-13 lines in 2 locations

src/Channel/ChannelComposite.php 1 location

@@ 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

src/Channel/Channel.php 1 location

@@ 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