io.jboot.components.mq.rabbitmq

类 JbootRabbitmqImpl

java.lang.Object

io.jboot.components.mq.JbootmqBase

io.jboot.components.mq.rabbitmq.JbootRabbitmqImpl

所有已实现的接口:

Jbootmq

public class JbootRabbitmqImpl
extends JbootmqBase
implements Jbootmq

doc : http://www.rabbitmq.com/api-guide.html

字段概要

字段

限定符和类型	字段和说明
private JbootApplicationConfig	appConfig
private Map<String,com.rabbitmq.client.Channel>	channelMap
private com.rabbitmq.client.Connection	connection
private JbootRabbitmqConfig	rabbitmqConfig

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

channels, config, isStarted, serializer, syncReceiveMessageChannels

构造器概要

构造器

构造器和说明
JbootRabbitmqImpl(JbootmqConfig config)

方法概要

限定符和类型	方法和说明
void	bindChannel(com.rabbitmq.client.Channel channel, String name, String orginaChannelName)
String	buildBroadcastChannelName(String channel)
void	enqueue(Object message, String toChannel)
com.rabbitmq.client.Channel	getChannel(String toChannel, boolean queueMode)
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

字段详细资料

connection

private com.rabbitmq.client.Connection connection

channelMap

private Map<String,com.rabbitmq.client.Channel> channelMap

rabbitmqConfig

private JbootRabbitmqConfig rabbitmqConfig

appConfig

private JbootApplicationConfig appConfig

构造器详细资料

JbootRabbitmqImpl

public JbootRabbitmqImpl(JbootmqConfig config)

方法详细资料

onStartListening

protected void onStartListening()

指定者:

onStartListening 在类中 JbootmqBase

onStopListening

protected void onStopListening()

指定者:

onStopListening 在类中 JbootmqBase

bindChannel

public void bindChannel(com.rabbitmq.client.Channel channel,
                        String name,
                        String orginaChannelName)

getChannel

public com.rabbitmq.client.Channel getChannel(String toChannel,
                                              boolean queueMode)

buildBroadcastChannelName

public String buildBroadcastChannelName(String channel)

enqueue

public void enqueue(Object message,
                    String toChannel)

指定者:

enqueue 在接口中 Jbootmq

publish

public void publish(Object message,
                    String toChannel)

指定者:

publish 在接口中 Jbootmq