Contents

module MessageDriver
  class TestAdapter < Adapters::Base
    def initialize(broker, _config)
      @broker = broker
    end

    def build_context
      TestContext.new(self)
    end
  end

  class TestContext < Adapters::ContextBase
    def handle_create_destination(_name, _dest_options = nil, _message_props = nil); end

    def handle_publish(_destination, _body, _dest_options = nil, _message_props = nil); end

    def handle_pop_message(_destination, _options = nil); end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
message-driver-1.0.1	spec/support/test_adapter.rb
message-driver-1.0.0	spec/support/test_adapter.rb
message-driver-0.7.2	spec/support/test_adapter.rb
message-driver-0.7.1	spec/support/test_adapter.rb
message-driver-0.7.0	spec/support/test_adapter.rb