ActiveMQBase

java.lang.Object

com.sh.wf.mq.activemq.ActiveMQBase

直接已知子类:: ActiveMQConsumer, ActiveMQProducer

public abstract class ActiveMQBase extends Object

Description:

Title:首亨软件 - TSS/CRM等

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

字段概要

字段

修饰符和类型

字段

说明

static final String

DEFAULT_TOPIC

protected javax.jms.Session

session

protected String

topicName
构造器概要

构造器

构造器

说明

ActiveMQBase()
方法概要

修饰符和类型

方法

说明

void

commit()

提交请求

boolean

connect()

boolean

connect(int count, int ackMode)

建立连接

void

disconnect()

断开连接

String

getTopicName()

abstract void

processConnect(javax.jms.Topic topic)

void

rollback()

回滚请求

void

setTopicName(String topicName)

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

字段详细资料
- DEFAULT_TOPIC
  
  public static final String DEFAULT_TOPIC
  另请参阅:
  
  常量字段值
- session
  
  protected javax.jms.Session session
- topicName
  
  protected String topicName
构造器详细资料
- 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 String getTopicName()
- setTopicName
  
  public void setTopicName(String topicName)