1 files changed, 20 insertions, 10 deletions
diff --git a/actionmailer/lib/action_mailer/queued_message.rb b/actionmailer/lib/action_mailer/queued_message.rb
index e5868ab43b..8d200617c4 100644
--- a/actionmailer/lib/action_mailer/queued_message.rb
+++ b/actionmailer/lib/action_mailer/queued_message.rb
@@ -5,23 +5,33 @@ module ActionMailer
     attr_reader :queue
 
     def initialize(queue, mailer_class, method_name, *args)
-      @queue        = queue
-      @mailer_class = mailer_class
-      @method_name  = method_name
-      @args         = args
+      @queue = queue
+      @job   = DeliveryJob.new(mailer_class, method_name, args)
     end
 
     def __getobj__
-      @actual_message ||= @mailer_class.send(:new, @method_name, *@args).message
+      @job.message
     end
 
-    def run
-      __getobj__.deliver
+    # Queues the message for delivery.
+    def deliver
+      tap { @queue.push @job }
     end
 
-    # Will push the message onto the Queue to be processed
-    def deliver
-      @queue << self
+    class DeliveryJob
+      def initialize(mailer_class, method_name, args)
+        @mailer_class = mailer_class
+        @method_name  = method_name
+        @args         = args
+      end
+
+      def message
+        @message ||= @mailer_class.send(:new, @method_name, *@args).message
+      end
+
+      def run
+        message.deliver
+      end
     end
   end
 end