Code Duplication    Length = 285-285 lines in 2 locations

Transport/Rpc/RpcQueueBag.php 1 location

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

Transport/Worker/WorkerQueueBag.php 1 location

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