Package com.alibaba.cloud.stream.binder.rocketmq.properties

Class RocketMQConsumerProperties.Push

java.lang.Object
com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties.Push
All Implemented Interfaces:
Serializable
Enclosing class:
RocketMQConsumerProperties
public static class RocketMQConsumerProperties.Push extends Object implements Serializable
See Also:

  • Constructor Details

    • Push

      public Push()

  • Method Details

    • getOrderly

      public boolean getOrderly()

    • setOrderly

      public void setOrderly(boolean orderly)

    • getSuspendCurrentQueueTimeMillis

      public int getSuspendCurrentQueueTimeMillis()

    • setSuspendCurrentQueueTimeMillis

      public void setSuspendCurrentQueueTimeMillis(int suspendCurrentQueueTimeMillis)

    • getMaxReconsumeTimes

      public int getMaxReconsumeTimes()

    • setMaxReconsumeTimes

      public void setMaxReconsumeTimes(int maxReconsumeTimes)

    • getDelayLevelWhenNextConsume

      public int getDelayLevelWhenNextConsume()

    • setDelayLevelWhenNextConsume

      public void setDelayLevelWhenNextConsume(int delayLevelWhenNextConsume)

    • getPullThresholdForTopic

      public int getPullThresholdForTopic()

    • setPullThresholdForTopic

      public void setPullThresholdForTopic(int pullThresholdForTopic)

    • getPullThresholdSizeForTopic

      public int getPullThresholdSizeForTopic()

    • setPullThresholdSizeForTopic

      public void setPullThresholdSizeForTopic(int pullThresholdSizeForTopic)

    • getPullInterval

      public long getPullInterval()

    • setPullInterval

      public void setPullInterval(long pullInterval)

    • getConsumeMessageBatchMaxSize

      public int getConsumeMessageBatchMaxSize()

    • setConsumeMessageBatchMaxSize

      public void setConsumeMessageBatchMaxSize(int consumeMessageBatchMaxSize)

    • getConsumeTimeout

      public long getConsumeTimeout()

    • setConsumeTimeout

      public void setConsumeTimeout(long consumeTimeout)