Contents

class Klomp
  class Subscription
    attr_reader :subscriber, :headers

    def initialize(subscriber, headers)
      @subscriber = subscriber
      @headers = headers
    end

    def call(message = nil)
      @subscriber.call(message)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
klomp-1.0.8	lib/klomp/subscription.rb