xdi2.transport.impl.websocket

Class WebSocketTransport

java.lang.Object

xdi2.transport.impl.AbstractTransport<REQUEST,RESPONSE>

xdi2.transport.impl.uri.UriTransport<WebSocketTransportRequest,WebSocketTransportResponse>

xdi2.transport.impl.websocket.WebSocketTransport

All Implemented Interfaces:

Transport<WebSocketTransportRequest,WebSocketTransportResponse>

public class WebSocketTransport
extends UriTransport<WebSocketTransportRequest,WebSocketTransportResponse>

Constructor Summary

Constructors

Constructor and Description
WebSocketTransport()
WebSocketTransport(UriMessagingContainerRegistry uriMessagingContainerRegistry, String endpointPath)

Method Summary

Modifier and Type	Method and Description
void	execute(WebSocketTransportRequest request, WebSocketTransportResponse response)
javax.websocket.Session	findSession(XDIArc toPeerRootXDIArc)
String	getEndpointPath()
UriMessagingContainerRegistry	getUriMessagingContainerRegistry()
void	init()
protected void	processMessage(WebSocketTransportRequest request, WebSocketTransportResponse response, UriMessagingContainerMount uriMessagingContainerMount)
void	registerSession(javax.websocket.Session session, XDIArc toPeerRootXDIArc)
void	setEndpointPath(String endpointPath)
void	setUriMessagingContainerRegistry(UriMessagingContainerRegistry uriMessagingContainerRegistry)
void	shutdown()
void	unregisterSession(javax.websocket.Session session)

Methods inherited from class xdi2.transport.impl.AbstractTransport

createExecutionContext, execute, getCurrent, getCurrentAsString, getInterceptors, getRequest, getResponse, getStartup, getStartupAsSeconds, getStartupAsString, getTransport, isInitialized, isResponseMessage, putRequest, putResponse, putTransport, setInterceptors

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketTransport

public WebSocketTransport(UriMessagingContainerRegistry uriMessagingContainerRegistry,
                          String endpointPath)

WebSocketTransport

public WebSocketTransport()

Method Detail

init

public void init()
          throws Exception

Specified by:

init in interface Transport<WebSocketTransportRequest,WebSocketTransportResponse>

Overrides:

init in class AbstractTransport<WebSocketTransportRequest,WebSocketTransportResponse>

Throws:

Exception

shutdown

public void shutdown()
              throws Exception

Specified by:

shutdown in interface Transport<WebSocketTransportRequest,WebSocketTransportResponse>

Overrides:

shutdown in class AbstractTransport<WebSocketTransportRequest,WebSocketTransportResponse>

Throws:

Exception

execute

public void execute(WebSocketTransportRequest request,
                    WebSocketTransportResponse response)
             throws IOException

Throws:

IOException

processMessage

protected void processMessage(WebSocketTransportRequest request,
                              WebSocketTransportResponse response,
                              UriMessagingContainerMount uriMessagingContainerMount)
                       throws Xdi2TransportException,
                              IOException

Throws:

Xdi2TransportException

IOException

registerSession

public void registerSession(javax.websocket.Session session,
                            XDIArc toPeerRootXDIArc)

unregisterSession

public void unregisterSession(javax.websocket.Session session)

findSession

public javax.websocket.Session findSession(XDIArc toPeerRootXDIArc)

getUriMessagingContainerRegistry

public UriMessagingContainerRegistry getUriMessagingContainerRegistry()

Specified by:

getUriMessagingContainerRegistry in class UriTransport<WebSocketTransportRequest,WebSocketTransportResponse>

setUriMessagingContainerRegistry

public void setUriMessagingContainerRegistry(UriMessagingContainerRegistry uriMessagingContainerRegistry)

getEndpointPath

public String getEndpointPath()

setEndpointPath

public void setEndpointPath(String endpointPath)