mookid8000

Configure.With(...)
    .Transport(t => t.UseRabbitMq(...)  //< giver en RabbitMqOptions
                   .PrefetchCount(5))

mookid8000

public class SomeDoc : Doc
{
    public Ref<AnotherDoc> TheOtherDoc { get; set; }
}

public class AnotherDoc : Doc
{
    public string Text { get; set; }
}

mookid8000

public interface ILoadAggregateRoots
{
  T Load<T>(string id) where T:Doc;
}

public static class Loader
{
  static ILoadAggregateRoots currentLoader = new ThrowMustProvideLoaderException();
  
  public static ILoadAggregateRoots Current

mookid8000

sqlReplicate('SomeTable', {
  Id: documentId,
  SomeIntegerColumn: 23
});

mookid8000

Configure.With(...)
         .EnableWebCallbacks()
         .(...)

// (...)

// just like that
adapter.Bus.Send(new SomeRequest {Message = "hello there!"},
                 (SomeReply reply) =>
                 {

mookid8000

Action<MyDomainAssembly.ISubscribeTo<MyDomainAssembly.IDomainEvent>, MyDomainAssembly.IDomainEvent>
 dispatchSpecification = (s, e) => s.Handle(e);


Action<MyDomainAssembly.IDomainEvent> myDispatcher =
  DomainEvents.Configure.With(someIocContainerAdapter)
     .DefineSubscriberAs<MyDomainAssembly.ISubscribeTo<MyDomainAssembly.IDomainEvent>>(dispatchSpecification)
     .RegisterSubscribersFromAssemblyContaining<MyDomainAssembly.SomeConcreteSubscriber>(Lifestyle.InstancePerCall)
     .RegisterSubscribersFromAssemblyContaining<MyInfrastructureAssembly.AnotherConcreteSubscriber>(Lifestyle.InstancePerCall)
     .CreateDispatcher();

mookid8000

public async Task<HttpResponseMessage> Get()
{
    var blobClient = GetBlobClientFromSomewhere();
    var imagesContainer = blobClient.GetContainerReference("images");

    var blobRef = await imagesContainer.GetBlobReferenceFromServerAsync(@"cute_cats_70MB.jpg");

    var openRead = await blobRef.OpenReadAsync();
    
    var response = new HttpResponseMessage(HttpStatusCode.OK)

mookid8000

try
{
    var startableBus = Configure.With(new BuiltinContainerAdapter())
        .Logging(l => l.None())
        .Transport(t => t.UseMsmqInOneWayClientMode())
        .CreateBus();

    using (var bus = startableBus.Start())
    {
        bus.Advanced.Routing.Send("NO_CHANCE_THAT_THIS_QUEUE_EXISTS", "hello there!");

mookid8000

using System;
using System.Threading;
using System.Threading.Tasks;
using Rebus.Logging;

namespace Rebus.Threading
{
    /// <summary>
    /// <see cref="Task"/>-based background timer thingie, that will periodically call an async <see cref="Func&lt;Task&gt;"/>
    ///  </summary>

mookid8000

    public static class SubscriberCacheExtensions
    {
        public static void EnableSubscriberCache(this OptionsConfigurer configurer)
        {
            configurer.Decorate<ISubscriptionStorage>(c =>
            {
                var subscriptionStorage = c.Get<ISubscriptionStorage>();

                return new CachingSubscriptionStorage(subscriptionStorage);
            });