Package org.springframework.cloud.stream.test.binder

Interface MessageCollector

public interface MessageCollector
Maintains a map between (output) channels and messages received (in FIFO order). To be injected in tests that can then run assertions on the enqueued messages.
Author:
Eric Bottard

  • Method Summary

    Modifier and Type
    Method
    Description
    BlockingQueue<org.springframework.messaging.Message<?>>
    forChannel(org.springframework.messaging.MessageChannel channel)
    Obtain a queue that will receive messages sent to the given channel.

  • Method Details

    • forChannel

      BlockingQueue<org.springframework.messaging.Message<?>> forChannel(org.springframework.messaging.MessageChannel channel)
      Obtain a queue that will receive messages sent to the given channel.
      Parameters:
      channel - message channel
      Returns:
      blocking queue for stored message