mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
[rackspace|queues] updating set_messages= to populate the claim_id attribute on messages in order for destroy to work properly.
This commit is contained in:
parent
a8f7033530
commit
05319d4f0f
2 changed files with 3 additions and 2 deletions
|
@ -80,12 +80,14 @@ module Fog
|
||||||
})
|
})
|
||||||
attributes[:messages] = messages.collect do |message|
|
attributes[:messages] = messages.collect do |message|
|
||||||
if message.instance_of? Fog::Rackspace::Queues::Message
|
if message.instance_of? Fog::Rackspace::Queues::Message
|
||||||
|
message.claim_id = self.id
|
||||||
message
|
message
|
||||||
else
|
else
|
||||||
Fog::Rackspace::Queues::Message.new(
|
Fog::Rackspace::Queues::Message.new(
|
||||||
message.merge({
|
message.merge({
|
||||||
:service => service,
|
:service => service,
|
||||||
:collection => message_collection
|
:collection => message_collection,
|
||||||
|
:claim_id => self.id
|
||||||
}.merge(message))
|
}.merge(message))
|
||||||
)
|
)
|
||||||
end
|
end
|
||||||
|
|
|
@ -27,7 +27,6 @@ module Fog
|
||||||
# @return [String] the id of the claim
|
# @return [String] the id of the claim
|
||||||
attribute :claim_id
|
attribute :claim_id
|
||||||
|
|
||||||
|
|
||||||
# @!attribute [r] identity
|
# @!attribute [r] identity
|
||||||
# @return [String] The messages identity
|
# @return [String] The messages identity
|
||||||
def identity
|
def identity
|
||||||
|
|
Loading…
Reference in a new issue