org.springframework.cloud.stream.binder.rocketmq.properties

Class RocketMQConsumerProperties

java.lang.Object

org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

public class RocketMQConsumerProperties
extends Object

Author:

Timur Valiev, Jim

Constructor Summary

Constructors

Constructor and Description
RocketMQConsumerProperties()

Method Summary

Modifier and Type	Method and Description
Boolean	getBroadcasting()
int	getDelayLevelWhenNextConsume()
Boolean	getEnabled()
Boolean	getOrderly()
String	getSql()
long	getSuspendCurrentQueueTimeMillis()
String	getTags()
void	setBroadcasting(Boolean broadcasting)
void	setDelayLevelWhenNextConsume(int delayLevelWhenNextConsume)
void	setEnabled(Boolean enabled)
void	setOrderly(Boolean orderly)
void	setSql(String sql)
void	setSuspendCurrentQueueTimeMillis(long suspendCurrentQueueTimeMillis)
void	setTags(String tags)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocketMQConsumerProperties

public RocketMQConsumerProperties()

Method Detail

getTags

public String getTags()

setTags

public void setTags(String tags)

getSql

public String getSql()

setSql

public void setSql(String sql)

getOrderly

public Boolean getOrderly()

setOrderly

public void setOrderly(Boolean orderly)

getEnabled

public Boolean getEnabled()

setEnabled

public void setEnabled(Boolean enabled)

getBroadcasting

public Boolean getBroadcasting()

setBroadcasting

public void setBroadcasting(Boolean broadcasting)

getDelayLevelWhenNextConsume

public int getDelayLevelWhenNextConsume()

setDelayLevelWhenNextConsume

public void setDelayLevelWhenNextConsume(int delayLevelWhenNextConsume)

getSuspendCurrentQueueTimeMillis

public long getSuspendCurrentQueueTimeMillis()

setSuspendCurrentQueueTimeMillis

public void setSuspendCurrentQueueTimeMillis(long suspendCurrentQueueTimeMillis)