io.jboot.components.mq.aliyunmq

类 JbootAliyunmqImpl

java.lang.Object

io.jboot.components.mq.JbootmqBase

io.jboot.components.mq.aliyunmq.JbootAliyunmqImpl

所有已实现的接口:

Jbootmq

public class JbootAliyunmqImpl
extends JbootmqBase
implements Jbootmq

字段概要

字段

限定符和类型	字段和说明
private JbootAliyunmqConfig	aliyunmqConfig
private com.aliyun.openservices.ons.api.Consumer	consumer
private static com.jfinal.log.Log	LOG
private com.aliyun.openservices.ons.api.Producer	producer

从类继承的字段 io.jboot.components.mq.JbootmqBase

channels, config, isStarted, serializer, syncReceiveMessageChannels

构造器概要

构造器

构造器和说明
JbootAliyunmqImpl(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	createProducer()
Properties	createProperties()
void	enqueue(Object message, String toChannel)
com.aliyun.openservices.ons.api.Producer	getProducer()
protected void	onStartListening()
protected void	onStopListening()
void	publish(Object message, String toChannel)
void	startBroadCastConsumer()
void	startQueueConsumer()

从类继承的方法 io.jboot.components.mq.JbootmqBase

addChannelListener, addMessageListener, addMessageListener, getConfig, getGlobalListeners, getListenersByChannel, getSerializer, getThreadPool, isStarted, notifyListeners, notifyListeners, removeAllListeners, removeListener, setSerializer, setThreadPool, startListening, stopListening

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

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

从接口继承的方法 io.jboot.components.mq.Jbootmq

addMessageListener, addMessageListener, getConfig, getGlobalListeners, getListenersByChannel, removeAllListeners, removeListener, startListening, stopListening

字段详细资料

LOG

private static final com.jfinal.log.Log LOG

producer

private com.aliyun.openservices.ons.api.Producer producer

consumer

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

aliyunmqConfig

private JbootAliyunmqConfig aliyunmqConfig

构造器详细资料

JbootAliyunmqImpl

public JbootAliyunmqImpl(JbootmqConfig config)

方法详细资料

onStartListening

protected void onStartListening()

指定者:

onStartListening 在类中 JbootmqBase

onStopListening

protected void onStopListening()

指定者:

onStopListening 在类中 JbootmqBase

startQueueConsumer

public void startQueueConsumer()

startBroadCastConsumer

public void startBroadCastConsumer()

enqueue

public void enqueue(Object message,
                    String toChannel)

指定者:

enqueue 在接口中 Jbootmq

publish

public void publish(Object message,
                    String toChannel)

指定者:

publish 在接口中 Jbootmq

getProducer

public com.aliyun.openservices.ons.api.Producer getProducer()

createProducer

public void createProducer()

createProperties

public Properties createProperties()