transport: Allow registering implementations for a URL scheme

Author: jonnor

README.md

@@ -67,3 +67,13 @@ You can enable (all) logging using:
 
     export DEBUG=msgflo*
 
+## Supporting other transports
+
+msgflo-nodejs has a transport abstraction layer. So to support a new messaging system,
+implement `Client` and `MessageBroker` [interfaces](./src/interfaces.coffee).
+
+You can then pass these into a `Participant`.
+
+Or you can use `msgflo.transport.register('mytransport', myTransportModule)`, and then `msgflo.transport.getClient('mysystem://somehost:666')`.
+This will also work for specifying `msgflo-nodejs --broker` and for `MSGFLO_BROKER=` environment variable.
+

src/transport.coffee

@@ -17,3 +17,7 @@ exports.getBroker = (address, options) ->
   scheme = address.split('://')[0]
   throw new Error 'Unsupported scheme: ' + scheme if not supportsScheme scheme
   return new transports[scheme].MessageBroker address, options
+
+# @module: Must have Client and MessageBroker constructors, implementing these interfaces
+export.register = (scheme, module) ->
+  transports[scheme] = module