Simple.ServiceBus 0.1

IServiceBus

  public interface IServiceBus
    {
        Task PublishAsync<T>(T message);
        IDisposable Subscribe<T>(IObserver<T> handler,SubscriptionConfiguration configuration=null);
    }

Pub Demo

var container = new ContainerBuilder()
          .RegisterServiceBus()
          .Build();

  var serviceBus = container.Resolve<IServiceBus>();
  var manager = container.Resolve<IServiceBusManager>();

Sub Demo

var container = new ContainerBuilder()
      .RegisterServiceBus()
      .RegisterObservers(typeof(Program).Assembly)
      .Build();

var resolver = new Resolver(container.ResolveNamed, container.Resolve);

serviceConfig.ConstructUsing(
    s =>
    new SubscriptionConfigurationService(resolver,
     map => map.ListenTo<SimpleMessage>().Using<SimpleHandler>()
            .WithConfiguration(new SubscriptionConfiguration("Test_1"))
        ));
serviceConfig.WhenStarted(sv => sv.Start());
serviceConfig.WhenStopped(sv => sv.Stop());