问NServicebus DataBus

EN

    #region Declarations

    private IBus Bus { get; set; }

    #endregion

    #region Constructors

    public Sender()
    {       
        if (Directory.Exists(BasePath))
        {
            Bus = Configure.Instance
                .FileShareDataBus(BasePath)
                .UnicastBus().DoNotAutoSubscribe()
                .CreateBus()
                .Start();
        }
    }

    #endregion

    #region Methods

    public void SendMessage()
    {
        // get a list of file names
        List<string> fileList = Directory.GetFiles(@"c:\test\").ToList();


        Bus.Send<GenericListMessage>(message =>
                                        {
                                            message.Name = "TEST";
                                            message.FileList = new DataBusProperty<List<string>>(fileList);
                                        });
    }
    #endregion

public class EndpointConfig : IConfigureThisEndpoint, AsA_Client 
{
}

internal class SetupDataBus : IWantCustomInitialization
{
    public static string BasePath = @"c:\storage\";

    public void Init()
    {
        Configure.Instance
            .FileShareDataBus(BasePath)
            .UnicastBus()
            .DoNotAutoSubscribe();
    }
}