io.jboot.components.mq.rocketmq

类 JbootRocketmqImpl

java.lang.Object

io.jboot.components.mq.JbootmqBase

io.jboot.components.mq.rocketmq.JbootRocketmqImpl

所有已实现的接口:

Jbootmq

public class JbootRocketmqImpl
extends JbootmqBase
implements Jbootmq

字段概要

字段

限定符和类型	字段和说明
private org.apache.rocketmq.client.consumer.DefaultMQPushConsumer	broadcastConsumer
private static com.jfinal.log.Log	LOG
private org.apache.rocketmq.client.producer.MQProducer	mqProducer
private org.apache.rocketmq.client.consumer.DefaultMQPushConsumer	queueConsumer
private JbootRocketmqConfig	rocketmqConfig

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

channels, config, isStarted, serializer, syncReceiveMessageChannels

构造器概要

构造器

构造器和说明
JbootRocketmqImpl(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	createMqProducer()
void	doSendMessage(Object message, String topic)
void	enqueue(Object message, String toChannel)
org.apache.rocketmq.client.producer.MQProducer	getMQProducer()
protected void	onStartListening()
protected void	onStopListening()
void	publish(Object message, String toChannel)
void	startBroadcastConsumer()
void	startQueueConsumer()

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

rocketmqConfig

private JbootRocketmqConfig rocketmqConfig

mqProducer

private org.apache.rocketmq.client.producer.MQProducer mqProducer

queueConsumer

private org.apache.rocketmq.client.consumer.DefaultMQPushConsumer queueConsumer

broadcastConsumer

private org.apache.rocketmq.client.consumer.DefaultMQPushConsumer broadcastConsumer

构造器详细资料

JbootRocketmqImpl

public JbootRocketmqImpl(JbootmqConfig config)

方法详细资料

onStartListening

protected void onStartListening()

指定者:

onStartListening 在类中 JbootmqBase

onStopListening

protected void onStopListening()

指定者:

onStopListening 在类中 JbootmqBase

startQueueConsumer

public void startQueueConsumer()
                        throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

startBroadcastConsumer

public void startBroadcastConsumer()
                            throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

enqueue

public void enqueue(Object message,
                    String toChannel)

指定者:

enqueue 在接口中 Jbootmq

publish

public void publish(Object message,
                    String toChannel)

指定者:

publish 在接口中 Jbootmq

doSendMessage

public void doSendMessage(Object message,
                          String topic)

getMQProducer

public org.apache.rocketmq.client.producer.MQProducer getMQProducer()
                                                             throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

createMqProducer

public void createMqProducer()
                      throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException