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
|
module DispatchRider |
× |
UNCOV
2
|
module QueueServices |
× |
UNCOV
3
|
class FileSystem < Base |
× |
UNCOV
4
|
class FsReceivedMessage < ReceivedMessage |
× |
UNCOV
5
|
attr_reader :queue
|
× |
6 |
|
|
UNCOV
7
|
def initialize(message, item, queue) |
× |
UNCOV
8
|
@queue = queue
|
× |
UNCOV
9
|
super(message, item)
|
× |
UNCOV
10
|
end
|
× |
11 |
|
|
UNCOV
12
|
def extend_timeout(timeout) |
× |
13 |
#file system doesn't support timeouts on items, so we ignore this.
|
|
UNCOV
14
|
end
|
× |
15 |
|
|
UNCOV
16
|
def return_to_queue |
× |
17 |
queue.put_back(item) |
× |
UNCOV
18
|
end
|
× |
19 |
|
|
UNCOV
20
|
def receive_count |
× |
21 |
1 # can't really check that in this service |
× |
UNCOV
22
|
end
|
× |
23 |
|
|
UNCOV
24
|
def sent_at |
× |
25 |
@item.ctime
|
× |
UNCOV
26
|
end
|
× |
27 |
|
|
UNCOV
28
|
def queue_name |
× |
29 |
File.basename(File.dirname(@item.path)) |
× |
UNCOV
30
|
end
|
× |
UNCOV
31
|
end
|
× |
UNCOV
32
|
end
|
× |
UNCOV
33
|
end
|
× |
UNCOV
34
|
end
|
× |