1 | <?php declare(strict_types=1); |
||
20 | abstract class Queue extends AbstractResource implements QueueInterface |
||
21 | { |
||
22 | /** |
||
23 | * @var int |
||
24 | */ |
||
25 | protected $memory; |
||
26 | |||
27 | /** |
||
28 | * @var MessageStats |
||
29 | */ |
||
30 | protected $message_stats; |
||
31 | |||
32 | /** |
||
33 | * @var int |
||
34 | */ |
||
35 | protected $messages; |
||
36 | |||
37 | /** |
||
38 | * @var Details |
||
39 | */ |
||
40 | protected $messages_details; |
||
41 | |||
42 | /** |
||
43 | * @var int |
||
44 | */ |
||
45 | protected $messages_ready; |
||
46 | |||
47 | /** |
||
48 | * @var Details |
||
49 | */ |
||
50 | protected $messages_ready_details; |
||
51 | |||
52 | /** |
||
53 | * @var int |
||
54 | */ |
||
55 | protected $messages_unacknowledged; |
||
56 | |||
57 | /** |
||
58 | * @var Details |
||
59 | */ |
||
60 | protected $messages_unacknowledged_details; |
||
61 | |||
62 | /** |
||
63 | * @var DateTime |
||
64 | */ |
||
65 | protected $idle_since; |
||
66 | |||
67 | /** |
||
68 | * @var mixed |
||
69 | */ |
||
70 | protected $consumer_utilisation; |
||
71 | |||
72 | /** |
||
73 | * @var mixed |
||
74 | */ |
||
75 | protected $policy; |
||
76 | |||
77 | /** |
||
78 | * @var mixed |
||
79 | */ |
||
80 | protected $exclusive_consumer_tag; |
||
81 | |||
82 | /** |
||
83 | * @var int |
||
84 | */ |
||
85 | protected $consumers; |
||
86 | |||
87 | /** |
||
88 | * @var mixed |
||
89 | */ |
||
90 | protected $recoverable_slaves; |
||
91 | |||
92 | /** |
||
93 | * @var string |
||
94 | */ |
||
95 | protected $state; |
||
96 | |||
97 | /** |
||
98 | * @var int |
||
99 | */ |
||
100 | protected $messages_ram; |
||
101 | |||
102 | /** |
||
103 | * @var int |
||
104 | */ |
||
105 | protected $messages_ready_ram; |
||
106 | |||
107 | /** |
||
108 | * @var int |
||
109 | */ |
||
110 | protected $messages_unacknowledged_ram; |
||
111 | |||
112 | /** |
||
113 | * @var int |
||
114 | */ |
||
115 | protected $messages_persistent; |
||
116 | |||
117 | /** |
||
118 | * @var int |
||
119 | */ |
||
120 | protected $message_bytes; |
||
121 | |||
122 | /** |
||
123 | * @var int |
||
124 | */ |
||
125 | protected $message_bytes_ready; |
||
126 | |||
127 | /** |
||
128 | * @var int |
||
129 | */ |
||
130 | protected $message_bytes_unacknowledged; |
||
131 | |||
132 | /** |
||
133 | * @var int |
||
134 | */ |
||
135 | protected $message_bytes_ram; |
||
136 | |||
137 | /** |
||
138 | * @var int |
||
139 | */ |
||
140 | protected $message_bytes_persistent; |
||
141 | |||
142 | /** |
||
143 | * @var DateTime |
||
144 | */ |
||
145 | protected $head_message_timestamp; |
||
146 | |||
147 | /** |
||
148 | * @var int |
||
149 | */ |
||
150 | protected $disk_reads; |
||
151 | |||
152 | /** |
||
153 | * @var int |
||
154 | */ |
||
155 | protected $disk_writes; |
||
156 | |||
157 | /** |
||
158 | * @var Queue\BackingQueueStatus |
||
159 | */ |
||
160 | protected $backing_queue_status; |
||
161 | |||
162 | /** |
||
163 | * @var string |
||
164 | */ |
||
165 | protected $name; |
||
166 | |||
167 | /** |
||
168 | * @var string |
||
169 | */ |
||
170 | protected $vhost; |
||
171 | |||
172 | /** |
||
173 | * @var bool |
||
174 | */ |
||
175 | protected $durable; |
||
176 | |||
177 | /** |
||
178 | * @var bool |
||
179 | */ |
||
180 | protected $auto_delete; |
||
181 | |||
182 | /** |
||
183 | * @var bool |
||
184 | */ |
||
185 | protected $exclusive; |
||
186 | |||
187 | /** |
||
188 | * @var array |
||
189 | */ |
||
190 | protected $arguments; |
||
191 | |||
192 | /** |
||
193 | * @var string |
||
194 | */ |
||
195 | protected $node; |
||
196 | |||
197 | /** |
||
198 | * @return int |
||
199 | */ |
||
200 | 4 | public function memory(): int |
|
204 | |||
205 | /** |
||
206 | * @return MessageStats |
||
207 | */ |
||
208 | public function messageStats(): MessageStats |
||
212 | |||
213 | /** |
||
214 | * @return int |
||
215 | */ |
||
216 | 4 | public function messages(): int |
|
220 | |||
221 | /** |
||
222 | * @return Details |
||
223 | */ |
||
224 | public function messagesDetails(): Details |
||
228 | |||
229 | /** |
||
230 | * @return int |
||
231 | */ |
||
232 | 4 | public function messagesReady(): int |
|
236 | |||
237 | /** |
||
238 | * @return Details |
||
239 | */ |
||
240 | public function messagesReadyDetails(): Details |
||
244 | |||
245 | /** |
||
246 | * @return int |
||
247 | */ |
||
248 | 4 | public function messagesUnacknowledged(): int |
|
252 | |||
253 | /** |
||
254 | * @return Details |
||
255 | */ |
||
256 | public function messagesUnacknowledgedDetails(): Details |
||
260 | |||
261 | /** |
||
262 | * @return DateTime |
||
263 | */ |
||
264 | public function idleSince(): DateTime |
||
268 | |||
269 | /** |
||
270 | * @return mixed |
||
271 | */ |
||
272 | public function consumerUtilisation(): mixed |
||
276 | |||
277 | /** |
||
278 | * @return mixed |
||
279 | */ |
||
280 | public function policy(): mixed |
||
284 | |||
285 | /** |
||
286 | * @return mixed |
||
287 | */ |
||
288 | public function exclusiveConsumerTag(): mixed |
||
292 | |||
293 | /** |
||
294 | * @return int |
||
295 | */ |
||
296 | 4 | public function consumers(): int |
|
300 | |||
301 | /** |
||
302 | * @return mixed |
||
303 | */ |
||
304 | public function recoverableSlaves(): mixed |
||
308 | |||
309 | /** |
||
310 | * @return string |
||
311 | */ |
||
312 | 4 | public function state(): string |
|
316 | |||
317 | /** |
||
318 | * @return int |
||
319 | */ |
||
320 | 4 | public function messagesRam(): int |
|
324 | |||
325 | /** |
||
326 | * @return int |
||
327 | */ |
||
328 | 4 | public function messagesReadyRam(): int |
|
332 | |||
333 | /** |
||
334 | * @return int |
||
335 | */ |
||
336 | 4 | public function messagesUnacknowledgedRam(): int |
|
340 | |||
341 | /** |
||
342 | * @return int |
||
343 | */ |
||
344 | 4 | public function messagesPersistent(): int |
|
348 | |||
349 | /** |
||
350 | * @return int |
||
351 | */ |
||
352 | 4 | public function messageBytes(): int |
|
356 | |||
357 | /** |
||
358 | * @return int |
||
359 | */ |
||
360 | 4 | public function messageBytesReady(): int |
|
364 | |||
365 | /** |
||
366 | * @return int |
||
367 | */ |
||
368 | 4 | public function messageBytesUnacknowledged(): int |
|
372 | |||
373 | /** |
||
374 | * @return int |
||
375 | */ |
||
376 | 4 | public function messageBytesRam(): int |
|
380 | |||
381 | /** |
||
382 | * @return int |
||
383 | */ |
||
384 | 4 | public function messageBytesPersistent(): int |
|
388 | |||
389 | /** |
||
390 | * @return DateTime |
||
391 | */ |
||
392 | public function headMessageTimestamp(): DateTime |
||
396 | |||
397 | /** |
||
398 | * @return int |
||
399 | */ |
||
400 | 4 | public function diskReads(): int |
|
404 | |||
405 | /** |
||
406 | * @return int |
||
407 | */ |
||
408 | 4 | public function diskWrites(): int |
|
412 | |||
413 | /** |
||
414 | * @return Queue\BackingQueueStatus |
||
415 | */ |
||
416 | public function backingQueueStatus(): Queue\BackingQueueStatus |
||
420 | |||
421 | /** |
||
422 | * @return string |
||
423 | */ |
||
424 | 4 | public function name(): string |
|
428 | |||
429 | /** |
||
430 | * @return string |
||
431 | */ |
||
432 | 4 | public function vhost(): string |
|
436 | |||
437 | /** |
||
438 | * @return bool |
||
439 | */ |
||
440 | 4 | public function durable(): bool |
|
444 | |||
445 | /** |
||
446 | * @return bool |
||
447 | */ |
||
448 | 4 | public function autoDelete(): bool |
|
452 | |||
453 | /** |
||
454 | * @return bool |
||
455 | */ |
||
456 | 4 | public function exclusive(): bool |
|
460 | |||
461 | /** |
||
462 | * @return array |
||
463 | */ |
||
464 | public function arguments(): array |
||
468 | |||
469 | /** |
||
470 | * @return string |
||
471 | */ |
||
472 | 4 | public function node(): string |
|
476 | } |
||
477 |