46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
# File 'lib/lifeboat.rb', line 46
def has_lifeboat(options={})
include LifeBoat::Queues
if options[:format] == :xml
format = :to_xml
else
format = :to_json
end
[:create, :update, :destroy ].each do |action|
define_method(action.to_s + "_lifeboat") do
begin
return unless (RAILS_ENV == "production") or (RAILS_ENV == "testing")
@cue = RightAws::SqsGen2.new(Credentials.key, Credentials.secret)
queue_name = action.to_s+"_"+ self.class.to_s.downcase + "_" + RAILS_ENV
q = RightAws::SqsGen2::Queue.create(@cue, queue_name, true, 1000)
q.send_message(self.attributes.send format)
rescue RightAws::AwsError => error
puts error
end
end
end
end
|