-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathQueue.php
More file actions
120 lines (107 loc) · 2.19 KB
/
Queue.php
File metadata and controls
120 lines (107 loc) · 2.19 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
<?php
declare(strict_types = 1);
namespace Innmind\RabbitMQ\Management\Model;
use Innmind\RabbitMQ\Management\Model\{
Queue\Identity,
Queue\Messages,
};
use Innmind\Time\Point;
use Innmind\Immutable\Maybe;
/**
* @psalm-immutable
*/
final class Queue
{
/**
* @param Maybe<Point> $idleSince
*/
private function __construct(
private Identity $identity,
private Messages $messages,
private Maybe $idleSince,
private Count $consumers,
private State $state,
private Node\Name $node,
private bool $exclusive,
private bool $autoDelete,
private bool $durable,
) {
}
/**
* @psalm-pure
*
* @param Maybe<Point> $idleSince
*/
#[\NoDiscard]
public static function of(
Identity $identity,
Messages $messages,
Maybe $idleSince,
Count $consumers,
State $state,
Node\Name $node,
bool $exclusive,
bool $autoDelete,
bool $durable,
): self {
return new self(
$identity,
$messages,
$idleSince,
$consumers,
$state,
$node,
$exclusive,
$autoDelete,
$durable,
);
}
#[\NoDiscard]
public function identity(): Identity
{
return $this->identity;
}
#[\NoDiscard]
public function messages(): Messages
{
return $this->messages;
}
/**
* @return Maybe<Point>
*/
#[\NoDiscard]
public function idleSince(): Maybe
{
return $this->idleSince;
}
#[\NoDiscard]
public function consumers(): Count
{
return $this->consumers;
}
#[\NoDiscard]
public function state(): State
{
return $this->state;
}
#[\NoDiscard]
public function node(): Node\Name
{
return $this->node;
}
#[\NoDiscard]
public function exclusive(): bool
{
return $this->exclusive;
}
#[\NoDiscard]
public function autoDelete(): bool
{
return $this->autoDelete;
}
#[\NoDiscard]
public function durable(): bool
{
return $this->durable;
}
}