com.sh.wf.mq.rabbitmq

类 RabbitMQProducer

java.lang.Object

com.sh.wf.mq.rabbitmq.RabbitMQBase

com.sh.wf.mq.rabbitmq.RabbitMQProducer

public class RabbitMQProducer
extends RabbitMQBase

Description:

Title:首亨软件 - 聚天平台

从以下版本开始:

2018年12月17日

版本:

3.0

作者:

江兴春

构造器概要

构造器

构造器和说明
RabbitMQProducer()
RabbitMQProducer(java.lang.String exchange)
RabbitMQProducer(java.lang.String connType, java.lang.String exchange)

方法概要

限定符和类型	方法和说明
static RabbitMQProducer	getInstance()
static RabbitMQProducer	getInstance(java.lang.String exchange)
static RabbitMQProducer	getInstance(java.lang.String connType, java.lang.String exchange)
static void	main(java.lang.String[] args)
boolean	sendDelayMessage(java.lang.String msg, boolean durable, int timeMills) 发送消息 发布订阅模式
boolean	sendDelayMessage(java.lang.String msg, int timeMills) 发送消息 发布订阅模式 不离线消息消息，可能丢失消息
boolean	sendDelayMessage(java.lang.String msg, java.lang.String type, java.lang.String routeKey, boolean durable, int timeMills)
boolean	sendDelayMessageSecurity(java.lang.String msg, boolean durable, int timeMills)
boolean	sendMessage(java.lang.String msg) 发送消息 发布订阅模式 不离线消息消息，可能丢失消息
boolean	sendMessage(java.lang.String msg, boolean durable) 发送消息 发布订阅模式
boolean	sendMessageRoute(java.lang.String msg, java.lang.String routeKey) 路由消息，不离线消息，可能丢失消息
boolean	sendMessageRoute(java.lang.String msg, java.lang.String routeKey, boolean durable) 发送消息，路由模式
boolean	sendMessageSecurity(java.lang.String msg)
boolean	sendMessageSecurity(java.lang.String msg, boolean durable) 发送消息，发送完毕后会马上关闭
boolean	sendMessageTopic(java.lang.String msg, java.lang.String routeKey) topic发送消息，不离线消息，可能丢失消息
boolean	sendMessageTopic(java.lang.String msg, java.lang.String routeKey, boolean durable) 发送消息 topic模式
RabbitMQProducer	setConnType(java.lang.String connType)

从类继承的方法 com.sh.wf.mq.rabbitmq.RabbitMQBase

connect, connect, disconnect, getChannel

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RabbitMQProducer

public RabbitMQProducer()

RabbitMQProducer

public RabbitMQProducer(java.lang.String exchange)

RabbitMQProducer

public RabbitMQProducer(java.lang.String connType,
                        java.lang.String exchange)

方法详细资料

getInstance

public static RabbitMQProducer getInstance()

getInstance

public static RabbitMQProducer getInstance(java.lang.String exchange)

getInstance

public static RabbitMQProducer getInstance(java.lang.String connType,
                                           java.lang.String exchange)

setConnType

public RabbitMQProducer setConnType(java.lang.String connType)

覆盖:

setConnType 在类中 RabbitMQBase

sendMessageRoute

public boolean sendMessageRoute(java.lang.String msg,
                                java.lang.String routeKey)

路由消息，不离线消息，可能丢失消息

参数:

msg - 发送消息

routeKey - 路由值

返回:

boolean

sendMessageRoute

public boolean sendMessageRoute(java.lang.String msg,
                                java.lang.String routeKey,
                                boolean durable)

发送消息，路由模式

参数:

msg - 发送消息

routeKey - 路由

durable - 是否离线消息，默认：false

返回:

boolean

sendMessageTopic

public boolean sendMessageTopic(java.lang.String msg,
                                java.lang.String routeKey)

topic发送消息，不离线消息，可能丢失消息

参数:

msg - 发送消息

routeKey - 路由值

返回:

boolean

sendMessageTopic

public boolean sendMessageTopic(java.lang.String msg,
                                java.lang.String routeKey,
                                boolean durable)

发送消息 topic模式

参数:

msg - 发送消息

routeKey - 路由值

durable - 是否离线消息，默认：false

返回:

boolean

sendMessage

public boolean sendMessage(java.lang.String msg)

发送消息 发布订阅模式 不离线消息消息，可能丢失消息

参数:

msg - 发送消息

返回:

boolean

sendMessage

public boolean sendMessage(java.lang.String msg,
                           boolean durable)

发送消息 发布订阅模式

参数:

msg - 发送消息

durable - 是否离线消息，默认：false

返回:

boolean

sendDelayMessage

public boolean sendDelayMessage(java.lang.String msg,
                                int timeMills)

发送消息 发布订阅模式 不离线消息消息，可能丢失消息

参数:

msg - 发送消息

返回:

boolean

sendDelayMessage

public boolean sendDelayMessage(java.lang.String msg,
                                boolean durable,
                                int timeMills)

发送消息 发布订阅模式

参数:

msg - 发送消息

durable - 是否离线消息，默认：false

返回:

boolean

sendDelayMessage

public boolean sendDelayMessage(java.lang.String msg,
                                java.lang.String type,
                                java.lang.String routeKey,
                                boolean durable,
                                int timeMills)

sendMessageSecurity

public boolean sendMessageSecurity(java.lang.String msg)

sendMessageSecurity

public boolean sendMessageSecurity(java.lang.String msg,
                                   boolean durable)

发送消息，发送完毕后会马上关闭

参数:

msg - String

durable - boolean

返回:

boolean

sendDelayMessageSecurity

public boolean sendDelayMessageSecurity(java.lang.String msg,
                                        boolean durable,
                                        int timeMills)

main

public static void main(java.lang.String[] args)