Skip to content

Instantly share code, notes, and snippets.

@perokvist perokvist/IServiceBus
Last active Dec 13, 2015

What would you like to do?
Simple.ServiceBus 0.1
public interface IServiceBus
Task PublishAsync<T>(T message);
IDisposable Subscribe<T>(IObserver<T> handler,SubscriptionConfiguration configuration=null);
var container = new ContainerBuilder()
var serviceBus = container.Resolve<IServiceBus>();
var manager = container.Resolve<IServiceBusManager>();
var container = new ContainerBuilder()
var resolver = new Resolver(container.ResolveNamed, container.Resolve);
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());
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.