io.jboot.components.mq.qpidmq

类 JbootQpidmqImpl

java.lang.Object

io.jboot.components.mq.JbootmqBase

io.jboot.components.mq.qpidmq.JbootQpidmqImpl

所有已实现的接口:

Jbootmq

public class JbootQpidmqImpl
extends JbootmqBase
implements Jbootmq

版本:

V1.0

作者:

徐海峰 （27533892@qq.com）

嵌套类概要

嵌套类

限定符和类型	类和说明
private class	JbootQpidmqImpl.ReceiveMsgThread

字段概要

字段

限定符和类型	字段和说明
private org.apache.qpid.jms.Connection	connection
private static com.jfinal.log.Log	LOG
private JbootQpidmqConfig	qpidConfig
private Thread	queueThread
private boolean	serializerEnable
private Thread	topicThread

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

channels, config, isStarted, serializer, syncReceiveMessageChannels

构造器概要

构造器

构造器和说明
JbootQpidmqImpl(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	enqueue(Object message, String toChannel)
String	getConnectionUrl()
String	getQueueAddr(String channel)
String	getTopicAddr(String channel)
protected void	onStartListening()
protected void	onStopListening()
void	publish(Object message, String toChannel)
void	sendMsg(String addr, Object message)
void	startReceiveMsgThread()

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

字段详细资料

LOG

private static final com.jfinal.log.Log LOG

connection

private org.apache.qpid.jms.Connection connection

serializerEnable

private boolean serializerEnable

qpidConfig

private JbootQpidmqConfig qpidConfig

queueThread

private Thread queueThread

topicThread

private Thread topicThread

构造器详细资料

JbootQpidmqImpl

public JbootQpidmqImpl(JbootmqConfig config)

方法详细资料

onStartListening

protected void onStartListening()

指定者:

onStartListening 在类中 JbootmqBase

onStopListening

protected void onStopListening()

指定者:

onStopListening 在类中 JbootmqBase

enqueue

public void enqueue(Object message,
                    String toChannel)

指定者:

enqueue 在接口中 Jbootmq

publish

public void publish(Object message,
                    String toChannel)

指定者:

publish 在接口中 Jbootmq

sendMsg

public void sendMsg(String addr,
                    Object message)

getConnectionUrl

public String getConnectionUrl()

getQueueAddr

public String getQueueAddr(String channel)

getTopicAddr

public String getTopicAddr(String channel)

startReceiveMsgThread

public void startReceiveMsgThread()
                           throws Exception

抛出:

Exception