Commit bd3c9772 authored by yangxiaodong's avatar yangxiaodong

refactor.

parent dab9d644
using System;
using System.Collections.Generic;
using System.Text;
using Cap.Consistency.Abstractions;
using Microsoft.Extensions.Logging;
namespace Cap.Consistency.Consumer.Kafka
{
public interface IKafkaTaskSchedule : ITaskSchedule { }
public class KafkaTaskSchedule : IKafkaTaskSchedule
{
private readonly ILogger _logger;
public KafkaTaskSchedule(ILoggerFactory loggerFactory) {
_logger = loggerFactory.CreateLogger<KafkaTaskSchedule>();
}
public void Start(IReadOnlyList<ConsumerExecutorDescriptor> methods) {
throw new NotImplementedException();
}
public void Stop() {
throw new NotImplementedException();
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment