NetMQ

NetMQ is 100% native C# port of ZeroMQ.

NetMQ is lightweight messaging library which extends the standard socket interfaces with features traditionally provided by specialised messaging middleware products. NetMQ sockets provide an abstraction of asynchronous message queues, multiple messaging patterns, message filtering (subscriptions), seamless access to multiple transport protocols and more.

Installation

You can find NetMQ in nuget.

Using / Documentation

Before using NetMQ, make sure to read the ZeroMQ Guide.

The NetMQ documentation can found here (thanks to Sacha Barber who agreed to do the documentation)

http://netmq.readthedocs.org/en/latest/.

There are also a few blog posts available, which you can read about here

Here is a small example

using (NetMQContext ctx = NetMQContext.Create())
{
	using (var server = ctx.CreateResponseSocket())
	{
		server.Bind("tcp://127.0.0.1:5556");
		using (var client = ctx.CreateRequestSocket())
		{
			client.Connect("tcp://127.0.0.1:5556");
			client.Send("Hello"); 

			string m1 = server.ReceiveString();
			Console.WriteLine("From Client: {0}", m1);
			server.Send("Hi Back");

			string m2 = client.ReceiveString();
			Console.WriteLine("From Server: {0}", m2);
			Console.ReadLine();
		}
	}
}

Contributing

We need help, so if you have good knowledge of C# and ZeroMQ just grab one of the issues and add a pull request. We are using C4 process, so make sure you read this before.

Regarding coding standards, we are using C# coding styles, to be a little more specific: we are using camelCase for variables and members (with m_ prefix for members) and PascalCase for methods, classes and constants. Make sure you are using Keep Spaces and 2 for tab and indent size.

You can also help us by:

Joining our mailing list and be an active member
Writing tutorials in the github wiki
Writing about the project in your blog (and add a pull request with a link to your blog at the bottom of this page)

Important note on backward compatibility

Since version 3.3.07 NetMQ changed the number serialization from Little Endian to Big Endian to be compatible with ZeroMQ. Any NetMQ version prior to 3.3.0.7 is not compatible with the new version. To support older versions you can set Endian option on a NetMQ socket to Little Endian, however doing so will make it incompatible with ZeroMQ.

We recommend to update to the latest version and use Big Endian which is now the default behavior.

Mailing list

You can join our mailing list here.

Who owns NetMQ?

NetMQ is owned by all its authors and contributors. This is an open source project licensed under the LGPLv3. To contribute to NetMQ please read the C4 process, it's what we use. There are open issues in the issues tab that still need to be taken care of, feel free to pick one up and submit a patch to the project.

Build Server

TeamCity at CodeBetter

YouTrack by JetBrains - keyboard-centric bug tracker

TeamCity by JetBrains - continuous integration server

Name		Name	Last commit message	Last commit date
Latest commit History 483 Commits
docs		docs
lib		lib
src

License

barzto/netmq

Folders and files

Latest commit

History