com.sh.wf.mq.activemq

类 ActiveMQBase

java.lang.Object

com.sh.wf.mq.activemq.ActiveMQBase

直接已知子类:

ActiveMQConsumer, ActiveMQProducer

public abstract class ActiveMQBase
extends java.lang.Object

Description:

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2016年12月5日

版本:

3.0

作者:

江兴春

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	DEFAULT_TOPIC

构造器概要

构造器

构造器和说明
ActiveMQBase()

方法概要

限定符和类型	方法和说明
void	commit() 提交请求
boolean	connect()
boolean	connect(int count, int ackMode) 建立连接
void	disconnect() 断开连接
java.lang.String	getTopicName()
abstract void	processConnect(javax.jms.Topic topic)
void	rollback() 回滚请求
void	setTopicName(java.lang.String topicName)

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

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

字段详细资料

DEFAULT_TOPIC

public static final java.lang.String DEFAULT_TOPIC

另请参阅:

常量字段值

构造器详细资料

ActiveMQBase

public ActiveMQBase()

方法详细资料

processConnect

public abstract void processConnect(javax.jms.Topic topic)
                             throws javax.jms.JMSException

抛出:

javax.jms.JMSException

connect

public boolean connect()

connect

public boolean connect(int count,
                       int ackMode)

建立连接

参数:

count - 当前连接次数，当有些未初始化错误会重新初始化后连接

ackMode - int

返回:

boolean

disconnect

public void disconnect()

断开连接

commit

public void commit()

提交请求

rollback

public void rollback()

回滚请求

getTopicName

public java.lang.String getTopicName()

setTopicName

public void setTopicName(java.lang.String topicName)