cn.t.util.socket.messaging.stomp

Class StompClient

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.AbstractWebSocket

org.java_websocket.client.WebSocketClient

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

All Implemented Interfaces:

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

public class StompClient
extends org.java_websocket.client.WebSocketClient

Nested Class Summary

Nested classes/interfaces inherited from interface org.java_websocket.WebSocket

org.java_websocket.WebSocket.READYSTATE, org.java_websocket.WebSocket.Role

Field Summary

Fields inherited from class org.java_websocket.client.WebSocketClient

uri

Fields inherited from interface org.java_websocket.WebSocket

DEFAULT_PORT, DEFAULT_WSS_PORT

Constructor Summary

Constructors

Constructor and Description
StompClient(URI serverUri, Map<String,String> httpHeaders, StompEventHandler stompEventHandler)

Method Summary

Modifier and Type	Method and Description
void	connect()
List<InstanceConvert>	getInstanceConvertList()
static void	main(String[] args)
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

Methods inherited from class org.java_websocket.client.WebSocketClient

close, close, close, closeBlocking, closeConnection, connectBlocking, getAttachment, getConnection, getConnections, getDraft, getLocalSocketAddress, getLocalSocketAddress, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getSocket, getURI, hasBufferedData, isClosed, isClosing, isConnecting, isFlushAndClose, isOpen, onCloseInitiated, onClosing, onFragment, onMessage, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketMessageFragment, onWebsocketOpen, onWriteDemand, reconnect, reconnectBlocking, run, send, send, send, sendFragmentedFrame, sendFrame, sendFrame, sendPing, setAttachment, setProxy, setSocket

Methods inherited from class org.java_websocket.AbstractWebSocket

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

Methods inherited from class org.java_websocket.WebSocketAdapter

onWebsocketHandshakeReceivedAsClient, onWebsocketHandshakeReceivedAsServer, onWebsocketHandshakeSentAsClient, onWebsocketPing, onWebsocketPong

Methods inherited from class java.lang.Object

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

Constructor Detail

StompClient

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

Method Detail

main

public static void main(String[] args)

connect

public void connect()

Overrides:

connect in class org.java_websocket.client.WebSocketClient

onOpen

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

Specified by:

onOpen in class org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(String message)

Specified by:

onMessage in class org.java_websocket.client.WebSocketClient

onClose

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

Specified by:

onClose in class org.java_websocket.client.WebSocketClient

onError

public void onError(Exception ex)

Specified by:

onError in class org.java_websocket.client.WebSocketClient

subscribe

public void subscribe(String path)
               throws IOException

subscribe

Parameters:

path - xxx

Throws:

IOException - xxx

send

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

send

Parameters:

path - xxx

content - xxx

Throws:

IOException - xxx

getInstanceConvertList

public List<InstanceConvert> getInstanceConvertList()

setInstanceConvertList

public void setInstanceConvertList(List<InstanceConvert> instanceConvertList)