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()
        关闭库

        使用结束后关闭库