class PubSubModelSync::MockKafkaService::MockConsumer

Public Instance Methods

each_message(*_args) click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 20
def each_message(*_args)
  true
end
mark_message_as_processed(*_args) click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 32
def mark_message_as_processed(*_args)
  true
end
stop(*_args) click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 24
def stop(*_args)
  true
end
subscribe(*_args) click to toggle source
# File lib/pub_sub_model_sync/mock_kafka_service.rb, line 28
def subscribe(*_args)
  true
end