com.supermap.messagequeue
类 STOMPManager
- java.lang.Object
-
- com.supermap.messagequeue.InternalHandle
-
- com.supermap.messagequeue.STOMPManager
-
public class STOMPManager extends InternalHandle
STOMP管理类,基于STOMP协议的消息总线客户端方案
-
-
构造器概要
构造器 构造器和说明 STOMPManager()构造函数
-
方法概要
所有方法 静态方法 实例方法 具体方法 限定符和类型 方法和说明 booleanconnection(java.lang.String uri, java.lang.String usrName, java.lang.String password)建立连接voiddisconnection()断开连接static voidinitializeLibrary()初始化库 在使用前要初始化库,结束后要关闭库STOMPReceivernewReceiver(boolean useTopic, java.lang.String name, java.lang.String clientId)创建一个接收者STOMPSendernewSender(boolean useTopic, java.lang.String name)创建一个发送端static voidshutdownLibrary()关闭库 使用结束后关闭库
-
-
-
方法详细资料
-
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()
关闭库使用结束后关闭库
-
-