class PubSubModelSync::MockKafkaService

Public Instance Methods

async_producer(*_args)
Alias for: producer
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