io.jboot.components.mq.activemq

类 JbootActivemq

java.lang.Object

io.jboot.components.mq.JbootmqBase

io.jboot.components.mq.activemq.JbootActivemq

所有已实现的接口:

Jbootmq

public class JbootActivemq
extends JbootmqBase
implements Jbootmq

字段概要

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

channels, config, isStarted, serializer, syncReceiveMessageChannels

构造器概要

构造器

构造器和说明
JbootActivemq(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	enqueue(Object message, String toChannel)
protected void	onStartListening()
protected void	onStopListening()
void	publish(Object message, String toChannel)

从类继承的方法 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

构造器详细资料

JbootActivemq

public JbootActivemq(JbootmqConfig config)

方法详细资料

enqueue

public void enqueue(Object message,
                    String toChannel)

指定者:

enqueue 在接口中 Jbootmq

publish

public void publish(Object message,
                    String toChannel)

指定者:

publish 在接口中 Jbootmq

onStartListening

protected void onStartListening()

指定者:

onStartListening 在类中 JbootmqBase

onStopListening

protected void onStopListening()

指定者:

onStopListening 在类中 JbootmqBase