transport: Check for amqplib/mqtt not included

Author: jonnor

src/amqp.coffee

@@ -1,10 +1,14 @@
 
-amqp = require 'amqplib/callback_api'
 debug = require('debug')('msgflo:amqp')
 async = require 'async'
-
 interfaces = require './interfaces'
 
+try
+  amqp = require 'amqplib/callback_api'
+catch e
+  amqp = e
+
+
 class Client extends interfaces.MessagingClient
   constructor: (@address, @options={}) ->
     @connection = null
@@ -14,6 +18,9 @@ class Client extends interfaces.MessagingClient
   ## Broker connection management
   connect: (callback) ->
     debug 'connect', @address
+    if amqp.message
+      return callback amqp
+
     amqp.connect @address, (err, conn) =>
       debug 'connected', err
       return callback err if err

src/mqtt.coffee

@@ -1,17 +1,23 @@
 
 debug = require('debug')('msgflo:mqtt')
-mqtt = require 'mqtt'
-
 interfaces = require './interfaces'
 routing = require './routing'
 
+try
+  mqtt = require 'mqtt'
+catch e
+  mqtt = e
+
 class Client extends interfaces.MessagingClient
   constructor: (@address, @options) ->
     @client = null
     @subscribers = {} # queueName -> [handler1, ...]
 
   ## Broker connection management
   connect: (callback) ->
+    if mqtt.message
+      return callback mqtt
+
     @client = mqtt.connect @address
     onConnected = (err) =>
       debug 'connected'