Code Duplication - contamobi/CmobiRabbitmqBundle - Measure and Improve Code Quality continuously with Scrutinizer

Code Duplication Length = 285-285 lines in 2 locations

Transport/Rpc/RpcQueueBag.php 1 location



use Cmobi\RabbitmqBundle\Queue\QueueBagInterface;

class RpcQueueBag implements QueueBagInterface
{
    private $options;

    public function __construct(
        $queue,
        $basicQos = 1,
        $passive = false,
        $durable = false,
        $exclusive = false,
        $autoDelete = true,
        $noWait = false,
        array $arguments = null,
        $ticket = null,
        $consumerTag = '',
        $noAck = false,
        $noLocal = false
    )
    {
        $this->options = [
            'queue' => $queue,
            'basic_qos' => $basicQos,
            'passive' => $passive,
            'durable' => $durable,
            'exclusive' => $exclusive,
            'auto_delete' => $autoDelete,
            'no_wait' => $noWait,
            'arguments' => $arguments,
            'ticket' => $ticket,
            'consumer_tag' => $consumerTag,
            'no_ack' => $noAck,
            'no_local' => $noLocal
        ];
    }

    /**
     * @param $queue
     */
    public function setQueue($queue)
    {
        $this->options['queue'] = $queue;
    }

    /**
     * @return string|mixed
     */
    public function getQueue()
    {
        return $this->options['queue'];
    }

    /**
     * @param $qos
     */
    public function setBasicQos($qos)
    {
        $this->options['basic_qos'] = $qos;
    }

    /**
     * @return int
     */
    public function getBasicQos()
    {
        return $this->options['basic_qos'];
    }

    /**
     * @param $passive
     */
    public function setPassive($passive)
    {
        $this->options['passive'] = $passive;
    }

    /**
     * @return bool
     */
    public function getPassive()
    {
        return $this->options['passive'];
    }

    /**
     * @param $durable
     */
    public function setDurable($durable)
    {
        $this->options['durable'] = $durable;
    }

    /**
     * @return bool
     */
    public function getDurable()
    {
        return $this->options['durable'];
    }

    /**
     * @param $exclusive
     */
    public function setExclusive($exclusive)
    {
        $this->options['exclusive'] = $exclusive;
    }

    /**
     * @return bool
     */
    public function getExclusive()
    {
        return $this->options['exclusive'];
    }

    /**
     * @param $autoDelete
     */
    public function setAutoDelete($autoDelete)
    {
        $this->options['auto_delete'] = $autoDelete;
    }

    /**
     * @return bool
     */
    public function getAutoDelete()
    {
        return $this->options['auto_delete'];
    }

    /**
     * @param $noWait
     */
    public function setNoWait($noWait)
    {
        $this->options['no_wait'] = $noWait;
    }

    /**
     * @return bool
     */
    public function getNoWait()
    {
        return $this->options['no_wait'];
    }

    /**
     * @param array $arguments
     */
    public function setArguments(array $arguments)
    {
        $this->options['arguments'] = $arguments;
    }

    /**
     * @return string
     */
    public function getArguments()
    {
        return $this->options['arguments'];
    }

    /**
     * @param $ticket
     */
    public function setTicket($ticket)
    {
        $this->options['ticket'] = $ticket;
    }

    /**
     * @return string
     */
    public function getTicket()
    {
        return $this->options['ticket'];
    }

    /**
     * @param $consumerTag
     */
    public function setConsumerTag($consumerTag)
    {
        $this->options['consumer_tag'] = $consumerTag;
    }

    /**
     * @return string
     */
    public function getConsumerTag()
    {
        return $this->options['consumer_tag'];
    }

    /**
     * @param $noAck
     */
    public function setNoAck($noAck)
    {
        $this->options['no_ack'] = $noAck;
    }

    /**
     * @return bool
     */
    public function getNoAck()
    {
        return $this->options['no_ack'];
    }

    /**
     * @param $noLocal
     */
    public function setNoLocal($noLocal)
    {
        $this->options['no_local'] = $noLocal;
    }

    /**
     * @return bool
     */
    public function getNoLocal()
    {
        return $this->options['no_local'];
    }

    /**
     * @return array
     */
    public function getQueueDeclare()
    {
        return [
            $this->getQueue(),
            $this->getPassive(),
            $this->getDurable(),
            $this->getExclusive(),
            $this->getAutoDelete(),
            $this->getNoWait(),
            $this->getArguments(),
            $this->getTicket()
        ];
    }

