Class: DispatchRider::QueueServices::ReceivedMessage
- Inherits:
-
SimpleDelegator
- Object
- SimpleDelegator
- DispatchRider::QueueServices::ReceivedMessage
show all
- Defined in:
- lib/dispatch-rider/queue_services/received_message.rb
Instance Attribute Summary collapse
-
#item ⇒ Object
readonly
Item is the raw message item as returned by the queue implementor it’s contents will depend on the queue being used.
Instance Method Summary
collapse
Constructor Details
Returns a new instance of ReceivedMessage.
11
12
13
14
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 11
def initialize(message, item)
@item = item
super(message)
end
|
Instance Attribute Details
#item ⇒ Object
Item is the raw message item as returned by the queue implementor it’s contents will depend on the queue being used
9
10
11
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 9
def item
@item
end
|
Instance Method Details
#extend_timeout(time) ⇒ Object
20
21
22
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 20
def extend_timeout(time)
raise NotImplementedError
end
|
#guid ⇒ Object
16
17
18
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 16
def guid
self.body['guid']
end
|
#queue_name ⇒ Object
36
37
38
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 36
def queue_name
raise NotImplementedError
end
|
#receive_count ⇒ Object
28
29
30
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 28
def receive_count
raise NotImplementedError
end
|
#return_to_queue ⇒ Object
24
25
26
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 24
def return_to_queue
raise NotImplementedError
end
|
#sent_at ⇒ Object
32
33
34
|
# File 'lib/dispatch-rider/queue_services/received_message.rb', line 32
def sent_at
raise NotImplementedError
end
|