-
Notifications
You must be signed in to change notification settings - Fork 10
Expand file tree
/
Copy pathQueueClientInterface.php
More file actions
131 lines (113 loc) · 2.83 KB
/
Copy pathQueueClientInterface.php
File metadata and controls
131 lines (113 loc) · 2.83 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
121
122
123
124
125
126
127
128
129
130
131
<?php
namespace ReputationVIP\QueueClient;
use ReputationVIP\QueueClient\PriorityHandler\Priority\Priority;
use ReputationVIP\QueueClient\PriorityHandler\PriorityHandlerInterface;
interface QueueClientInterface
{
/**
* @param string $queueName
* @param mixed $message
* @param Priority $priority
* @param int $delaySeconds
*
* @return QueueClientInterface
*/
public function addMessage($queueName, $message, $priority = null, $delaySeconds = 0);
/**
* @param string $queueName
* @param array $messages
* @param Priority $priority
*
* @return QueueClientInterface
*/
public function addMessages($queueName, $messages, $priority = null);
/**
* @param string $queueName
* @param Priority $priority
* @param int $nbMsg
*
* @return array
*/
public function getMessages($queueName, $nbMsg = 1, $priority = null);
/**
* @param string $queueName
* @param array $message
*
* @return QueueClientInterface
*/
public function deleteMessage($queueName, $message);
/**
* @param string $queueName
* @param array $messages
*
* @return QueueClientInterface
*/
public function deleteMessages($queueName, $messages);
/**
* @param string $queueName
* @param Priority $priority
*
* @return bool
*/
public function isEmpty($queueName, $priority = null);
/**
* @param string $queueName
* @param Priority $priority
*
* @return int
*/
public function getNumberMessages($queueName, $priority = null);
/**
* @param string $queueName
*
* @return QueueClientInterface
*/
public function deleteQueue($queueName);
/**
* @param string $queueName
*
* @return QueueClientInterface
*/
public function createQueue($queueName);
/**
* @param string $sourceQueueName
* @param string $targetQueueName
*
* @return QueueClientInterface
*/
public function renameQueue($sourceQueueName, $targetQueueName);
/**
* @param string $queueName
* @param Priority $priority
*
* @return QueueClientInterface
*/
public function purgeQueue($queueName, $priority = null);
/**
* @param string $regex
*
* @return array
*/
public function listQueues($regex = null);
/**
* @param string $queueName
* @param string $alias
*
* @return QueueClientInterface
*/
public function addAlias($queueName, $alias);
/**
* @param string $alias
*
* @return QueueClientInterface
*/
public function removeAlias($alias);
/**
* @return []
*/
public function getAliases();
/**
* @return PriorityHandlerInterface
*/
public function getPriorityHandler();
}