    /**
     * @return array
     */
    public function getQueueConsume()
    {
        return [
            $this->getQueue(),
            $this->getConsumerTag(),
            $this->getNoLocal(),
            $this->getNoAck(),
            $this->getExclusive(),
            $this->getNoWait(),
            $this->getTicket(),
            $this->getArguments()
        ];
    }

    /**
     * @return array|false
     */
    public function getExchangeDeclare()
    {
        return false;
    }

    /**
     * @return string
     */
    public function getExchange()
    {
        return false;
    }

    /**
     * @return string
     */
    public function getType()
    {
        return false;
    }
}

Transport/Worker/WorkerQueueBag.php 1 location



use Cmobi\RabbitmqBundle\Queue\QueueBagInterface;

class WorkerQueueBag implements QueueBagInterface
{
    private $options;

    public function __construct(
        $queue,
        $basicQos = 1,
        $passive = false,
        $durable = true,
        $exclusive = false,
        $autoDelete = false,
        $noWait = false,
        array $arguments = null,
        $ticket = null,
        $consumerTag = '',
        $noAck = false,
        $noLocal = false
    )
    {
        $this->options = [
            'queue' => $queue,
            'basic_qos' => $basicQos,
            'passive' => $passive,
            'durable' => $durable,
            'exclusive' => $exclusive,
            'auto_delete' => $autoDelete,
            'no_wait' => $noWait,
            'arguments' => $arguments,
            'ticket' => $ticket,
            'consumer_tag' => $consumerTag,
            'no_ack' => $noAck,
            'no_local' => $noLocal
        ];
    }

    /**
     * @param $queue
     */
    public function setQueue($queue)
    {
        $this->options['queue'] = $queue;
    }

    /**
     * @return string|mixed
     */
    public function getQueue()
    {
        return $this->options['queue'];
    }

    /**
     * @param $qos
     */
    public function setBasicQos($qos)
    {
        $this->options['basic_qos'] = $qos;
    }

    /**
     * @return int
     */
    public function getBasicQos()
    {
        return $this->options['basic_qos'];
    }

    /**
     * @param $passive
     */
    public function setPassive($passive)
    {
        $this->options['passive'] = $passive;
    }

    /**
     * @return bool
     */
    public function getPassive()
    {
        return $this->options['passive'];
    }

    /**
     * @param $durable
     */
    public function setDurable($durable)
    {
        $this->options['durable'] = $durable;
    }

    /**
     * @return bool
     */
    public function getDurable()
    {
        return $this->options['durable'];
    }

    /**
     * @param $exclusive
     */
    public function setExclusive($exclusive)
    {
        $this->options['exclusive'] = $exclusive;
    }

    /**
     * @return bool
     */
    public function getExclusive()
    {
        return $this->options['exclusive'];
    }

    /**
     * @param $autoDelete
     */
    public function setAutoDelete($autoDelete)
    {
        $this->options['auto_delete'] = $autoDelete;
    }

    /**
     * @return bool
     */
    public function getAutoDelete()
    {
        return $this->options['auto_delete'];
    }

    /**
     * @param $noWait
     */
    public function setNoWait($noWait)
    {
        $this->options['no_wait'] = $noWait;
    }

    /**
     * @return bool
     */
    public function getNoWait()
    {
        return $this->options['no_wait'];
    }

    /**
     * @param array $arguments
     */
    public function setArguments(array $arguments)
    {
        $this->options['arguments'] = $arguments;
    }

    /**
     * @return string
     */
    public function getArguments()
    {
        return $this->options['arguments'];
    }

    /**
     * @param $ticket
     */
    public function setTicket($ticket)
    {
        $this->options['ticket'] = $ticket;
    }

    /**
     * @return string
     */
    public function getTicket()
    {
        return $this->options['ticket'];
    }

    /**
     * @param $consumerTag
     */
    public function setConsumerTag($consumerTag)
    {
        $this->options['consumer_tag'] = $consumerTag;
    }

    /**
     * @return string
     */
    public function getConsumerTag()
    {
        return $this->options['consumer_tag'];
    }

    /**
     * @param $noAck
     */
    public function setNoAck($noAck)
    {
        $this->options['no_ack'] = $noAck;
    }

