gistfile1.cs

// from: http://pastebin.com/Hg8vkNAu
//
// Suggested improvement:
static readonly Dictionary<Type, Func<byte[], object>> Decoders = new Dictionary<Type, Func<byte[], object>>() {
	{ typeof (string), x => Encoding.UTF8.GetString(x) },
	{ typeof (byte[]), x => x },
};

public void Add<T>(string cmd, MessageReceiver<T> receiver)
{
	Func<byte[], object> decoder;
	if (!Decoders.TryGetValue (typeof (T), out decoder))
		decoder = x => JsonConvert.DeserializeObject<T>(Encoding.UTF8.GetString(x));
	
	Receivers.Add (cmd, (data, headers) => {
			T message = (T) decode(data);
			receiver(message, headers);
	});
}