BenDerPan.Emitter

Emitter is an MQTT client tailored for emitter.io service, allowing real-time publish subscribe. It supports full .Net Framework and WinRT platform (Windows 8+ and Windows Phone 8+).


Keywords
emitter, mqtt, queue, messaging, pubsub, publish, subscribe, internetofthings, iot, cloud, embedded, netduino, hardware, winrt, windows8, windows8.1, windowsphone, windowsphone8.1, gadgeteer
License
EPL-1.0
Install
Install-Package BenDerPan.Emitter -Version 4.3.1

Documentation

Emitter C# SDK

This repository contains C# client for .Net Framework, .Net Micro Framework and WinRT for Emitter (see also on Emitter GitHub). Emitter is an open-source real-time communication service for connecting online devices. At its core, emitter.io is a distributed, scalable and fault-tolerant publish-subscribe messaging platform based on MQTT protocol and featuring message storage.

The current version supports several .Net Frameworks:

  • .Net Framework (2.0, 3.0, 3.5, 4.0, 4.5, 4.5.1, 4.5.2, 4.6, 4.6.1)
  • .Net Micro Framework 4.2, 4.3 and 4.4
  • Mono (for Linux O.S.)

The current version also supports WinRT platforms:

  • Windows 8.1
  • Windows Phone 8.1
  • Windows 10

This library provides a nicer MQTT interface fine-tuned and extended with specific features provided by emitter.io. The library is based upon the M2MQTT library written by Paolo Patierno and released under Eclipse Public License.

Build Notes

The solution contains C# projects for Micro Framework.

Alternatively, the files can be downloaded from here:

Nuget

To install Emitter, run the following command in the Package Manager Console:

Install-Package Emitter

Usage

Below is a sample program written using this C# client library. This demonstrates a simple console chat app where the messages are published to chat channel and every connected client receives them in real-time.

// Creating a connection to emitter.io service.
var emitter    = new Emitter.Connection(host, port);
var channelKey = "<channel key for 'chat' channel>";

// Connect to emitter.io service
emitter.Connect();

// Handle chat messages
emitter.On(channelKey, "chat", (channel, msg) =>
{
    Console.WriteLine(Encoding.UTF8.GetString(msg));
});

// Publish messages to the 'chat' channel
string text = "";
Console.WriteLine("Type to chat or 'q' to exit...");
do
{
    text = Console.ReadLine();
    emitter.Publish(channelKey, "chat", text);
}
while (text != "q");

// Disconnect the client
emitter.Disconnect();

To generate a channel key using the secret key provided, the GenerateKey method can be used.

// Generate a read-write key for our channel
emitter.GenerateKey(
    "<secret key>", 
    "chat", 
    Messages.EmitterKeyType.ReadWrite, 
    (response) => Console.WriteLine("Generated Key: " + response.Key)
    );