Class: PubSubModelSync::MockKafkaService

Inherits:
Object
  • Object
show all
Defined in:
lib/pub_sub_model_sync/mock_kafka_service.rb

Defined Under Namespace

Classes: MockConsumer, MockProducer

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



54
55
56
 
# File 'lib/pub_sub_model_sync/mock_kafka_service.rb', line 54

def close
  true
end

#consumer(*_args) ⇒ Object 



42
43
44
 
# File 'lib/pub_sub_model_sync/mock_kafka_service.rb', line 42

def consumer(*_args)
  MockConsumer.new
end

#create_topic(_name) ⇒ Object 



50
51
52
 
# File 'lib/pub_sub_model_sync/mock_kafka_service.rb', line 50

def create_topic(_name)
  true
end

#producer(*_args) ⇒ Object Also known as: async_producer 



37
38
39
 
# File 'lib/pub_sub_model_sync/mock_kafka_service.rb', line 37

def producer(*_args)
  MockProducer.new
end

#topics ⇒ Object 



46
47
48
 
# File 'lib/pub_sub_model_sync/mock_kafka_service.rb', line 46

def topics
  []
end