public class StompSocket extends AbstractStompSocket implements org.eclipse.jetty.websocket.api.WebSocketListener
certificates, protocolConverter, protocolLock, receiveCounter, remoteAddress, socketTransportStarted, stompInactivityMonitor, wireFormat
Constructor and Description |
---|
StompSocket(String remoteAddress) |
Modifier and Type | Method and Description |
---|---|
void |
handleStopped()
Called when the transport is stopping to allow the dervied classes
a chance to close WebSocket resources.
|
void |
onWebSocketBinary(byte[] arg0,
int arg1,
int arg2) |
void |
onWebSocketClose(int arg0,
String arg1) |
void |
onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session) |
void |
onWebSocketError(Throwable arg0) |
void |
onWebSocketText(String data) |
void |
sendToStomp(StompFrame command) |
doStart, doStop, getCertificates, getInactivityMonitor, getReceiveCounter, getRemoteAddress, getWireFormat, oneway, processStompFrame, sendToActiveMQ, setCertificates
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onException
public StompSocket(String remoteAddress)
public void sendToStomp(StompFrame command) throws IOException
sendToStomp
in interface StompTransport
sendToStomp
in class AbstractStompSocket
IOException
public void handleStopped() throws IOException
AbstractStompSocket
handleStopped
in class AbstractStompSocket
IOException
- if an error occurs during the stop.public void onWebSocketBinary(byte[] arg0, int arg1, int arg2)
onWebSocketBinary
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketClose(int arg0, String arg1)
onWebSocketClose
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session)
onWebSocketConnect
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketError(Throwable arg0)
onWebSocketError
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketText(String data)
onWebSocketText
in interface org.eclipse.jetty.websocket.api.WebSocketListener
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.