jbogard

ProcessLineInFileMessage[] messages = ConvertFileToMessages(file);

Bus.Send(messages); // Sends all logical messages in 1 transport message

jbogard

ProcessLineInFileMessage[] messages = ConvertFileToMessages(file);

foreach (var message in messages)
    Bus.Send(message); // Send one logical message at a time

jbogard

if (db.EmailIsUnique(member.Email))
    db.Save(member);

jbogard

    public class ClientRoleHandler : IConfigureRole<AsA_Client>
    {
        public ConfigUnicastBus ConfigureRole(IConfigureThisEndpoint specifier)
        {
            if (!Configure.Instance.Configurer.HasComponent<ISendMessages>())
                Configure.Instance.MsmqTransport();

            return Configure.Instance
                .PurgeOnStartup(true)
                .IsTransactional(false)

jbogard

    public class ServerRoleHandler : IConfigureRole<AsA_Server>
    {
        public ConfigUnicastBus ConfigureRole(IConfigureThisEndpoint specifier)
        {
            if (!Configure.Instance.Configurer.HasComponent<ISendMessages>())
                Configure.Instance.MsmqTransport();

            return Configure.Instance
                .Sagas()
                .IsTransactional(true)

jbogard

public class TestClassBaseWithInitialize
{
    private IContainer _container;

    [SetUp]
    public void SetUp()
    {
        _container = Root.BuildContainer();
    }

jbogard

public abstract class TestClassBase
{
    private readonly IContainer _container 
        = Root.Container.GetNestedContainer();

    protected T GetInstance<T>()
    {
        return _container.GetInstance<T>();
    }

jbogard

public class EndpointConfig : 
    IConfigureThisEndpoint, 
    AsA_Server
{
}

jbogard

internal class ProductionProfileHandler : IHandleProfile<Production>, IWantTheEndpointConfig
{
    void IHandleProfile.ProfileActivated()
    {
        Configure.Instance.RavenPersistence();

        if (!Configure.Instance.Configurer.HasComponent<ISagaPersister>())
            Configure.Instance.RavenSagaPersister();

        if (!Configure.Instance.Configurer.HasComponent<IManageMessageFailures>())

jbogard

public class RavenProductionPersistenceSetup : IHandleProfile<Production>
{
    void IHandleProfile.ProfileActivated()
    {
        Configure.Instance
            .RavenPersistence("MyProductionConnectionString");
    }
}