Code Duplication - equip/queue - Measure and Improve Code Quality continuously with Scrutinizer

queue

Code Duplication Length = 9-9 lines in 2 locations

src/Event.php 2 locations


     *
     * @param Message $message
     */
    public function acknowledge(Message $message)
    {
        array_map(function ($name) use ($message) {
            $this->emitter->emit($name, $message);
        }, [
            static::QUEUE_ACKNOWLEDGE,
            sprintf('%s.%s', static::QUEUE_ACKNOWLEDGE, $message->handler())
        ]);
    }

    /**
     * Emits message rejection events

     * @param Message $message
     * @param Exception $exception
     */
    public function reject(Message $message, Exception $exception)
    {
        array_map(function ($name) use ($message, $exception) {
            $this->emitter->emit($name, $message, $exception);
        }, [
            static::QUEUE_REJECT,
            sprintf('%s.%s', static::QUEUE_REJECT, $message->handler())
        ]);
    }
}


		@@ 31-39 (lines=9) @@
28		*
29		* @param Message $message
30		*/
31		public function acknowledge(Message $message)
32		{
33		array_map(function ($name) use ($message) {
34		$this->emitter->emit($name, $message);
35		}, [
36		static::QUEUE_ACKNOWLEDGE,
37		sprintf('%s.%s', static::QUEUE_ACKNOWLEDGE, $message->handler())
38		]);
39		}
40
41		/**
42		* Emits message rejection events
		@@ 47-55 (lines=9) @@
44		* @param Message $message
45		* @param Exception $exception
46		*/
47		public function reject(Message $message, Exception $exception)
48		{
49		array_map(function ($name) use ($message, $exception) {
50		$this->emitter->emit($name, $message, $exception);
51		}, [
52		static::QUEUE_REJECT,
53		sprintf('%s.%s', static::QUEUE_REJECT, $message->handler())
54		]);
55		}
56		}
57

equip / queue

Code Duplication Length = 9-9 lines in 2 locations

src/Event.php 2 locations