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 raise "must be implemented in subclass" end end end end