io.jboot.components.mq.redismq

类 JbootRedismqImpl

java.lang.Object

io.jboot.components.mq.JbootmqBase

io.jboot.components.mq.redismq.JbootRedismqImpl

所有已实现的接口:

Jbootmq, Runnable

public class JbootRedismqImpl
extends JbootmqBase
implements Jbootmq, Runnable

字段概要

字段

限定符和类型	字段和说明
private Integer	database
private Thread	dequeueThread
private long	interval
private redis.clients.jedis.BinaryJedisPubSub	jedisPubSub
private static com.jfinal.log.Log	LOG
private Map<String,String>	outterChannelMap
private JbootRedis	redis

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

channels, config, isStarted, serializer, syncReceiveMessageChannels

构造器概要

构造器

构造器和说明
JbootRedismqImpl(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	doExecuteDequeue()
void	enqueue(Object message, String toChannel)
long	getInterval()
protected void	onStartListening()
protected void	onStopListening()
void	publish(Object message, String toChannel)
void	run()
void	setInterval(long interval)

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

redis

private JbootRedis redis

dequeueThread

private Thread dequeueThread

jedisPubSub

private redis.clients.jedis.BinaryJedisPubSub jedisPubSub

interval

private long interval

database

private Integer database

outterChannelMap

private Map<String,String> outterChannelMap

构造器详细资料

JbootRedismqImpl

public JbootRedismqImpl(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

run

public void run()

指定者:

run 在接口中 Runnable

doExecuteDequeue

public void doExecuteDequeue()

getInterval

public long getInterval()

setInterval

public void setInterval(long interval)