| 程序包 | 说明 |
|---|---|
| io.jboot.components.mq |
| 限定符和类型 | 字段和说明 |
|---|---|
private Map<String,List<JbootmqMessageListener>> |
JbootmqBase.channelListeners |
private List<JbootmqMessageListener> |
JbootmqBase.globalListeners |
| 限定符和类型 | 方法和说明 |
|---|---|
Collection<JbootmqMessageListener> |
Jbootmq.getGlobalListeners() |
Collection<JbootmqMessageListener> |
JbootmqBase.getGlobalListeners() |
Collection<JbootmqMessageListener> |
Jbootmq.getListenersByChannel(String channel) |
Collection<JbootmqMessageListener> |
JbootmqBase.getListenersByChannel(String channel) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
JbootmqBase.addChannelListener(String channel,
JbootmqMessageListener listener) |
void |
Jbootmq.addMessageListener(JbootmqMessageListener listener) |
void |
JbootmqBase.addMessageListener(JbootmqMessageListener listener) |
void |
Jbootmq.addMessageListener(JbootmqMessageListener listener,
String forChannel) |
void |
JbootmqBase.addMessageListener(JbootmqMessageListener listener,
String forChannel) |
void |
Jbootmq.removeListener(JbootmqMessageListener listener) |
void |
JbootmqBase.removeListener(JbootmqMessageListener listener) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected boolean |
JbootmqBase.notifyListeners(String channel,
Object message,
MessageContext context,
Collection<JbootmqMessageListener> listeners) |
Copyright © 2024. All rights reserved.