程序包 cn.t.util.socket.messaging.stomp

类 StompClient

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.AbstractWebSocket

org.java_websocket.client.WebSocketClient

cn.t.util.socket.messaging.stomp.StompClient

所有已实现的接口:

Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener

public class StompClient
extends org.java_websocket.client.WebSocketClient

字段概要

从类继承的字段 org.java_websocket.client.WebSocketClient

uri

构造器概要

构造器

构造器	说明
StompClient(URI serverUri, Map<String,String> httpHeaders, StompEventHandler stompEventHandler)

方法概要

修饰符和类型	方法	说明
void	connect()
List<InstanceConvert>	getInstanceConvertList()
void	onClose(int code, String reason, boolean remote)
void	onError(Exception ex)
void	onMessage(String message)
void	onOpen(org.java_websocket.handshake.ServerHandshake handshakedata)
void	send(String path, String content)	send
void	setInstanceConvertList(List<InstanceConvert> instanceConvertList)
void	subscribe(String path)	subscribe

从类继承的方法 org.java_websocket.client.WebSocketClient

addHeader, clearHeaders, close, close, close, closeBlocking, closeConnection, connectBlocking, connectBlocking, getAttachment, getConnection, getConnections, getDraft, getLocalSocketAddress, getLocalSocketAddress, getProtocol, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getSocket, getSSLSession, getURI, hasBufferedData, hasSSLSupport, isClosed, isClosing, isFlushAndClose, isOpen, onCloseInitiated, onClosing, onMessage, onSetSSLParameters, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketOpen, onWriteDemand, reconnect, reconnectBlocking, removeHeader, run, send, send, send, sendFragmentedFrame, sendFrame, sendFrame, sendPing, setAttachment, setDnsResolver, setProxy, setSocket, setSocketFactory

从类继承的方法 org.java_websocket.AbstractWebSocket

getConnectionLostTimeout, isReuseAddr, isTcpNoDelay, setConnectionLostTimeout, setReuseAddr, setTcpNoDelay, startConnectionLostTimer, stopConnectionLostTimer

从类继承的方法 org.java_websocket.WebSocketAdapter

onPreparePing, onWebsocketHandshakeReceivedAsClient, onWebsocketHandshakeReceivedAsServer, onWebsocketHandshakeSentAsClient, onWebsocketPing, onWebsocketPong

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

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

构造器详细资料

StompClient

public StompClient(URI serverUri,
                   Map<String,String> httpHeaders,
                   StompEventHandler stompEventHandler)

方法详细资料

connect

public void connect()

覆盖:

connect 在类中 org.java_websocket.client.WebSocketClient

onOpen

public void onOpen(org.java_websocket.handshake.ServerHandshake handshakedata)

指定者:

onOpen 在类中 org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(String message)

指定者:

onMessage 在类中 org.java_websocket.client.WebSocketClient

onClose

public void onClose(int code,
                    String reason,
                    boolean remote)

指定者:

onClose 在类中 org.java_websocket.client.WebSocketClient

onError

public void onError(Exception ex)

指定者:

onError 在类中 org.java_websocket.client.WebSocketClient

subscribe

public void subscribe(String path)
               throws IOException

subscribe

参数:

path - xxx

抛出:

IOException - xxx

send

public void send(String path,
                 String content)
          throws IOException

send

参数:

path - xxx

content - xxx

抛出:

IOException - xxx

getInstanceConvertList

public List<InstanceConvert> getInstanceConvertList()

setInstanceConvertList

public void setInstanceConvertList(List<InstanceConvert> instanceConvertList)