Contents

require 'activemessaging/message_sender'

module SayWhen
  module Processor
  
    class ActiveMessaging < SayWhen::Processor::Base
      
      include ::ActiveMessaging::MessageSender
    
      def initialize(scheduler)
        super(scheduler)
      end

      # send the job to the other end, then in the a13g processor, call the execute method
      def process(job)
        message = {:job_id=>job.id}.to_yaml
        publish :say_when, message
      end
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
say_when-0.1.0	lib/say_when/processor/active_messaging.rb