Completed
Pull Request — master (#43)
by Harry
02:04
created

EagerAcknowledgementHandler::reject()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 7
Code Lines 5

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 3
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 7
c 0
b 0
f 0
ccs 3
cts 3
cp 1
rs 9.4285
cc 1
eloc 5
nc 1
nop 3
crap 1
1
<?php
2
3
/**
4
 * This file is part of graze/queue.
5
 *
6
 * Copyright (c) 2015 Nature Delivered Ltd. <https://www.graze.com>
7
 *
8
 * For the full copyright and license information, please view the LICENSE
9
 * file that was distributed with this source code.
10
 *
11
 * @license https://github.com/graze/queue/blob/master/LICENSE MIT
12
 *
13
 * @link    https://github.com/graze/queue
14
 */
15
16
namespace Graze\Queue\Handler;
17
18
use Graze\Queue\Adapter\AdapterInterface;
19
use Graze\Queue\Message\MessageInterface;
20
21
class EagerAcknowledgementHandler extends AbstractAcknowledgementHandler
22
{
23
    /**
24
     * @param MessageInterface $message
25
     * @param AdapterInterface $adapter
26
     * @param mixed            $result
27
     */
28 5
    protected function acknowledge(
29
        MessageInterface $message,
30
        AdapterInterface $adapter,
31
        $result = null
32
    ) {
33 5
        $adapter->acknowledge([$message]);
34 5
    }
35
36
    /**
37
     * @param MessageInterface $message
38
     * @param AdapterInterface $adapter
39
     * @param mixed            $result
40
     */
41 1
    protected function reject(
42
        MessageInterface $message,
43
        AdapterInterface $adapter,
44
        $result = null
45
    ) {
46 1
        $adapter->reject([$message]);
47 1
    }
48
49
    /**
50
     * @param AdapterInterface $adapter
51
     */
52 6
    protected function flush(AdapterInterface $adapter)
53
    {
54
        // Nothing to flush
55 6
    }
56
}
57