程序包 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日

  • 构造器详细资料

    • RabbitMQProducer

      public RabbitMQProducer()

    • RabbitMQProducer

      public RabbitMQProducer(String exchange)

    • RabbitMQProducer

      public RabbitMQProducer(String connType, String exchange)

  • 方法详细资料

    • getInstance

      public static RabbitMQProducer getInstance()

    • getInstance

      public static RabbitMQProducer getInstance(String exchange)

    • getInstance

      public static RabbitMQProducer getInstance(String connType, String exchange)

    • setConnType

      public RabbitMQProducer setConnType(String connType)
      覆盖:
      setConnType 在类中 RabbitMQBase

    • sendMessageRoute

      public boolean sendMessageRoute(String msg, String routeKey)
      路由消息，不离线消息，可能丢失消息
      参数:
      msg - 发送消息
      routeKey - 路由值
      返回:
      boolean

    • sendMessageRoute

      public boolean sendMessageRoute(String msg, String routeKey, boolean durable)
      发送消息，路由模式
      参数:
      msg - 发送消息
      routeKey - 路由
      durable - 是否离线消息，默认：false
      返回:
      boolean

    • sendMessageTopic

      public boolean sendMessageTopic(String msg, String routeKey)
      topic发送消息，不离线消息，可能丢失消息
      参数:
      msg - 发送消息
      routeKey - 路由值
      返回:
      boolean

    • sendMessageTopic

      public boolean sendMessageTopic(String msg, String routeKey, boolean durable)
      发送消息 topic模式
      参数:
      msg - 发送消息
      routeKey - 路由值
      durable - 是否离线消息，默认：false
      返回:
      boolean

    • sendMessage

      public boolean sendMessage(String msg)
      发送消息 发布订阅模式 不离线消息消息，可能丢失消息
      参数:
      msg - 发送消息
      返回:
      boolean

    • sendMessage

      public boolean sendMessage(String msg, boolean durable)
      发送消息 发布订阅模式
      参数:
      msg - 发送消息
      durable - 是否离线消息，默认：false
      返回:
      boolean

    • sendDelayMessage

      public boolean sendDelayMessage(String msg, int timeMills)
      发送消息 发布订阅模式 不离线消息消息，可能丢失消息
      参数:
      msg - 发送消息
      返回:
      boolean

    • sendDelayMessage

      public boolean sendDelayMessage(String msg, boolean durable, int timeMills)
      发送消息 发布订阅模式
      参数:
      msg - 发送消息
      durable - 是否离线消息，默认：false
      返回:
      boolean

    • sendDelayMessage

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

    • sendMessageSecurity

      public boolean sendMessageSecurity(String msg)

    • sendMessageSecurity

      public boolean sendMessageSecurity(String msg, boolean durable)
      发送消息，发送完毕后会马上关闭
      参数:
      msg - String
      durable - boolean
      返回:
      boolean

    • sendDelayMessageSecurity

      public boolean sendDelayMessageSecurity(String msg, boolean durable, int timeMills)