CoffeeScript 2 constructor compat

Author: bergie

src/amqp.coffee

@@ -11,7 +11,10 @@ catch e
   amqp = e
 
 class Client extends interfaces.MessagingClient
-  constructor: (@address, @options={}) ->
+  constructor: (address, options={}) ->
+    super address, options
+    @address = address
+    @options = options
     @connection = null
     @channel = null
     @options.prefetch = 2 if not @options.prefetch?

src/direct.coffee

@@ -9,7 +9,10 @@ brokers = {}
 
 
 class Client extends interfaces.MessagingClient
-  constructor: (@address, @options) ->
+  constructor: (address, options) ->
+    super address, options
+    @address = address
+    @options = options
 #    console.log 'client', @address
     @broker = null
 
@@ -76,7 +79,9 @@ class Queue extends EventEmitter
     @emit 'message', msg
 
 class MessageBroker extends interfaces.MessageBroker
-  constructor: (@address) ->
+  constructor: (address) ->
+    super address
+    @address = address
     routing.binderMixin this
     @queues = {}
 #    console.log 'broker', @address

src/mqtt.coffee

@@ -9,7 +9,10 @@ catch e
   mqtt = e
 
 class Client extends interfaces.MessagingClient
-  constructor: (@address, @options) ->
+  constructor: (address, options) ->
+    super address, options
+    @address = address
+    @options = options
     @client = null
     @subscribers = {} # queueName -> [handler1, ...]
 

src/participant.coffee

@@ -49,7 +49,9 @@ defaultDiscoveryPeriod = parseInt process.env.MSGFLO_DISCOVERY_PERIOD if process
 
 class Participant extends EventEmitter
   # @func gets called with inport, , and should return outport, outdata
-  constructor: (client, def, @func, role, options={}) ->
+  constructor: (client, def, func, role, options={}) ->
+    super()
+    @func = func
     client = transport.getClient(client) if typeof client == 'string'
     @messaging = client
     role = 'unknown' if not role