HarakaMQ.Client
1.0.0
See the version list below for details.
dotnet add package HarakaMQ.Client --version 1.0.0
NuGet\Install-Package HarakaMQ.Client -Version 1.0.0
<PackageReference Include="HarakaMQ.Client" Version="1.0.0" />
paket add HarakaMQ.Client --version 1.0.0
#r "nuget: HarakaMQ.Client, 1.0.0"
// 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
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
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
.NET Core | netcoreapp2.0 is compatible. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
-
.NETCoreApp 2.0
- HarakaMQ.UDPCommunication (>= 1.0.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
First version of the HarakaMQ Client. See examples on github.