org.springframework.cloud.stream.binder.rocketmq.consuming

Class RocketMQListenerBindingContainer

java.lang.Object

org.springframework.cloud.stream.binder.rocketmq.consuming.RocketMQListenerBindingContainer

All Implemented Interfaces:

org.apache.rocketmq.spring.support.RocketMQListenerContainer, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class RocketMQListenerBindingContainer
extends Object
implements org.springframework.beans.factory.InitializingBean, org.apache.rocketmq.spring.support.RocketMQListenerContainer, org.springframework.context.SmartLifecycle

Author:

Jim

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	RocketMQListenerBindingContainer.DefaultMessageListenerConcurrently
class	RocketMQListenerBindingContainer.DefaultMessageListenerOrderly

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
RocketMQListenerBindingContainer(org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> rocketMQConsumerProperties, RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties, RocketMQMessageChannelBinder rocketMQMessageChannelBinder)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
String	getCharset()
org.apache.rocketmq.spring.annotation.ConsumeMode	getConsumeMode()
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer	getConsumer()
String	getConsumerGroup()
int	getConsumeThreadMax()
int	getDelayLevelWhenNextConsume()
org.apache.rocketmq.spring.annotation.MessageModel	getMessageModel()
String	getNameServer()
int	getPhase()
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>	getRocketMQConsumerProperties()
org.apache.rocketmq.spring.core.RocketMQListener	getRocketMQListener()
String	getSelectorExpression()
org.apache.rocketmq.spring.annotation.SelectorType	getSelectorType()
long	getSuspendCurrentQueueTimeMillis()
String	getTopic()
boolean	isAutoStartup()
boolean	isRunning()
void	setCharset(String charset)
void	setConsumer(org.apache.rocketmq.client.consumer.DefaultMQPushConsumer consumer)
void	setConsumerGroup(String consumerGroup)
void	setConsumeThreadMax(int consumeThreadMax)
void	setDelayLevelWhenNextConsume(int delayLevelWhenNextConsume)
void	setNameServer(String nameServer)
void	setRocketMQListener(org.apache.rocketmq.spring.core.RocketMQListener rocketMQListener)
void	setSuspendCurrentQueueTimeMillis(long suspendCurrentQueueTimeMillis)
void	setTopic(String topic)
void	setupMessageListener(org.apache.rocketmq.spring.core.RocketMQListener<?> rocketMQListener)
void	start()
void	stop()
void	stop(Runnable callback)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RocketMQListenerBindingContainer

public RocketMQListenerBindingContainer(org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> rocketMQConsumerProperties,
                                        RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
                                        RocketMQMessageChannelBinder rocketMQMessageChannelBinder)

Method Detail

setupMessageListener

public void setupMessageListener(org.apache.rocketmq.spring.core.RocketMQListener<?> rocketMQListener)

Specified by:

setupMessageListener in interface org.apache.rocketmq.spring.support.RocketMQListenerContainer

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

Specified by:

getPhase in interface org.springframework.context.SmartLifecycle

toString

public String toString()

Overrides:

toString in class Object

getSuspendCurrentQueueTimeMillis

public long getSuspendCurrentQueueTimeMillis()

setSuspendCurrentQueueTimeMillis

public void setSuspendCurrentQueueTimeMillis(long suspendCurrentQueueTimeMillis)

getDelayLevelWhenNextConsume

public int getDelayLevelWhenNextConsume()

setDelayLevelWhenNextConsume

public void setDelayLevelWhenNextConsume(int delayLevelWhenNextConsume)

getNameServer

public String getNameServer()

setNameServer

public void setNameServer(String nameServer)

getConsumerGroup

public String getConsumerGroup()

setConsumerGroup

public void setConsumerGroup(String consumerGroup)

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getConsumeThreadMax

public int getConsumeThreadMax()

setConsumeThreadMax

public void setConsumeThreadMax(int consumeThreadMax)

getCharset

public String getCharset()

setCharset

public void setCharset(String charset)

getRocketMQListener

public org.apache.rocketmq.spring.core.RocketMQListener getRocketMQListener()

setRocketMQListener

public void setRocketMQListener(org.apache.rocketmq.spring.core.RocketMQListener rocketMQListener)

getConsumer

public org.apache.rocketmq.client.consumer.DefaultMQPushConsumer getConsumer()

setConsumer

public void setConsumer(org.apache.rocketmq.client.consumer.DefaultMQPushConsumer consumer)

getRocketMQConsumerProperties

public org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> getRocketMQConsumerProperties()

getConsumeMode

public org.apache.rocketmq.spring.annotation.ConsumeMode getConsumeMode()

getSelectorType

public org.apache.rocketmq.spring.annotation.SelectorType getSelectorType()

getSelectorExpression

public String getSelectorExpression()

getMessageModel

public org.apache.rocketmq.spring.annotation.MessageModel getMessageModel()