File tree Expand file tree Collapse file tree 1 file changed +20
-0
lines changed Expand file tree Collapse file tree 1 file changed +20
-0
lines changed Original file line number Diff line number Diff line change 6
6
7
7
abstract class BaseConsumer extends BaseAmqp implements DequeuerInterface
8
8
{
9
+ /** @var int */
9
10
protected $ target ;
10
11
12
+ /** @var int */
11
13
protected $ consumed = 0 ;
12
14
15
+ /** @var callable */
13
16
protected $ callback ;
14
17
18
+ /** @var bool */
15
19
protected $ forceStop = false ;
16
20
21
+ /** @var int */
17
22
protected $ idleTimeout = 0 ;
18
23
24
+ /** @var int */
19
25
protected $ idleTimeoutExitCode ;
20
26
27
+ /**
28
+ * @param $callback
29
+ */
21
30
public function setCallback ($ callback )
22
31
{
23
32
$ this ->callback = $ callback ;
24
33
}
25
34
35
+ /**
36
+ * @return callable
37
+ */
38
+ public function getCallback ()
39
+ {
40
+ return $ this ->callback ;
41
+ }
42
+
43
+ /**
44
+ * @param int $msgAmount
45
+ */
26
46
public function start ($ msgAmount = 0 )
27
47
{
28
48
$ this ->target = $ msgAmount ;
You can’t perform that action at this time.
0 commit comments