NewDelayRelay creates a DelayRelay that consumes from `channel` and relays messages to `publisher`.

NewQueueConsumerChannel returns a ConsumerChannel that uses Redis queues for communication.

NewTopicConsumerChannel returns a ConsumerChannel that uses Redis PubSub for communication.

RelayFilter objects provide a predicate function to determine whether a message should be passed to the next stage.