Sha256: d84dd055f5288dbda6e53218445bd6fa0b6b7c21531426196d7f19df14beaaba
Contents?: true
Size: 992 Bytes
Versions: 10
Compression:
Stored size: 992 Bytes
Contents
# frozen_string_literal: true
require "timeout"
module Mimi
module Messaging
module Adapters
#
# A Test is a mock adapter object for running tests.
#
class Test < Base
register_adapter_name "test"
def start
end
def stop
end
def command(target, message, opts = {})
end
def query(target, message, opts = {})
end
def event(target, message, opts = {})
end
def start_request_processor(queue_name, processor, _opts = {})
super
true
end
def start_event_processor(topic_name, processor, _opts = {})
super
true
end
def start_event_processor_with_queue(topic_name, queue_name, processor, opts = {})
super
true
end
def stop_all_processors
true
end
end # class Test
end # module Adapters
end # module Messaging
end # module Mimi
Version data entries
10 entries across 10 versions & 1 rubygems