 
   # just listen
   listen: (channel, topic, callback) ->
-    sub = core.bus.subscribe
+    sub = bus.subscribe
       channel: channel
       topic: topic
       callback: (data, envelope) ->

  signal: (channel, data) ->


# Expose 'bus' access for internal methods, wiretaps.
# Non-enumerable, non-configurable, non-assignable.
Object.defineProperty core, 'bus', {value: bus}


module.exports = core
        msg = "Responder with id #{responderId} timed out on channel '#{channel}'"
        err = new Error msg

        bus.publish
          channel: replyTo.channel
          topic: replyTo.topic.err
          data: err
