Contents

module MessageDriver
  module Middleware
    class Base
      attr_reader :destination

      def initialize(*args)
        @destination = args.shift
      end

      def on_publish(body, headers, properties)
        [body, headers, properties]
      end

      def on_consume(body, headers, properties)
        [body, headers, properties]
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
message-driver-1.0.1	lib/message_driver/middleware/base.rb
message-driver-1.0.0	lib/message_driver/middleware/base.rb
message-driver-0.7.2	lib/message_driver/middleware/base.rb
message-driver-0.7.1	lib/message_driver/middleware/base.rb
message-driver-0.7.0	lib/message_driver/middleware/base.rb
message-driver-0.6.1	lib/message_driver/middleware/base.rb
message-driver-0.6.0	lib/message_driver/middleware/base.rb
message-driver-0.5.3	lib/message_driver/middleware/base.rb
message-driver-0.5.2	lib/message_driver/middleware/base.rb
message-driver-0.5.1	lib/message_driver/middleware/base.rb
message-driver-0.5.0	lib/message_driver/middleware/base.rb