Commit 87b26ae9 authored by yangxiaodong's avatar yangxiaodong

refactor

parent 2ca99909
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Cap.Consistency.Abstractions;
using Cap.Consistency.Consumer;
using Cap.Consistency.Infrastructure;
using System.Collections.Generic;
namespace Cap.Consistency.Routing
{
public delegate Task HandlerConsumer(ConsumerExecutorDescriptor context);
public class TopicRouteContext
{
public TopicRouteContext() {
}
public TopicRouteContext(DeliverMessage message) {
Message = message;
}
public DeliverMessage Message { get; }
// public event EventHandler<ConsumerExecutorDescriptor> OnMessage;
public HandlerConsumer Handler { get; set; }
public IList<IConsumerHandler> Consumers { get; set; }
public IServiceProvider ServiceProvider { get; set; }
public IList<ITopicRoute> Routes { get; set; }
......
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