public interface Jbootmq
| 限定符和类型 | 方法和说明 |
|---|---|
void |
addMessageListener(JbootmqMessageListener listener) |
void |
addMessageListener(JbootmqMessageListener listener,
String forChannel) |
void |
enqueue(Object message,
String toChannel) |
JbootmqConfig |
getConfig() |
Collection<JbootmqMessageListener> |
getGlobalListeners() |
Collection<JbootmqMessageListener> |
getListenersByChannel(String channel) |
void |
publish(Object message,
String toChannel) |
void |
removeAllListeners() |
void |
removeListener(JbootmqMessageListener listener) |
boolean |
startListening() |
boolean |
stopListening() |
void addMessageListener(JbootmqMessageListener listener)
void addMessageListener(JbootmqMessageListener listener, String forChannel)
void removeListener(JbootmqMessageListener listener)
void removeAllListeners()
Collection<JbootmqMessageListener> getGlobalListeners()
Collection<JbootmqMessageListener> getListenersByChannel(String channel)
boolean startListening()
boolean stopListening()
JbootmqConfig getConfig()
Copyright © 2024. All rights reserved.