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() |
private static final com.jfinal.log.Log LOG
protected final JbootmqConfig config
private List<JbootmqMessageListener> globalListeners
private Map<String,List<JbootmqMessageListener>> channelListeners
protected Set<String> syncReceiveMessageChannels
protected JbootSerializer serializer
private ExecutorService threadPool
protected boolean isStarted
public JbootmqBase(JbootmqConfig config)
public void addMessageListener(JbootmqMessageListener listener)
addMessageListener 在接口中 Jbootmqpublic void addMessageListener(JbootmqMessageListener listener, String forChannel)
addMessageListener 在接口中 Jbootmqpublic final void addChannelListener(String channel, JbootmqMessageListener listener)
public void removeListener(JbootmqMessageListener listener)
removeListener 在接口中 Jbootmqpublic void removeAllListeners()
removeAllListeners 在接口中 Jbootmqpublic Collection<JbootmqMessageListener> getGlobalListeners()
getGlobalListeners 在接口中 Jbootmqpublic Collection<JbootmqMessageListener> getListenersByChannel(String channel)
getListenersByChannel 在接口中 Jbootmqpublic void notifyListeners(String channel, Object message, MessageContext context)
protected boolean notifyListeners(String channel, Object message, MessageContext context, Collection<JbootmqMessageListener> listeners)
public JbootSerializer getSerializer()
public boolean startListening()
startListening 在接口中 Jbootmqpublic boolean stopListening()
stopListening 在接口中 Jbootmqpublic boolean isStarted()
protected abstract void onStartListening()
protected abstract void onStopListening()
public JbootmqConfig getConfig()
public void setSerializer(JbootSerializer serializer)
public ExecutorService getThreadPool()
public void setThreadPool(ExecutorService threadPool)
Copyright © 2024. All rights reserved.