ActiveMQConsumer

java.lang.Object

com.sh.wf.mq.activemq.ActiveMQBase

com.sh.wf.mq.activemq.ActiveMQConsumer

public class ActiveMQConsumer extends ActiveMQBase

Description:

Title:首亨软件 - TSS/CRM等

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

字段概要

从类继承的字段 com.sh.wf.mq.activemq.ActiveMQBase
DEFAULT_TOPIC, session, topicName
构造器概要

构造器

构造器

说明

ActiveMQConsumer()

ActiveMQConsumer(String topicName)
方法概要

修饰符和类型

方法

说明

static ActiveMQConsumer

getInstance()

static ActiveMQConsumer

getInstance(String topic)

javax.jms.MessageListener

getListener()

void

processConnect(javax.jms.Topic topic)

void

removeListener()

移除定时器

boolean

setListener(javax.jms.MessageListener listener)

设置监听器

boolean

subscribe(ActiveMQCallBack callback)

boolean

subscribe(ActiveMQCallBack callback, int ackMode)

订阅服务

从类继承的方法 com.sh.wf.mq.activemq.ActiveMQBase
commit, connect, connect, disconnect, getTopicName, rollback, setTopicName

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料
- ActiveMQConsumer
  
  public ActiveMQConsumer()
- ActiveMQConsumer
  
  public ActiveMQConsumer(String topicName)
方法详细资料
- getInstance
  
  public static ActiveMQConsumer getInstance()
- getInstance
  
  public static ActiveMQConsumer getInstance(String topic)
- processConnect
  
  public void processConnect(javax.jms.Topic topic) throws javax.jms.JMSException
  
  指定者:
  
  processConnect 在类中 ActiveMQBase
  
  抛出:
  
  javax.jms.JMSException
- getListener
  
  public javax.jms.MessageListener getListener()
- subscribe
  
  public boolean subscribe(ActiveMQCallBack callback)
- subscribe
  
  public boolean subscribe(ActiveMQCallBack callback, int ackMode)
  
  订阅服务
  
  参数:
  
  callback - ActiveMQCallBack
  
  ackMode - JMS消息确认机制,在session接口中定义的几个常量 AUTO_ACKNOWLEDGE = 1 自动确认(默认) CLIENT_ACKNOWEDGE = 2 客户端手动确认 DUPS_OK_ACKNOWLEDGE = 3 自动批量确认 SESSION_TRANSACTED = 0 事务提交并确认如果为手动确认，需要执行：message.acknowledge();进行消息确认，并且返回false会进行补发
  
  返回:
  
  boolean
- setListener
  
  public boolean setListener(javax.jms.MessageListener listener)
  
  设置监听器
  
  参数:
  
  listener - MessageListener
  
  返回:
  
  boolean
- removeListener
  
  public void removeListener()
  
  移除定时器