File Queuing

This file explains how to send and receive File by Queuing (RabbitMQ).

Overview

The BIA.Net.Queue authorize to send/Receive file by Message Queuing using a RabbitMQ server.

How to install

First install a rabbitMQ server. https://www.rabbitmq.com/install-windows.html

Add BIA.Net.Queue's Packages from nuget.org on the the proper project in your solution. BIA.Net.Queue.Domain BIA.Net.Queue.Domain.Dto BIA.Net.Queue.Infrastructure.Service BIA.Net.Queue.Crosscutting.Common

Add the following line in the infrastructure service methods in IOCContainer Class.

private static void ConfigureInfrastructureServiceContainer(IServiceCollection collection)
{
     // Infrastructure Service Layer
     collection.AddTransient<IFileQueueRepository, FileQueueRepository>();
}

how to serialize/deserialize a file

File are transferred by FileQueueDto :

    /// <summary>
    /// DTO of File Queue
    /// </summary>
    [Serializable]
    public class FileQueueDto
    {
        /// <summary>
        /// Gets or Sets the filename.
        /// </summary>
        public string FileName { get; set; }

        /// <summary>
        /// Gets or Sets the output path folder to put the file.
        /// </summary>
        public string OutputPath { get; set; }

        /// <summary>
        /// Gets or sets the data of the files en bytes.
        /// </summary>
        public byte[] Data { get; set; }
    }

which can be instantiate from a file path :

    FileQueueDto file = new FileQueueDto();
    file.FileName = System.IO.Path.GetFileName(filePath);
    file.OutputPath = outputPath;
    file.Data = File.ReadAllBytes(filePath);

How to receive a file

To receive a file, create an observer of FileQueueDto

	public class FileReceiverHandler : IObserver<FileQueueDto>
    {
        public void OnCompleted()
        {
            throw new NotImplementedException();
        }

        public void OnError(Exception error)
        {
            throw new NotImplementedException();
        }

        public void OnNext(FileQueueDto value)
        {
            if (value != null && !string.IsNullOrEmpty(value.FileName) && !string.IsNullOrEmpty(value.OutputPath) && value.Data.Length > 0)
            {
                // TODO
            }
        }
    }
	

Then subscribe to the observable, create a QueueDto

    /// <summary>
    /// Dto to define address of RabbitMQ server and queue.
    /// </summary>
    public class QueueDto
    {
        /// <summary>
        /// The RabbitMQ server URI.
        /// </summary>
        public string Endpoint { get; set; }

        /// <summary>
        /// The rabbitMQ Queue to listen
        /// </summary>
        public string QueueName { get; set; }
    }

    private readonly IFileQueueRepository fileQueueRepository;
	
	...
	
	fileQueueRepository.Configure(fileReceiverConfigurations.Select(x => new QueueDto { Endpoint = XXX, QueueName = YYY }));
	fileQueueRepository.Subscribe(fileReceiverHandler);

How to send a file

To send, just use SendFile method with server URI, queue name and a FileQueueDto

    private readonly IFileQueueRepository fileQueueRepository;
	
	...
	
	fileQueueRepository.SendFile(Sever, queueName, file);