Contents

module Waffle
  class Base

    def initialize(strategy = nil)
      @strategy = strategy
    end

    def publish(flow = 'events', message = '')
      begin
        @strategy.publish flow, message
      rescue
        nil
      end
    end

    def subscribe(flow = '', &block)
      @strategy.subscribe flow, &block
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
waffle-0.1.3	lib/waffle/base.rb