Sha256: 721e7d2dd33a28b654ea2a4ad3c7e9ab4069ba1565746da9b4b406a57bcb3509
Contents?: true
Size: 604 Bytes
Versions: 30
Compression:
Stored size: 604 Bytes
Contents
# frozen_string_literal: true
module PubSubModelSync
class MockKafkaService
class MockProducer
def produce(*_args)
true
end
def deliver_messages(*_args)
true
end
def shutdown
true
end
end
class MockConsumer
def each_message(*_args)
true
end
def stop(*_args)
true
end
def subscribe(*_args)
true
end
end
def producer(*_args)
MockProducer.new
end
def consumer(*_args)
MockConsumer.new
end
def close
true
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems