KN.RabbitMQ.Queue 1.0.2

Easy-to-use RabbitMQ Queue library for .NET products.

Install-Package KN.RabbitMQ.Queue -Version 1.0.2
dotnet add package KN.RabbitMQ.Queue --version 1.0.2
<PackageReference Include="KN.RabbitMQ.Queue" Version="1.0.2" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add KN.RabbitMQ.Queue --version 1.0.2
The NuGet Team does not provide support for this client. Please contact its maintainers for support.

About

Easy-to-use RabbitMQ Queue library for .NET products.
This is project is derived from RabbitMQ.Cliente library.

Source Code

Installation

Get KN.RabbitMQ.Queue from NuGet. The purpose of this fork is to add support to easiest .NET Standard development.

PM> Install-Package KN.RabbitMQ.Queue

Usage

Init in Startup

Write in appsettings file your RabbitMQ Broker credentials, ID is the name for the QUEUE.


{
  "KNQueueConfigurations": {
    "HostName": "example.cloudamqp.com",
    "Port": 80,
    "UserName": "example",
    "Password": "example",
    "Uri": "amqp://example:example@example.cloudamqp.com/example",
    "Id": "TestApi"
  }
}

Startup.cs
See in examples files for other project files

    public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllers();
            MessageBroker.Init(services);
        }

Publish message

Publish your message with the "Type" you need in message.

 [HttpPost]
        public object Post(
            [FromBody]Message message)
        {
            var queue = new MessageQueue("TestClient");

            MessageBroker.Publish(queue, message);

            return new
            {
                Result = "Message sent",
                Message = message
            };
        }

Consume a message

Implement the interface IMessagingService, with the QueueConsumer attribute is the same name of the Type in message.

    [QueueConsumer("TestMessageApi")]
    public class QueueReturnConsumerService : IMessagingService
    {
        public MessageResult Run(Message message, IServiceScopeFactory _scopeFactory)
        {
            Console.WriteLine(JsonConvert.SerializeObject(message));

            return new MessageResult() { Sucess = true };
        }

        public bool UnavailableService()
        {
            return false;
        }
    }

Credits

License

This project is licensed under MIT License.

About

Easy-to-use RabbitMQ Queue library for .NET products.
This is project is derived from RabbitMQ.Cliente library.

Source Code

Installation

Get KN.RabbitMQ.Queue from NuGet. The purpose of this fork is to add support to easiest .NET Standard development.

PM> Install-Package KN.RabbitMQ.Queue

Usage

Init in Startup

Write in appsettings file your RabbitMQ Broker credentials, ID is the name for the QUEUE.


{
  "KNQueueConfigurations": {
    "HostName": "example.cloudamqp.com",
    "Port": 80,
    "UserName": "example",
    "Password": "example",
    "Uri": "amqp://example:example@example.cloudamqp.com/example",
    "Id": "TestApi"
  }
}

Startup.cs
See in examples files for other project files

    public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllers();
            MessageBroker.Init(services);
        }

Publish message

Publish your message with the "Type" you need in message.

 [HttpPost]
        public object Post(
            [FromBody]Message message)
        {
            var queue = new MessageQueue("TestClient");

            MessageBroker.Publish(queue, message);

            return new
            {
                Result = "Message sent",
                Message = message
            };
        }

Consume a message

Implement the interface IMessagingService, with the QueueConsumer attribute is the same name of the Type in message.

    [QueueConsumer("TestMessageApi")]
    public class QueueReturnConsumerService : IMessagingService
    {
        public MessageResult Run(Message message, IServiceScopeFactory _scopeFactory)
        {
            Console.WriteLine(JsonConvert.SerializeObject(message));

            return new MessageResult() { Sucess = true };
        }

        public bool UnavailableService()
        {
            return false;
        }
    }

Credits

License

This project is licensed under MIT License.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version History

Version Downloads Last updated
1.0.2 207 2/21/2020
1.0.1 243 2/16/2020
1.0.0 252 2/16/2020