    /**
     * @return bool
     */
    public function getNoAck()
    {
        return $this->options['no_ack'];
    }

    /**
     * @param $noLocal
     */
    public function setNoLocal($noLocal)
    {
        $this->options['no_local'] = $noLocal;
    }

    /**
     * @return bool
     */
    public function getNoLocal()
    {
        return $this->options['no_local'];
    }

    /**
     * @return array
     */
    public function getQueueDeclare()
    {
        return [
            $this->getQueue(),
            $this->getPassive(),
            $this->getDurable(),
            $this->getExclusive(),
            $this->getAutoDelete(),
            $this->getNoWait(),
            $this->getArguments(),
            $this->getTicket()
        ];
    }

    /**
     * @return array
     */
    public function getQueueConsume()
    {
        return [
            $this->getQueue(),
            $this->getConsumerTag(),
            $this->getNoLocal(),
            $this->getNoAck(),
            $this->getExclusive(),
            $this->getNoWait(),
            $this->getTicket(),
            $this->getArguments()
        ];
    }

    /**
     * @return array|false
     */
    public function getExchangeDeclare()
    {
        return false;
    }

    /**
     * @return string
     */
    public function getExchange()
    {
        return false;
    }

    /**
     * @return string
     */
    public function getType()
    {
        return false;
    }
}

		@@ 7-291 (lines=285) @@
4
5		use Cmobi\RabbitmqBundle\Queue\QueueBagInterface;
6
7		class RpcQueueBag implements QueueBagInterface
8		{
9		private $options;
10
11		public function __construct(
12		$queue,
13		$basicQos = 1,
14		$passive = false,
15		$durable = false,
16		$exclusive = false,
17		$autoDelete = true,
18		$noWait = false,
19		array $arguments = null,
20		$ticket = null,
21		$consumerTag = '',
22		$noAck = false,
23		$noLocal = false
24		)
25		{
26		$this->options = [
27		'queue' => $queue,
28		'basic_qos' => $basicQos,
29		'passive' => $passive,
30		'durable' => $durable,
31		'exclusive' => $exclusive,
32		'auto_delete' => $autoDelete,
33		'no_wait' => $noWait,
34		'arguments' => $arguments,
35		'ticket' => $ticket,
36		'consumer_tag' => $consumerTag,
37		'no_ack' => $noAck,
38		'no_local' => $noLocal
39		];
40		}
41
42		/**
43		* @param $queue
44		*/
45		public function setQueue($queue)
46		{
47		$this->options['queue'] = $queue;
48		}
49
50		/**
51		* @return string\|mixed
52		*/
53		public function getQueue()
54		{
55		return $this->options['queue'];
56		}
57
58		/**
59		* @param $qos
60		*/
61		public function setBasicQos($qos)
62		{
63		$this->options['basic_qos'] = $qos;
64		}
65
66		/**
67		* @return int
68		*/
69		public function getBasicQos()
70		{
71		return $this->options['basic_qos'];
72		}
73
74		/**
75		* @param $passive
76		*/
77		public function setPassive($passive)
78		{
79		$this->options['passive'] = $passive;
80		}
81
82		/**
83		* @return bool
84		*/
85		public function getPassive()
86		{
87		return $this->options['passive'];
88		}
89
90		/**
91		* @param $durable
92		*/
93		public function setDurable($durable)
94		{
95		$this->options['durable'] = $durable;
96		}
97
98		/**
99		* @return bool
100		*/
101		public function getDurable()
102		{
103		return $this->options['durable'];
104		}
105
106		/**
107		* @param $exclusive
108		*/
109		public function setExclusive($exclusive)
110		{
111		$this->options['exclusive'] = $exclusive;
112		}
113
114		/**
115		* @return bool
116		*/
117		public function getExclusive()
118		{
119		return $this->options['exclusive'];
120		}
121
122		/**
123		* @param $autoDelete
124		*/
125		public function setAutoDelete($autoDelete)
126		{
127		$this->options['auto_delete'] = $autoDelete;
128		}
129
130		/**
131		* @return bool
132		*/
133		public function getAutoDelete()
134		{
135		return $this->options['auto_delete'];
136		}
137
138		/**
139		* @param $noWait
140		*/
141		public function setNoWait($noWait)
142		{
143		$this->options['no_wait'] = $noWait;
144		}
145
146		/**
147		* @return bool
148		*/
149		public function getNoWait()
150		{
151		return $this->options['no_wait'];
152		}
153
154		/**
155		* @param array $arguments
156		*/
157		public function setArguments(array $arguments)
158		{
159		$this->options['arguments'] = $arguments;
160		}
161
162		/**
163		* @return string
164		*/
165		public function getArguments()
166		{
167		return $this->options['arguments'];
168		}
169
170		/**
171		* @param $ticket
172		*/
173		public function setTicket($ticket)
174		{
175		$this->options['ticket'] = $ticket;
176		}
177
178		/**
179		* @return string
180		*/
181		public function getTicket()
182		{
183		return $this->options['ticket'];
184		}
185
186		/**
187		* @param $consumerTag
188		*/
189		public function setConsumerTag($consumerTag)
190		{
191		$this->options['consumer_tag'] = $consumerTag;
192		}
193
194		/**
195		* @return string
196		*/
197		public function getConsumerTag()
198		{
199		return $this->options['consumer_tag'];
200		}
201
202		/**
203		* @param $noAck
204		*/
205		public function setNoAck($noAck)
206		{
207		$this->options['no_ack'] = $noAck;
208		}
209
210		/**
211		* @return bool
212		*/
213		public function getNoAck()
214		{
215		return $this->options['no_ack'];
216		}
217
218		/**
219		* @param $noLocal
220		*/
221		public function setNoLocal($noLocal)
222		{
223		$this->options['no_local'] = $noLocal;
224		}
225
226		/**
227		* @return bool
228		*/
229		public function getNoLocal()
230		{
231		return $this->options['no_local'];
232		}
233
234		/**
235		* @return array
236		*/
237		public function getQueueDeclare()
238		{
239		return [
240		$this->getQueue(),
241		$this->getPassive(),
242		$this->getDurable(),
243		$this->getExclusive(),
244		$this->getAutoDelete(),
245		$this->getNoWait(),
246		$this->getArguments(),
247		$this->getTicket()
248		];
249		}
250
251		/**
252		* @return array
253		*/
254		public function getQueueConsume()
255		{
256		return [
257		$this->getQueue(),
258		$this->getConsumerTag(),
259		$this->getNoLocal(),
260		$this->getNoAck(),
261		$this->getExclusive(),
262		$this->getNoWait(),
263		$this->getTicket(),
264		$this->getArguments()
265		];
266		}
267
268		/**
269		* @return array\|false
270		*/
271		public function getExchangeDeclare()
272		{
273		return false;
274		}
275
276		/**
277		* @return string
278		*/
279		public function getExchange()
280		{
281		return false;
282		}
283
284		/**
285		* @return string
286		*/
287		public function getType()
288		{
289		return false;
290		}
291		}

		@@ 7-291 (lines=285) @@
