The file share data bus allows large properties to be transferred via a Windows file share.
This implementation leverages both serialization and headers to provide its functionality.
Usage
Cleanup strategy
The business requirements can indicate how a message and its corresponding file should be processed and when the files can safely be removed. One strategy to deal with these attachments is to set up a cleanup policy which removes any attachments after a certain number of days have passed based on business Service Level Agreements.
The file location used by the data bus is set during configuration time.
var dataBus = busConfiguration.UseDataBus<FileShareDataBus>();
dataBus.BasePath(@"\\share\databus_attachments\");
This same location should be used when performing the cleanup.
For example, this path can be used in a Handler for a message containing data bus properties.
public class Handler :
IHandleMessages<MessageWithLargePayload>,
IHandleMessages<RemoveDatabusAttachment>
{
IBus bus;
public Handler(IBus bus)
{
this.bus = bus;
}
public void Handle(MessageWithLargePayload message)
{
var filePath = Path.Combine(@"\\share\databus_attachments\", message.LargeBlob.Key);
var removeAttachment = new RemoveDatabusAttachment
{
FilePath = filePath
};
bus.Defer(TimeSpan.FromDays(30), removeAttachment);
}
public void Handle(RemoveDatabusAttachment message)
{
var filePath = message.FilePath;
// Code to clean up
}
}