HarakaMQ.Client 1.0.0

There is a newer version of this package available.
See the version list below for details.
Install-Package HarakaMQ.Client -Version 1.0.0
dotnet add package HarakaMQ.Client --version 1.0.0
<PackageReference Include="HarakaMQ.Client" Version="1.0.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add HarakaMQ.Client --version 1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: HarakaMQ.Client, 1.0.0"
#r directive can be used in F# Interactive, C# scripting and .NET Interactive. Copy this into the interactive tool or source code of the script to reference the package.
// Install HarakaMQ.Client as a Cake Addin
#addin nuget:?package=HarakaMQ.Client&version=1.0.0

// Install HarakaMQ.Client as a Cake Tool
#tool nuget:?package=HarakaMQ.Client&version=1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.

HarakaMQ

Reliable Message Oriented Middleware Based on UDP and created with .NET Core 2.0

Message Broker

Start up the Broker by building the MessageBroker project, and runs it with the command "dotnet HarakaMQ.MessageBroker.dll". Remember to add a "settings.json" file in the running directory with this content:

{  
   "BrokerPort":11100,
   "PrimaryNumber":1,
   "AntiEntropyMilliseonds":1000,
   "RunInCLusterSetup":false,
   "Brokers":[]
}

You can also use the pre-builded Message broker (Client-Server setup) from this project https://github.com/Rotvig/HarakaMQ-Benchmark/tree/master/ClientServerSetup/Broker

Publish

var factory = new ConnectionFactory {HostName = "127.0.0.1", ListenPort = 11000, Port = 11100};
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare("hello");
    channel.BasicPublish("hello", Encoding.UTF8.GetBytes("Hello world");

    Console.WriteLine(" Press [enter] to exit.");
    Console.ReadLine();
}

Subscribe

var factory = new ConnectionFactory {HostName = "127.0.0.1", ListenPort = 12000, Port = 11100};
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare("hello");
    var consumer = new DefaultBasicConsumer(channel);
    var stopWatch = new Stopwatch();
    consumer.Received += (model, ea) =>
    {
        var message = Encoding.UTF8.GetString(ea.Body);
        Console.WriteLine(msgNumb + " Received {0}", message);
    };
    channel.BasicConsume("hello", consumer);

    Console.WriteLine(" Press [enter] to exit.");
    Console.ReadLine();
}

Test Repo

https://github.com/Rotvig/HarakaMQ-Benchmark

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
1.0.1 526 10/3/2018
1.0.0 494 6/27/2018

First version of the HarakaMQ Client. See examples on github.