namespace Messages.Commands
{
    public class CreatePurchaseOrderCommand
    {
        public int PurchaseOrderId { get; set; }
        public string Description { get; set; }
    }
}

Namespace Commands
    Public Class CreatePurchaseOrderCommand

        Public Property PurchaseOrderId() As Integer
        Public Property Description() As String

    End Class
End Namespace

namespace Messages.Mess
{
    public class CheckPurchaseOrderStatusMessage
    {
        public int PurchaseOrderId { get; set; }
        public string ConfirmationDescription { get; set; }
    }
}

Namespace Mess
    Public Class CheckPurchaseOrderStatusMessage

        Public Property PurchaseOrderId() As Integer
        Public Property ConfirmationDescription() As String

    End Class
End Namespace

private static IBus CreateBusFactory()
{
    Configure.Transactions.Enable();
    Configure.Serialization.Xml();

    //Disable Sagas to stop NSB from trying to use RavenDB in this app, which we don't need since
    //we are using MSMQ subscription storage in this app
    //See : http://support.nservicebus.com/customer/portal/articles/860436-publish-subscribe-configuration
    Configure.Features.Disable<Sagas>();

    var bus = Configure.With()
        .DefaultBuilder()
        .Log4Net()
        .MsmqSubscriptionStorage()
        .DefiningCommandsAs(t => t.Namespace != null && t.Namespace.StartsWith("Messages.Commands"))
        .UseTransport<Msmq>()
        .UnicastBus()
        //See : http://stackoverflow.com/questions/18344962/nservicebus-4-0-3-how-to-disable-ravendb
        .DisableTimeoutManager()
        .SendOnly();

    return bus;
}

    Private Shared Function CreateBusFactory() As IBus
        Configure.Transactions.Enable()
        Configure.Serialization.Xml()

        'Disable Sagas to stop NSB from trying to use RavenDB in this app, which we don't need since
        'we are using MSMQ subscription storage in this app
        'See : http://support.nservicebus.com/customer/portal/articles/860436-publish-subscribe-configuration
        Configure.Features.Disable(Of Sagas)()

        'See : http://stackoverflow.com/questions/18344962/nservicebus-4-0-3-how-to-disable-ravendb
        Dim bus = Configure.[With]() _
                  .DefaultBuilder() _
                  .Log4Net() _
                  .MsmqSubscriptionStorage() _
                  .DefiningCommandsAs(Function(t) t.[Namespace] IsNot Nothing _
                                          AndAlso t.[Namespace].StartsWith("Messages.Commands")) _
                  .UseTransport(Of NServiceBus.Msmq)() _
                  .UnicastBus() _
                  .DisableTimeoutManager() _
                  .SendOnly()

        Return bus
    End Function

namespace SQLSubscriber.IOC
{
    public class NServiceBusInstaller : IWindsorInstaller
    {
        public void Install(IWindsorContainer container, IConfigurationStore store)
        {

            Configure.Transactions.Enable();
            Configure.Serialization.Xml();
            Configure.Features.Enable<Sagas>();
          

            Configure.With()
                     .Log4Net()
                     .CastleWindsorBuilder(container)
                     .DefiningCommandsAs(t => t.Namespace != null && t.Namespace.StartsWith("Messages.Commands"))
                     .DefiningMessagesAs(t => t.Namespace != null && t.Namespace.StartsWith("Messages.Mess"))
                     .UseTransport<Msmq>()
                        .PurgeOnStartup(false)
                     .UnicastBus()
                     .LoadMessageHandlers()
                     .UseNHibernateSubscriptionPersister() 
                     .UseNHibernateTimeoutPersister() 
                     .UseNHibernateSagaPersister() 
                     .UseNHibernateGatewayPersister()
                     .CreateBus()
                     .Start(() => Configure.Instance.ForInstallationOn<Windows>().Install());
        }
    }
}

