xin.manong.weapon.aliyun.ons

类 ONSConsumer

java.lang.Object

xin.manong.weapon.aliyun.ons.ONSConsumer

所有已实现的接口:

Rebuildable

public class ONSConsumer
extends Object
implements Rebuildable

ONS消息消费器

作者:

frankcl

字段概要

字段

限定符和类型	字段和说明
protected ONSConsumerConfig	config
protected com.aliyun.openservices.ons.api.Consumer	consumer
protected List<RebuildListener>	rebuildListeners

构造器概要

构造器

构造器和说明
ONSConsumer(ONSConsumerConfig config)

方法概要

限定符和类型	方法和说明
void	addRebuildListener(RebuildListener listener) 添加重建监听器
void	rebuild()
boolean	start() 启动消息消费器
void	stop() 停止消息消费器

从类继承的方法 java.lang.Object

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

字段详细资料

config

protected ONSConsumerConfig config

rebuildListeners

protected List<RebuildListener> rebuildListeners

consumer

protected com.aliyun.openservices.ons.api.Consumer consumer

构造器详细资料

ONSConsumer

public ONSConsumer(ONSConsumerConfig config)

方法详细资料

rebuild

public void rebuild()

指定者:

rebuild 在接口中 Rebuildable

start

public boolean start()

启动消息消费器

返回:

启动成功返回true，否则返回false

stop

public void stop()

停止消息消费器

addRebuildListener

public void addRebuildListener(RebuildListener listener)

添加重建监听器

参数:

listener - 重建监听器