4
5		use Cmobi\RabbitmqBundle\Queue\QueueBagInterface;
6
7		class WorkerQueueBag implements QueueBagInterface
8		{
9		private $options;
10
11		public function __construct(
12		$queue,
13		$basicQos = 1,
14		$passive = false,
15		$durable = true,
16		$exclusive = false,
17		$autoDelete = false,
18		$noWait = false,
19		array $arguments = null,
20		$ticket = null,
21		$consumerTag = '',
22		$noAck = false,
23		$noLocal = false
24		)
25		{
26		$this->options = [
27		'queue' => $queue,
28		'basic_qos' => $basicQos,
29		'passive' => $passive,
30		'durable' => $durable,
31		'exclusive' => $exclusive,
32		'auto_delete' => $autoDelete,
33		'no_wait' => $noWait,
34		'arguments' => $arguments,
35		'ticket' => $ticket,
36		'consumer_tag' => $consumerTag,
37		'no_ack' => $noAck,
38		'no_local' => $noLocal
39		];
40		}
41
42		/**
43		* @param $queue
44		*/
45		public function setQueue($queue)
46		{
47		$this->options['queue'] = $queue;
48		}
49
50		/**
51		* @return string\|mixed
52		*/
53		public function getQueue()
54		{
55		return $this->options['queue'];
56		}
57
58		/**
59		* @param $qos
60		*/
61		public function setBasicQos($qos)
62		{
63		$this->options['basic_qos'] = $qos;
64		}
65
66		/**
67		* @return int
68		*/
69		public function getBasicQos()
70		{
71		return $this->options['basic_qos'];
72		}
73
74		/**
75		* @param $passive
76		*/
77		public function setPassive($passive)
78		{
79		$this->options['passive'] = $passive;
80		}
81
82		/**
83		* @return bool
84		*/
85		public function getPassive()
86		{
87		return $this->options['passive'];
88		}
89
90		/**
91		* @param $durable
92		*/
93		public function setDurable($durable)
94		{
95		$this->options['durable'] = $durable;
96		}
97
98		/**
99		* @return bool
100		*/
101		public function getDurable()
102		{
103		return $this->options['durable'];
104		}
105
106		/**
107		* @param $exclusive
108		*/
109		public function setExclusive($exclusive)
110		{
111		$this->options['exclusive'] = $exclusive;
112		}
113
114		/**
115		* @return bool
116		*/
117		public function getExclusive()
118		{
119		return $this->options['exclusive'];
120		}
121
122		/**
123		* @param $autoDelete
124		*/
125		public function setAutoDelete($autoDelete)
126		{
127		$this->options['auto_delete'] = $autoDelete;
128		}
129
130		/**
131		* @return bool
132		*/
133		public function getAutoDelete()
134		{
135		return $this->options['auto_delete'];
136		}
137
138		/**
139		* @param $noWait
140		*/
141		public function setNoWait($noWait)
142		{
143		$this->options['no_wait'] = $noWait;
144		}
145
146		/**
147		* @return bool
148		*/
149		public function getNoWait()
150		{
151		return $this->options['no_wait'];
152		}
153
154		/**
155		* @param array $arguments
156		*/
157		public function setArguments(array $arguments)
158		{
159		$this->options['arguments'] = $arguments;
160		}
161
162		/**
163		* @return string
164		*/
165		public function getArguments()
166		{
167		return $this->options['arguments'];
168		}
169
170		/**
171		* @param $ticket
172		*/
173		public function setTicket($ticket)
174		{
175		$this->options['ticket'] = $ticket;
176		}
177
178		/**
179		* @return string
180		*/
181		public function getTicket()
182		{
183		return $this->options['ticket'];
184		}
185
186		/**
187		* @param $consumerTag
188		*/
189		public function setConsumerTag($consumerTag)
190		{
191		$this->options['consumer_tag'] = $consumerTag;
192		}
193
194		/**
195		* @return string
196		*/
197		public function getConsumerTag()
198		{
199		return $this->options['consumer_tag'];
200		}
201
202		/**
203		* @param $noAck
204		*/
205		public function setNoAck($noAck)
206		{
207		$this->options['no_ack'] = $noAck;
208		}
209
210		/**
211		* @return bool
212		*/
213		public function getNoAck()
214		{
215		return $this->options['no_ack'];
216		}
217
218		/**
219		* @param $noLocal
220		*/
221		public function setNoLocal($noLocal)
222		{
223		$this->options['no_local'] = $noLocal;
224		}
225
226		/**
227		* @return bool
228		*/
229		public function getNoLocal()
230		{
231		return $this->options['no_local'];
232		}
233
234		/**
235		* @return array
236		*/
237		public function getQueueDeclare()
238		{
239		return [
240		$this->getQueue(),
241		$this->getPassive(),
242		$this->getDurable(),
243		$this->getExclusive(),
244		$this->getAutoDelete(),
245		$this->getNoWait(),
246		$this->getArguments(),
247		$this->getTicket()
248		];
249		}
250
251		/**
252		* @return array
253		*/
254		public function getQueueConsume()
255		{
256		return [
257		$this->getQueue(),
258		$this->getConsumerTag(),
259		$this->getNoLocal(),
260		$this->getNoAck(),
261		$this->getExclusive(),
262		$this->getNoWait(),
263		$this->getTicket(),
264		$this->getArguments()
265		];
266		}
267
268		/**
269		* @return array\|false
270		*/
271		public function getExchangeDeclare()
272		{
273		return false;
274		}
275
276		/**
277		* @return string
278		*/
279		public function getExchange()
280		{
281		return false;
282		}
283
284		/**
285		* @return string
286		*/
287		public function getType()
288		{
289		return false;
290		}
291		}

contamobi / CmobiRabbitmqBundle

Code Duplication Length = 285-285 lines in 2 locations

Transport/Rpc/RpcQueueBag.php 1 location

Transport/Worker/WorkerQueueBag.php 1 location