org.apache.activemq.transport.ws

Class StompWSConnection

java.lang.Object

org.eclipse.jetty.websocket.api.WebSocketAdapter

org.apache.activemq.transport.ws.StompWSConnection

All Implemented Interfaces:

org.eclipse.jetty.websocket.api.WebSocketListener

public class StompWSConnection
extends org.eclipse.jetty.websocket.api.WebSocketAdapter
implements org.eclipse.jetty.websocket.api.WebSocketListener

STOMP over WS based Connection class

Constructor Summary

Constructors

Constructor and Description
StompWSConnection()

Method Summary

Modifier and Type	Method and Description
void	awaitConnection()
boolean	awaitConnection(long time, TimeUnit unit)
void	close()
int	getCloseCode()
String	getCloseMessage()
protected org.eclipse.jetty.websocket.api.Session	getConnection()
boolean	isConnected()
void	keepAlive()
void	onWebSocketClose(int statusCode, String reason)
void	onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session)
void	onWebSocketText(String data)
String	receive()
String	receive(long timeout, TimeUnit unit)
String	receiveNoWait()
void	sendFrame(StompFrame frame)
void	sendRawFrame(String rawFrame)

Methods inherited from class org.eclipse.jetty.websocket.api.WebSocketAdapter

getRemote, getSession, isNotConnected, onWebSocketBinary, onWebSocketError

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.websocket.api.WebSocketListener

onWebSocketBinary, onWebSocketError

Constructor Detail

StompWSConnection

public StompWSConnection()

Method Detail

isConnected

public boolean isConnected()

Overrides:

isConnected in class org.eclipse.jetty.websocket.api.WebSocketAdapter

close

public void close()

getConnection

protected org.eclipse.jetty.websocket.api.Session getConnection()

sendRawFrame

public void sendRawFrame(String rawFrame)
                  throws Exception

Throws:

Exception

sendFrame

public void sendFrame(StompFrame frame)
               throws Exception

Throws:

Exception

keepAlive

public void keepAlive()
               throws Exception

Throws:

Exception

receive

public String receive()
               throws Exception

Throws:

Exception

receive

public String receive(long timeout,
                      TimeUnit unit)
               throws Exception

Throws:

Exception

receiveNoWait

public String receiveNoWait()
                     throws Exception

Throws:

Exception

awaitConnection

public void awaitConnection()
                     throws InterruptedException

Throws:

InterruptedException

awaitConnection

public boolean awaitConnection(long time,
                               TimeUnit unit)
                        throws InterruptedException

Throws:

InterruptedException

getCloseCode

public int getCloseCode()

getCloseMessage

public String getCloseMessage()

onWebSocketText

public void onWebSocketText(String data)

Specified by:

onWebSocketText in interface org.eclipse.jetty.websocket.api.WebSocketListener

Overrides:

onWebSocketText in class org.eclipse.jetty.websocket.api.WebSocketAdapter

onWebSocketClose

public void onWebSocketClose(int statusCode,
                             String reason)

Specified by:

onWebSocketClose in interface org.eclipse.jetty.websocket.api.WebSocketListener

Overrides:

onWebSocketClose in class org.eclipse.jetty.websocket.api.WebSocketAdapter

onWebSocketConnect

public void onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session)

Specified by:

onWebSocketConnect in interface org.eclipse.jetty.websocket.api.WebSocketListener

Overrides:

onWebSocketConnect in class org.eclipse.jetty.websocket.api.WebSocketAdapter