Namespace IOC
    Public Class NServiceBusInstaller
        Implements IWindsorInstaller

        Public Sub IWindsorInstaller_Install(ByVal container As IWindsorContainer, ByVal store As IConfigurationStore) Implements IWindsorInstaller.Install
            Configure.Transactions.Enable()
            Configure.Serialization.Xml()
            Configure.Features.Enable(Of Sagas)()


            Configure.[With]() _
                .Log4Net() _
                .CastleWindsorBuilder(container) _
                .DefiningCommandsAs(Function(t) t.[Namespace] _
                                        IsNot Nothing AndAlso t.[Namespace].StartsWith("Messages.Commands")) _
                .DefiningMessagesAs(Function(t) t.[Namespace] _
                                        IsNot Nothing AndAlso t.[Namespace].StartsWith("Messages.Mess")) _
                .UseTransport(Of NServiceBus.Msmq)() _
                .PurgeOnStartup(False) _
                .UnicastBus() _
                .LoadMessageHandlers() _
                .UseNHibernateSubscriptionPersister() _
                .UseNHibernateTimeoutPersister() _
                .UseNHibernateSagaPersister() _
                .UseNHibernateGatewayPersister() _
                .CreateBus() _
                .Start(Function() InstallForWindows())
        End Sub

        Private Function InstallForWindows()
            Configure.Instance.ForInstallationOn(Of Windows)().Install()
            ' return dummy value to get around VB.NET (expression does not return a value) in lambda
            ' see : http://stackoverflow.com/questions/2786753/vb-net-action-delegate-problem
            Return True
        End Function


    End Class
End Namespace

using System.Threading;
using Messages.Commands;
using Messages.Mess;
using NServiceBus;
using NServiceBus.Saga;
using Services;

namespace SQLSubscriber.Handlers
{
    public class MySaga : Saga<CreatePurchaseOrderSagaData>,
       IAmStartedByMessages<CreatePurchaseOrderCommand>,
       IHandleMessages<CheckPurchaseOrderStatusMessage>
    {
        public IPurchaseService PurchaseService { get; set; }

        public override void ConfigureHowToFindSaga()
        {
            ConfigureMapping<CreatePurchaseOrderCommand>
                (message => message.PurchaseOrderId)
                    .ToSaga(saga => saga.PurchaseOrderId);
            ConfigureMapping<CheckPurchaseOrderStatusMessage>
                (message => message.PurchaseOrderId)
                    .ToSaga(saga => saga.PurchaseOrderId);
        }

        public void Handle(CreatePurchaseOrderCommand message)
        {
            this.Data.TransactionId = PurchaseService.Initialise();
            this.Data.PurchaseOrderId = message.PurchaseOrderId;
            PurchaseService.Purchase(this.Data.TransactionId, 
                string.Format("1 * {0}", message.PurchaseOrderId));
            Bus.SendLocal(new CheckPurchaseOrderStatusMessage()
                          {
                              PurchaseOrderId = this.Data.PurchaseOrderId
                          });
        }


        public void Handle(CheckPurchaseOrderStatusMessage message)
        {
            if (this.Data.Retries < 3)
            {
                bool isCompleted = PurchaseService.IsCompleted(this.Data.TransactionId);
                if (isCompleted)
                {
                    base.MarkAsComplete();
                }
                else
                {
                    Thread.Sleep(2000);
                    this.Data.Retries++;
                    Bus.SendLocal(new CheckPurchaseOrderStatusMessage()
                                  {
                                      PurchaseOrderId = this.Data.PurchaseOrderId
                                  });
                }
            }
            else
            {
                base.MarkAsComplete();
            }
        }
    }
}

Imports System.Threading
Imports VB.Services.VB.Services
Imports VB.Messages.Mess
Imports VB.Messages.Commands
Imports NServiceBus
Imports NServiceBus.Saga

