aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--actionmailer/lib/action_mailer/async.rb58
-rw-r--r--actionmailer/lib/action_mailer/base.rb6
2 files changed, 33 insertions, 31 deletions
diff --git a/actionmailer/lib/action_mailer/async.rb b/actionmailer/lib/action_mailer/async.rb
index 86a5b0d035..a364342745 100644
--- a/actionmailer/lib/action_mailer/async.rb
+++ b/actionmailer/lib/action_mailer/async.rb
@@ -1,39 +1,41 @@
require 'delegate'
-module ActionMailer::Async
- def method_missing(method_name, *args)
- if action_methods.include?(method_name.to_s)
- QueuedMessage.new(queue, self, method_name, *args)
- else
- super
+module ActionMailer
+ module Async
+ def method_missing(method_name, *args)
+ if action_methods.include?(method_name.to_s)
+ QueuedMessage.new(queue, self, method_name, *args)
+ else
+ super
+ end
end
- end
- def queue
- Rails.queue
- end
+ def queue
+ Rails.queue
+ end
- class QueuedMessage < ::Delegator
- attr_reader :queue
+ class QueuedMessage < ::Delegator
+ attr_reader :queue
- def initialize(queue, mailer_class, method_name, *args)
- @queue = queue
- @mailer_class = mailer_class
- @method_name = method_name
- @args = args
- end
+ def initialize(queue, mailer_class, method_name, *args)
+ @queue = queue
+ @mailer_class = mailer_class
+ @method_name = method_name
+ @args = args
+ end
- def __getobj__
- @actual_message ||= @mailer_class.send(:new, @method_name, *@args).message
- end
+ def __getobj__
+ @actual_message ||= @mailer_class.send(:new, @method_name, *@args).message
+ end
- def run
- __getobj__.deliver
- end
+ def run
+ __getobj__.deliver
+ end
- # Will push the message onto the Queue to be processed
- def deliver
- @queue << self
+ # Will push the message onto the Queue to be processed
+ def deliver
+ @queue << self
+ end
end
end
-end
+end \ No newline at end of file
diff --git a/actionmailer/lib/action_mailer/base.rb b/actionmailer/lib/action_mailer/base.rb
index 89e0adc04d..f31e1e007b 100644
--- a/actionmailer/lib/action_mailer/base.rb
+++ b/actionmailer/lib/action_mailer/base.rb
@@ -457,10 +457,11 @@ module ActionMailer #:nodoc:
end
# Will force ActionMailer to push new messages to the queue defined
- # in the ActionMailer class when set to true
+ # in the ActionMailer class when set to true.
#
# class WelcomeMailer < ActionMailer::Base
# self.async = true
+ # end
def async=(truth)
if truth
require 'action_mailer/async'
@@ -785,5 +786,4 @@ module ActionMailer #:nodoc:
ActiveSupport.run_load_hooks(:action_mailer, self)
end
-end
-
+end \ No newline at end of file