push
0 of 1 new or added line in 1 file covered. (0.0%)
1529 existing lines in 63 files now uncovered.7 of 1711 relevant lines covered (0.41%)
0.0 hits per line
|
UNCOV
1
|
require 'delegate'
|
× |
| 2 |
|
|
|
UNCOV
3
|
module DispatchRider |
× |
|
UNCOV
4
|
module QueueServices |
× |
|
UNCOV
5
|
class ReceivedMessage < ::SimpleDelegator |
× |
| 6 |
#Item is the raw message item as returned by the queue implementor
|
|
| 7 |
#it's contents will depend on the queue being used
|
|
|
UNCOV
8
|
attr_reader :item
|
× |
| 9 |
|
|
|
UNCOV
10
|
def initialize(message, item) |
× |
|
UNCOV
11
|
@item = item
|
× |
|
UNCOV
12
|
super(message)
|
× |
|
UNCOV
13
|
end
|
× |
| 14 |
|
|
|
UNCOV
15
|
def guid |
× |
|
UNCOV
16
|
self.body['guid'] |
× |
|
UNCOV
17
|
end
|
× |
| 18 |
|
|
|
UNCOV
19
|
def extend_timeout(time) |
× |
|
UNCOV
20
|
raise NotImplementedError
|
× |
|
UNCOV
21
|
end
|
× |
| 22 |
|
|
|
UNCOV
23
|
def return_to_queue |
× |
|
UNCOV
24
|
raise NotImplementedError
|
× |
|
UNCOV
25
|
end
|
× |
| 26 |
|
|
|
UNCOV
27
|
def receive_count |
× |
| 28 |
raise NotImplementedError
|
× |
|
UNCOV
29
|
end
|
× |
| 30 |
|
|
|
UNCOV
31
|
def sent_at |
× |
| 32 |
raise NotImplementedError
|
× |
|
UNCOV
33
|
end
|
× |
| 34 |
|
|
|
UNCOV
35
|
def queue_name |
× |
| 36 |
raise NotImplementedError
|
× |
|
UNCOV
37
|
end
|
× |
|
UNCOV
38
|
end
|
× |
|
UNCOV
39
|
end
|
× |
|
UNCOV
40
|
end
|
× |