gistfile1.groovy

  def "subscriber receives message"() {
    given: "An async event bus"
    def eventBus = new AsyncEventBus(Executors.newCachedThreadPool())

    and: "A Fake Service"
    def vars = new BlockingVariables()
    def fakeService = Stub(FictionalService) {
      process(_) >> { PersonMessage message -> vars.message = message }
    }

    and: "A Subscriber"
    def subscriber = new PersonSubscriber(eventBus, fakeService)

    and: "A Person Message"
    def personMessage = new PersonMessage(new Person(), PersonMessage.ACTION.CREATE)

    when: "A message is published"
    eventBus.post(personMessage)

    then: "Our publisher delegates the message to our service"
    vars.message == personMessage
  }