Contents

module MessageDriver
  module Subscription
    class Base
      include Logging
      attr_reader :adapter, :destination, :consumer, :options

      def initialize(adapter, destination, consumer, options = {})
        @adapter = adapter
        @destination = destination
        @consumer = consumer
        @options = options
      end

      def unsubscribe
        fail 'must be implemented in subclass'
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
message-driver-0.6.1	lib/message_driver/subscription.rb
message-driver-0.6.0	lib/message_driver/subscription.rb
message-driver-0.5.3	lib/message_driver/subscription.rb
message-driver-0.5.2	lib/message_driver/subscription.rb
message-driver-0.5.1	lib/message_driver/subscription.rb
message-driver-0.5.0	lib/message_driver/subscription.rb