class PubSubModelSync::MockKafkaService
Public Instance Methods
close()
click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 54 def close true end
consumer(*_args)
click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 42 def consumer(*_args) MockConsumer.new end
create_topic(_name)
click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 50 def create_topic(_name) true end
producer(*_args)
click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 37 def producer(*_args) MockProducer.new end
Also aliased as: async_producer
topics()
click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 46 def topics [] end