Package org.aktin.broker.websocket

Class MyBrokerWebsocket

java.lang.Object

org.aktin.broker.websocket.AbstractBroadcastWebsocket

org.aktin.broker.websocket.MyBrokerWebsocket

public class MyBrokerWebsocket
extends AbstractBroadcastWebsocket

Field Summary

Fields

Modifier and Type	Field	Description
static String	REST_PATH

Constructor Summary

Constructors

Constructor	Description
MyBrokerWebsocket()

Method Summary

Modifier and Type	Method	Description
protected void	addSession(javax.websocket.Session session, Principal user)
static void	broadcastRequestClosed(int requestId, int[] nodeIds)
static void	broadcastRequestPublished(int requestId, int[] nodeIds)
static void	broadcastToNode(int nodeId, String message)
protected boolean	isAuthorized(Principal principal)
protected void	removeSession(javax.websocket.Session session, Principal user)

Methods inherited from class org.aktin.broker.websocket.AbstractBroadcastWebsocket

close, error, getSessionPrincipal, message, message, open

Methods inherited from class java.lang.Object

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

Field Details

REST_PATH

public static final String REST_PATH

See Also:

Constant Field Values

Constructor Details

MyBrokerWebsocket

public MyBrokerWebsocket()

Method Details

broadcastRequestPublished

public static void broadcastRequestPublished(int requestId,
 int[] nodeIds)

broadcastRequestClosed

public static void broadcastRequestClosed(int requestId,
 int[] nodeIds)

broadcastToNode

public static void broadcastToNode(int nodeId,
 String message)

isAuthorized

protected boolean isAuthorized(Principal principal)

Specified by:

isAuthorized in class AbstractBroadcastWebsocket

addSession

protected void addSession(javax.websocket.Session session,
 Principal user)

Specified by:

addSession in class AbstractBroadcastWebsocket

removeSession

protected void removeSession(javax.websocket.Session session,
 Principal user)

Specified by:

removeSession in class AbstractBroadcastWebsocket