com.supermap.messagequeue
类 STOMPManager
- java.lang.Object
-
- com.supermap.messagequeue.InternalHandle
-
- com.supermap.messagequeue.STOMPManager
-
public class STOMPManager extends InternalHandle
STOMP管理类,基于STOMP协议的消息总线客户端方案
-
-
构造器概要
构造器 构造器和说明 STOMPManager()
构造函数
-
方法概要
所有方法 静态方法 实例方法 具体方法 限定符和类型 方法和说明 boolean
connection(java.lang.String uri, java.lang.String usrName, java.lang.String password)
建立连接void
disconnection()
断开连接static void
initializeLibrary()
初始化库 在使用前要初始化库,结束后要关闭库STOMPReceiver
newReceiver(boolean useTopic, java.lang.String name, java.lang.String clientId)
创建一个接收者STOMPSender
newSender(boolean useTopic, java.lang.String name)
创建一个发送端static void
shutdownLibrary()
关闭库 使用结束后关闭库
-
-
-
方法详细资料
-
connection
public boolean connection(java.lang.String uri, java.lang.String usrName, java.lang.String password)
建立连接- 参数:
uri
- 服务地址usrName
- 用户名password
- 用户密码- 返回:
- 连接成功返回true,否则返回false
-
disconnection
public void disconnection()
断开连接
-
newSender
public STOMPSender newSender(boolean useTopic, java.lang.String name)
创建一个发送端- 参数:
useTopic
- 是否使用Topic模式name
- 目的地名- 返回:
- 新建的发送端
-
newReceiver
public STOMPReceiver newReceiver(boolean useTopic, java.lang.String name, java.lang.String clientId)
创建一个接收者- 参数:
useTopic
- 是否使用Topic模式name
- 目的地名称clientId
- 客户端ID- 返回:
- 新建的接收者
-
initializeLibrary
public static void initializeLibrary()
初始化库在使用前要初始化库,结束后要关闭库
-
shutdownLibrary
public static void shutdownLibrary()
关闭库使用结束后关闭库
-
-