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() 关闭库 使用结束后关闭库

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

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

构造器详细资料

STOMPManager

public STOMPManager()

构造函数

方法详细资料

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()

关闭库

使用结束后关闭库