io.jboot.components.mq

类 JbootmqBase

java.lang.Object

io.jboot.components.mq.JbootmqBase

所有已实现的接口:

Jbootmq

直接已知子类:

JbootActivemq, JbootAliyunmqImpl, JbootLocalmqImpl, JbootQpidmqImpl, JbootRabbitmqImpl, JbootRedismqImpl, JbootRocketmqImpl

public abstract class JbootmqBase
extends Object
implements Jbootmq

字段概要

字段

限定符和类型	字段和说明
private Map<String,List<JbootmqMessageListener>>	channelListeners
protected Set<String>	channels
protected JbootmqConfig	config
private List<JbootmqMessageListener>	globalListeners
protected boolean	isStarted
private static com.jfinal.log.Log	LOG
protected JbootSerializer	serializer
protected Set<String>	syncReceiveMessageChannels
private ExecutorService	threadPool

构造器概要

构造器

构造器和说明
JbootmqBase(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	addChannelListener(String channel, JbootmqMessageListener listener)
void	addMessageListener(JbootmqMessageListener listener)
void	addMessageListener(JbootmqMessageListener listener, String forChannel)
JbootmqConfig	getConfig()
Collection<JbootmqMessageListener>	getGlobalListeners()
Collection<JbootmqMessageListener>	getListenersByChannel(String channel)
JbootSerializer	getSerializer()
ExecutorService	getThreadPool()
boolean	isStarted()
void	notifyListeners(String channel, Object message, MessageContext context)
protected boolean	notifyListeners(String channel, Object message, MessageContext context, Collection<JbootmqMessageListener> listeners)
protected abstract void	onStartListening()
protected abstract void	onStopListening()
void	removeAllListeners()
void	removeListener(JbootmqMessageListener listener)
void	setSerializer(JbootSerializer serializer)
void	setThreadPool(ExecutorService threadPool)
boolean	startListening()
boolean	stopListening()

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

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

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

enqueue, publish

字段详细资料

LOG

private static final com.jfinal.log.Log LOG

config

protected final JbootmqConfig config

globalListeners

private List<JbootmqMessageListener> globalListeners

channelListeners

private Map<String,List<JbootmqMessageListener>> channelListeners

channels

protected Set<String> channels

syncReceiveMessageChannels

protected Set<String> syncReceiveMessageChannels

serializer

protected JbootSerializer serializer

threadPool

private ExecutorService threadPool

isStarted

protected boolean isStarted

构造器详细资料

JbootmqBase

public JbootmqBase(JbootmqConfig config)

方法详细资料

addMessageListener

public void addMessageListener(JbootmqMessageListener listener)

指定者:

addMessageListener 在接口中 Jbootmq

addMessageListener

public void addMessageListener(JbootmqMessageListener listener,
                               String forChannel)

指定者:

addMessageListener 在接口中 Jbootmq

addChannelListener

public final void addChannelListener(String channel,
                                     JbootmqMessageListener listener)

removeListener

public void removeListener(JbootmqMessageListener listener)

指定者:

removeListener 在接口中 Jbootmq

removeAllListeners

public void removeAllListeners()

指定者:

removeAllListeners 在接口中 Jbootmq

getGlobalListeners

public Collection<JbootmqMessageListener> getGlobalListeners()

指定者:

getGlobalListeners 在接口中 Jbootmq

getListenersByChannel

public Collection<JbootmqMessageListener> getListenersByChannel(String channel)

指定者:

getListenersByChannel 在接口中 Jbootmq

notifyListeners

public void notifyListeners(String channel,
                            Object message,
                            MessageContext context)

notifyListeners

protected boolean notifyListeners(String channel,
                                  Object message,
                                  MessageContext context,
                                  Collection<JbootmqMessageListener> listeners)

getSerializer

public JbootSerializer getSerializer()

startListening

public boolean startListening()

指定者:

startListening 在接口中 Jbootmq

stopListening

public boolean stopListening()

指定者:

stopListening 在接口中 Jbootmq

isStarted

public boolean isStarted()

onStartListening

protected abstract void onStartListening()

onStopListening

protected abstract void onStopListening()

getConfig

public JbootmqConfig getConfig()

指定者:

getConfig 在接口中 Jbootmq

setSerializer

public void setSerializer(JbootSerializer serializer)

getThreadPool

public ExecutorService getThreadPool()

setThreadPool

public void setThreadPool(ExecutorService threadPool)