@@ 65-72 (lines=8) @@ | ||
62 | assertThat(iterator_to_array($iterator), is(identicalTo([]))); |
|
63 | } |
|
64 | ||
65 | public function testAcknowledgeOne() |
|
66 | { |
|
67 | $this->adapter->acknowledge([$this->messageB]); |
|
68 | ||
69 | $iterator = $this->adapter->dequeue($this->factory, 10); |
|
70 | ||
71 | assertThat(iterator_to_array($iterator), is(identicalTo([$this->messageA, $this->messageC]))); |
|
72 | } |
|
73 | ||
74 | public function testReject() |
|
75 | { |
|
@@ 83-90 (lines=8) @@ | ||
80 | assertThat(iterator_to_array($iterator), is(identicalTo($this->messages))); |
|
81 | } |
|
82 | ||
83 | public function testRejectOne() |
|
84 | { |
|
85 | $this->adapter->reject([$this->messageA]); |
|
86 | ||
87 | $iterator = $this->adapter->dequeue($this->factory, 10); |
|
88 | ||
89 | assertThat(iterator_to_array($iterator), is(identicalTo($this->messages))); |
|
90 | } |
|
91 | ||
92 | public function testDequeue() |
|
93 | { |