Namespace Handlers

    Public Class MySaga
        Inherits Saga(Of CreatePurchaseOrderSagaData)
        Implements IAmStartedByMessages(Of CreatePurchaseOrderCommand)
        Implements IHandleMessages(Of CheckPurchaseOrderStatusMessage)

        Public Overrides Sub ConfigureHowToFindSaga()

            ConfigureMapping(Of CreatePurchaseOrderCommand) _
                (Function(message) message.PurchaseOrderId) _
                .ToSaga(Function(saga) saga.PurchaseOrderId)
            ConfigureMapping(Of CheckPurchaseOrderStatusMessage) _
                (Function(message) message.PurchaseOrderId) _
                .ToSaga(Function(saga) saga.PurchaseOrderId)

        End Sub


        Public Property PurchaseService() As IPurchaseService

        Public Sub Handle(ByVal message As CreatePurchaseOrderCommand) _
            Implements IHandleMessages(Of CreatePurchaseOrderCommand).Handle

            Me.Data.TransactionId = PurchaseService.Initialise()
            Me.Data.PurchaseOrderId = message.PurchaseOrderId
            PurchaseService.Purchase(Me.Data.TransactionId, String.Format("1 * {0}", message.PurchaseOrderId))
            Dim checkPurchaseOrderStatusMessage = New CheckPurchaseOrderStatusMessage()
            checkPurchaseOrderStatusMessage.PurchaseOrderId = Me.Data.PurchaseOrderId
            Bus.SendLocal(checkPurchaseOrderStatusMessage)

        End Sub

        Public Sub Handle(ByVal message As CheckPurchaseOrderStatusMessage) _
            Implements IHandleMessages(Of CheckPurchaseOrderStatusMessage).Handle

            If Me.Data.Retries < 3 Then
                Dim isCompleted As Boolean = PurchaseService.IsCompleted(Me.Data.TransactionId)
                If isCompleted Then
                    MyBase.MarkAsComplete()
                Else
                    Thread.Sleep(2000)
                    Me.Data.Retries += 1
                    Dim checkPurchaseOrderStatusMessage = New CheckPurchaseOrderStatusMessage()
                    checkPurchaseOrderStatusMessage.PurchaseOrderId = Me.Data.PurchaseOrderId
                    Bus.SendLocal(checkPurchaseOrderStatusMessage)
                End If
            Else
                MyBase.MarkAsComplete()
            End If

        End Sub


    End Class
End Namespace

 this.Data.PurchaseOrderId = message.PurchaseOrderId;

Me.Data.PurchaseOrderId = message.PurchaseOrderId

base.MarkAsComplete();

MyBase.MarkAsComplete()

using System;
using NServiceBus.Saga;

namespace SQLSubscriber.Handlers
{
    public class CreatePurchaseOrderSagaData : IContainSagaData
    {
        // the following properties are mandatory
        public virtual Guid Id { get; set; }
        public virtual string Originator { get; set; }
        public virtual string OriginalMessageId { get; set; }

        // all other properties you want persisted - remember to make them virtual

        public virtual int PurchaseOrderId { get; set; }
        public virtual string Description { get; set; }
        public virtual string ConfirmationDescription { get; set; }
        public virtual int Retries { get; set; }
        public virtual Guid TransactionId { get; set; }
    }
}

Imports NServiceBus.Saga

Namespace Handlers
    Public Class CreatePurchaseOrderSagaData
        Implements IContainSagaData

        ' the following properties are mandatory
        Public Overridable Property Id() As Guid Implements IContainSagaData.Id
        Public Overridable Property Originator() As String Implements IContainSagaData.Originator
        Public Overridable Property OriginalMessageId() As String Implements IContainSagaData.OriginalMessageId

        ' all other properties you want persisted - remember to make them virtual
        Public Overridable Property PurchaseOrderId() As Int32
        Public Overridable Property Description() As String
        Public Overridable Property ConfirmationDescription() As String
        Public Overridable Property Retries() As Int32
        Public Overridable Property TransactionId() As Guid

    End Class
End Namespace

 this.Data.TransactionId = PurchaseService.Initialise();

Me.Data.TransactionId = PurchaseService.Initialise()

public override void ConfigureHowToFindSaga()
{
    ConfigureMapping<CreatePurchaseOrderCommand>
	(message => message.PurchaseOrderId)
            .ToSaga(saga => saga.PurchaseOrderId);
    ConfigureMapping<CheckPurchaseOrderStatusMessage>
	(message => message.PurchaseOrderId)
            .ToSaga(saga => saga.PurchaseOrderId);
}

Public Overrides Sub ConfigureHowToFindSaga()

    ConfigureMapping(Of CreatePurchaseOrderCommand) _
        (Function(message) message.PurchaseOrderId) _
            .ToSaga(Function(saga) saga.PurchaseOrderId)
    ConfigureMapping(Of CheckPurchaseOrderStatusMessage) _
        (Function(message) message.PurchaseOrderId) _
            .ToSaga(Function(saga) saga.PurchaseOrderId)

End Sub