Scenario

pub-sub-scenario.coffee

  subscribe: () ->
    context = @context
    spire = @context.spire
    iteration = @context.iteration

    spire.messages.subscribe "channel #{iteration}", {maxCallCount: 1}, 
      (error,messages) ->
        if error
          context.error(error)
          return
        
        context.finish()
        
        # TODO: verify content of messages
        for message in messages
          console.log message