       binding = @bindings[id]
       return if not binding?.enabled
       debug 'edge message', from, to, msg
+
+      subscription = @subscriptions[id]
+      if subscription
+        for subCallback in subscription.handlers
+          subCallback(subscription.binding, msg.data)
+
       @transport.sendTo 'outqueue', to, msg.data, (err) ->
         throw err if err
+
     @transport.subscribeToQueue from, handler, (err) =>
       return callback err if err
       @bindings[id] =

    return callback null, []

  subscribeData: (binding, datahandler, callback) ->
    throw new Error 'Not Implemented'
  unsubscribeData: (binding, datahandler, callback) ->
    throw new Error 'Not Implemented'

exports.Binder = Binder
exports.binderMixin = (transport) ->

  transport.addBinding = b.addBinding.bind b
  transport.removeBinding = b.removeBinding.bind b
  transport.listBindings = b.listBindings.bind b
  transport.subscribeData = b.subscribeData.bind b
  transport.unsubscribeData = b.unsubscribeData.bind b

