com.eworkcloud.rocket

Class ConsumeListener

java.lang.Object

com.eworkcloud.rocket.ConsumeListener

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean

public abstract class ConsumeListener
extends Object
implements org.springframework.beans.factory.DisposableBean

Constructor Summary

Constructors

Constructor and Description
ConsumeListener()

Method Summary

Modifier and Type	Method and Description
void	destroy()
protected abstract void	handle(com.aliyun.mq.http.model.Message message)
void	startup(com.aliyun.mq.http.MQConsumer consumer)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumeListener

public ConsumeListener()

Method Detail

startup

public void startup(com.aliyun.mq.http.MQConsumer consumer)

destroy

public void destroy()
             throws Exception

Specified by:

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

Throws:

Exception

handle

protected abstract void handle(com.aliyun.mq.http.model.Message message)