   
   ## Broker connection management
   connect: (callback) ->
+    debug 'client connect'
     @broker = brokers[@address]
     return callback null
   disconnect: (callback) ->
+    debug 'client disconnect'
     @broker = null
     return callback null
 


interfaces = require './interfaces'
EventEmitter = require('events').EventEmitter


  constructor: (@address) ->
    @queues = {}
#    console.log 'broker', @address

  ## Broker connection management
  connect: (callback) ->
    debug 'broker connect'
    brokers[@address] = this
    return callback null
  disconnect: (callback) ->
    debug 'broker disconnect'
    delete brokers[@address]
    return callback null

  ## Manipulating queues
