程序包 com.sh.wf.mq.activemq

类 ActiveMQProducer

java.lang.Object
com.sh.wf.mq.activemq.ActiveMQBase
com.sh.wf.mq.activemq.ActiveMQProducer
public class ActiveMQProducer extends ActiveMQBase

Description: ActiveMQ消息中间件发布消息

Title:首亨软件 - TSS/CRM等

从以下版本开始:
2016年12月5日

  • 字段详细资料

    • messageProducer

      protected javax.jms.MessageProducer messageProducer

  • 构造器详细资料

    • ActiveMQProducer

      public ActiveMQProducer()

    • ActiveMQProducer

      public ActiveMQProducer(String topicName)

  • 方法详细资料

    • getInstance

      public static ActiveMQProducer getInstance()

    • getInstance

      public static ActiveMQProducer getInstance(String topicId)

    • processAfterGetConnecion

      public void processAfterGetConnecion(org.apache.activemq.pool.PooledConnection connection)

    • sendMessage

      public boolean sendMessage(String msg)
      发送消息
      参数:
      msg - String
      返回:
      boolean

    • sendObjectMessage

      public boolean sendObjectMessage(Serializable obj)
      发送对象
      参数:
      obj - 实现了Serializable可序列化的对象
      返回:
      boolean

    • sendMessageSecurity

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

    • sendObjectMessageSecurity

      public boolean sendObjectMessageSecurity(Serializable obj)
      发送消息，发送完毕后会马上关闭
      参数:
      obj - Serializable
      返回:
      boolean

    • processConnect

      public void processConnect(javax.jms.Topic topic) throws javax.jms.JMSException
      指定者:
      processConnect 在类中 ActiveMQBase
      抛出:
      javax.jms.JMSException