Class RedisConsumerProperties

java.lang.Object
org.springframework.cloud.fn.consumer.redis.RedisConsumerProperties

@ConfigurationProperties("redis.consumer") @Validated public class RedisConsumerProperties extends Object
Used to configure those Redis Sink module options that are not related to connecting to Redis.
Author:
Eric Bottard, Mark Pollack, Artem Bilan, Soby Chacko
  • Constructor Details

    • RedisConsumerProperties

      public RedisConsumerProperties()
  • Method Details

    • keyExpression

      public Expression keyExpression()
    • queueExpression

      public Expression queueExpression()
    • topicExpression

      public Expression topicExpression()
    • getTopicExpression

      public String getTopicExpression()
    • setTopicExpression

      public void setTopicExpression(String topicExpression)
    • getQueueExpression

      public String getQueueExpression()
    • setQueueExpression

      public void setQueueExpression(String queueExpression)
    • getKeyExpression

      public String getKeyExpression()
    • setKeyExpression

      public void setKeyExpression(String keyExpression)
    • getKey

      public String getKey()
    • setKey

      public void setKey(String key)
    • getQueue

      public String getQueue()
    • setQueue

      public void setQueue(String queue)
    • getTopic

      public String getTopic()
    • setTopic

      public void setTopic(String topic)
    • isMutuallyExclusive

      @AssertTrue(message="Exactly one of \'queue\', \'queueExpression\', \'key\', \'keyExpression\', \'topic\' and \'topicExpression\' must be set") public @jakarta.validation.constraints.AssertTrue(message="Exactly one of \'queue\', \'queueExpression\', \'key\', \'keyExpression\', \'topic\' and \'topicExpression\' must be set") boolean isMutuallyExclusive()