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

Code Duplication Length = 9-9 lines in 3 locations

src/Event.php 3 locations


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

    /**
     * Emits message finished events

     *
     * @param Message $message
     */
    public function finish(Message $message)
    {
        array_map(function ($name) use ($message) {
           $this->emitter->emit($name, $message) ;
        }, [
            static::MESSAGE_FINISH,
            sprintf('%s.%s', static::MESSAGE_FINISH, $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::MESSAGE_REJECT,
            sprintf('%s.%s', static::MESSAGE_REJECT, $message->handler())
        ]);
    }
}


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

equip / queue

Code Duplication Length = 9-9 lines in 3 locations

src/Event.php 3 locations