Contents

# Example:
# RosettaQueue::Filters.define do |filter_for|
#   filter_for.receiving { |message| ActiveSupport::JSON.decode(message) }
#   filter_for.sending { |hash| hash.to_json }
# end


module RosettaQueue
  class Filters
    
    class << self
            
      def define
        yield self
      end
      
      def reset
        @receiving = nil
        @sending = nil
      end
    
      def receiving(&receiving_filter)
        @receiving = receiving_filter
      end
    
      def sending(&sending_filter)
        @sending = sending_filter
      end
      
      def process_sending(message)
        return message unless @sending
        @sending.call(message)
      end
      
      def process_receiving(message)
        return message unless @receiving
        @receiving.call(message)
      end
      
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cwyckoff-rosetta_queue-0.1.4	lib/rosetta_queue/filters.rb
cwyckoff-rosetta_queue-0.2.0	lib/rosetta_queue/filters.rb
cwyckoff-rosetta_queue-0.2.1	lib/rosetta_queue/filters.rb
cwyckoff-rosetta_queue-0.2.2	lib/rosetta_queue/filters.rb
cwyckoff-rosetta_queue-0.3.0	lib/rosetta_queue/filters.rb