interfaces: Add un/subscribeData()

Author: jonnor

src/amqp.coffee

@@ -190,12 +190,18 @@ class MessageBroker extends Client
 
     else
       return callback new Error 'Unsupported binding type: '+binding.type
-  removeBinding: (binding, callback) ->
-    # FIXME: implement
+
+  removeBinding: (binding, callback) -> # FIXME: implement
     return callback null
-  listBindings: (from, callback) ->
+  listBindings: (from, callback) -> # FIXME: implement
     return callback null, []
-    
+
+  # Data subscriptions
+  subscribeData: (binding, datahandler, callback) -> # TODO: implement
+    return callback null
+  unsubscribeData: (binding, datahandler, callback) -> # TODO: implement
+    return callback null
+
   # Participant registration
   subscribeParticipantChange: (handler) ->
     deserialize = (message) =>

src/interfaces.coffee

@@ -66,6 +66,12 @@ class MessageBroker extends MessagingSystem
   listBindings: (callback) ->
     throw new Error 'Not Implemented'
 
+  # Subscribing to data on a binding
+  subscribeData: (binding, datahandler, callback) ->
+    throw new Error 'Not Implemented'
+  unsubscribeData: (binding, datahandler, callback) ->
+    throw new Error 'Not Implemented'
+
   # Participant registration
   subscribeParticipantChange: (handler) ->
     throw new Error 'Not Implemented'

src/routing.coffee

@@ -68,6 +68,10 @@ class Binder
     debug 'Binder.listBindings'
     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) ->