com.sh.wf.mq.activemq

类 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日

版本:

3.0

作者:

江兴春

字段概要

从类继承的字段 com.sh.wf.mq.activemq.ActiveMQBase

DEFAULT_TOPIC

构造器概要

构造器

构造器和说明
ActiveMQConsumer()
ActiveMQConsumer(java.lang.String topicName)

方法概要

限定符和类型	方法和说明
static ActiveMQConsumer	getInstance()
static ActiveMQConsumer	getInstance(java.lang.String topic)
javax.jms.MessageListener	getListener()
static void	main(java.lang.String[] args)
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

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

构造器详细资料

ActiveMQConsumer

public ActiveMQConsumer()

ActiveMQConsumer

public ActiveMQConsumer(java.lang.String topicName)

方法详细资料

getInstance

public static ActiveMQConsumer getInstance()

getInstance

public static ActiveMQConsumer getInstance(java.lang.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()

移除定时器

main

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